@@ -39,26 +39,26 @@ var (
39
39
openshiftInClusterMonitoringNamespace = "openshift-monitoring"
40
40
)
41
41
42
- var _ manager.Runnable = & OperatorMetrics {}
42
+ var _ manager.Runnable = operatorMetrics {}
43
43
44
- type OperatorMetrics struct {
44
+ type operatorMetrics struct {
45
45
kubeClient client.Client
46
46
log logr.Logger
47
47
}
48
48
49
- func NewOperatorMetrics (config * rest.Config , scheme * runtime.Scheme , log logr.Logger ) (OperatorMetrics , error ) {
49
+ func NewOperatorMetrics (config * rest.Config , scheme * runtime.Scheme , log logr.Logger ) (manager. Runnable , error ) {
50
50
kubeClient , err := client .New (config , client.Options {Scheme : scheme })
51
51
if err != nil {
52
- return OperatorMetrics {}, err
52
+ return operatorMetrics {}, err
53
53
}
54
54
55
- return OperatorMetrics {
55
+ return operatorMetrics {
56
56
kubeClient : kubeClient ,
57
57
log : log ,
58
58
}, nil
59
59
}
60
60
61
- func (om OperatorMetrics ) Start (ctx context.Context ) error {
61
+ func (om operatorMetrics ) Start (ctx context.Context ) error {
62
62
err := om .createOperatorMetricsServiceMonitor (ctx )
63
63
if err != nil {
64
64
om .log .Error (err , "error creating Service Monitor for operator metrics" )
@@ -67,19 +67,19 @@ func (om OperatorMetrics) Start(ctx context.Context) error {
67
67
return nil
68
68
}
69
69
70
- func (om OperatorMetrics ) NeedLeaderElection () bool {
70
+ func (om operatorMetrics ) NeedLeaderElection () bool {
71
71
return true
72
72
}
73
73
74
- func (om OperatorMetrics ) caConfigMapExists () bool {
74
+ func (om operatorMetrics ) caConfigMapExists () bool {
75
75
return om .kubeClient .Get (context .Background (), client.ObjectKey {
76
76
Name : caBundleConfigMap ,
77
77
Namespace : openshiftInClusterMonitoringNamespace ,
78
78
}, & corev1.ConfigMap {},
79
79
) == nil
80
80
}
81
81
82
- func (om OperatorMetrics ) getOwnerReferences (ctx context.Context , namespace string ) (metav1.OwnerReference , error ) {
82
+ func (om operatorMetrics ) getOwnerReferences (ctx context.Context , namespace string ) (metav1.OwnerReference , error ) {
83
83
var deploymentList appsv1.DeploymentList
84
84
85
85
listOptions := []client.ListOption {
@@ -110,7 +110,7 @@ func (om OperatorMetrics) getOwnerReferences(ctx context.Context, namespace stri
110
110
return ownerRef , nil
111
111
}
112
112
113
- func (om OperatorMetrics ) createOperatorMetricsServiceMonitor (ctx context.Context ) error {
113
+ func (om operatorMetrics ) createOperatorMetricsServiceMonitor (ctx context.Context ) error {
114
114
rawNamespace , err := os .ReadFile (namespaceFile )
115
115
if err != nil {
116
116
return fmt .Errorf ("error reading namespace file: %w" , err )
0 commit comments