1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
package options
import (
"sort"
"sync"
"github.com/argoproj-labs/argocd-image-updater/registry-scanner/pkg/log"
)
// ManifestOptions define some options when retrieving image manifests
type ManifestOptions struct {
platforms map[string]bool
mutex sync.RWMutex
metadata bool
logger *log.LogContext
}
// NewManifestOptions returns an initialized ManifestOptions struct
func NewManifestOptions() *ManifestOptions {
return &ManifestOptions{
platforms: make(map[string]bool),
metadata: false,
}
}
// PlatformKey returns a string usable as platform key
func PlatformKey(os string, arch string, variant string) string {
key := os + "/" + arch
if variant != "" {
key += "/" + variant
}
return key
}
// WantsPlatform returns true if given platform matches the platform set in options
func (o *ManifestOptions) WantsPlatform(os string, arch string, variant string) bool {
o.mutex.RLock()
defer o.mutex.RUnlock()
if len(o.platforms) == 0 {
return true
}
_, ok := o.platforms[PlatformKey(os, arch, variant)]
if ok {
return true
}
// if no exact match, and the passed platform has variant, it may be a more
// specific variant of the platform specified in options. So compare os/arch only
if variant != "" {
_, ok = o.platforms[PlatformKey(os, arch, "")]
return ok
}
return false
}
// WithPlatform sets a platform filter for options o
func (o *ManifestOptions) WithPlatform(os string, arch string, variant string) *ManifestOptions {
o.mutex.Lock()
defer o.mutex.Unlock()
if o.platforms == nil {
o.platforms = map[string]bool{}
}
o.platforms[PlatformKey(os, arch, variant)] = true
return o
}
func (o *ManifestOptions) Platforms() []string {
o.mutex.RLock()
defer o.mutex.RUnlock()
if len(o.platforms) == 0 {
return []string{}
}
keys := make([]string, 0, len(o.platforms))
for k := range o.platforms {
keys = append(keys, k)
}
// We sort the slice before returning it, to guarantee stable order
sort.Strings(keys)
return keys
}
// WantsMetdata returns true if metadata should be requested
func (o *ManifestOptions) WantsMetadata() bool {
return o.metadata
}
// WithMetadata sets metadata to be requested
func (o *ManifestOptions) WithMetadata(val bool) *ManifestOptions {
o.metadata = val
return o
}
// WithLogger sets the log context to use for the given manifest options.
func (o *ManifestOptions) WithLogger(logger *log.LogContext) *ManifestOptions {
o.logger = logger
return o
}
// Logger gets the configured log context for given manifest options. If logger
// is nil, returns a default log context.
func (o *ManifestOptions) Logger() *log.LogContext {
if o.logger == nil {
return log.WithContext()
} else {
return o.logger
}
}
|
