/
docker.go
59 lines (52 loc) 路 1.45 KB
/
docker.go
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
package cluster
import (
"context"
anywherev1 "github.com/aws/eks-anywhere/pkg/api/v1alpha1"
)
func dockerEntry() *ConfigManagerEntry {
return &ConfigManagerEntry{
APIObjectMapping: map[string]APIObjectGenerator{
anywherev1.DockerDatacenterKind: func() APIObject {
return &anywherev1.DockerDatacenterConfig{}
},
},
Processors: []ParsedProcessor{
processDockerDatacenter,
},
Validations: []Validation{
func(c *Config) error {
if c.DockerDatacenter != nil {
return c.DockerDatacenter.Validate()
}
return nil
},
func(c *Config) error {
if c.DockerDatacenter != nil {
if err := validateSameNamespace(c, c.DockerDatacenter); err != nil {
return err
}
}
return nil
},
},
}
}
func processDockerDatacenter(c *Config, objects ObjectLookup) {
if c.Cluster.Spec.DatacenterRef.Kind == anywherev1.DockerDatacenterKind {
datacenter := objects.GetFromRef(c.Cluster.APIVersion, c.Cluster.Spec.DatacenterRef)
if datacenter != nil {
c.DockerDatacenter = datacenter.(*anywherev1.DockerDatacenterConfig)
}
}
}
func getDockerDatacenter(ctx context.Context, client Client, c *Config) error {
if c.Cluster.Spec.DatacenterRef.Kind != anywherev1.DockerDatacenterKind {
return nil
}
datacenter := &anywherev1.DockerDatacenterConfig{}
if err := client.Get(ctx, c.Cluster.Spec.DatacenterRef.Name, c.Cluster.Namespace, datacenter); err != nil {
return err
}
c.DockerDatacenter = datacenter
return nil
}