-
Notifications
You must be signed in to change notification settings - Fork 300
/
observed.go
83 lines (72 loc) · 2.38 KB
/
observed.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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
package globalconfig
import (
"context"
"fmt"
configv1 "github.com/openshift/api/config/v1"
"github.com/openshift/hypershift/support/api"
"github.com/openshift/hypershift/support/util"
corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/runtime"
utilerrors "k8s.io/apimachinery/pkg/util/errors"
ctrl "sigs.k8s.io/controller-runtime"
"sigs.k8s.io/controller-runtime/pkg/client"
)
const (
observedConfigKey = "config"
)
type ObservedConfig struct {
Build *configv1.Build
Project *configv1.Project
}
func ReconcileObservedConfig(cm *corev1.ConfigMap, config runtime.Object) error {
serializedConfig, err := util.SerializeResource(config, api.Scheme)
if err != nil {
return fmt.Errorf("cannot serialize config: %w", err)
}
cm.Data = map[string]string{observedConfigKey: serializedConfig}
return nil
}
func deserializeObservedConfig(cm *corev1.ConfigMap, config runtime.Object) error {
serializedConfig, exists := cm.Data[observedConfigKey]
if !exists {
return fmt.Errorf("observed config key not found in configmap")
}
return util.DeserializeResource(serializedConfig, config, api.Scheme)
}
// ReadObservedConfig reads global configuration resources from configmaps that
// were created by the hosted-cluster-config-operator from resources inside the
// guest cluster.
func ReadObservedConfig(ctx context.Context, c client.Client, observedConfig *ObservedConfig, namespace string) error {
log := ctrl.LoggerFrom(ctx)
var errs []error
configs := map[string]struct {
observed *corev1.ConfigMap
dest runtime.Object
}{
"project": {
observed: ObservedProjectConfig(namespace),
dest: ProjectConfig(),
},
"build": {
observed: ObservedBuildConfig(namespace),
dest: BuildConfig(),
},
}
for _, config := range configs {
if err := c.Get(ctx, client.ObjectKeyFromObject(config.observed), config.observed); err != nil {
if errors.IsNotFound(err) {
continue
}
errs = append(errs, err)
continue
}
log.Info("Observed global configuration", "name", config.observed.Name, "resourceVersion", config.observed.ResourceVersion)
if err := deserializeObservedConfig(config.observed, config.dest); err != nil {
errs = append(errs, err)
}
}
observedConfig.Build = configs["build"].dest.(*configv1.Build)
observedConfig.Project = configs["project"].dest.(*configv1.Project)
return utilerrors.NewAggregate(errs)
}