Skip to content

Commit 4dabb4a

Browse files
authored
K8SPSMDB-1003: Disable cache reflector for corev1.Node (#1533)
1 parent ae8cfeb commit 4dabb4a

File tree

2 files changed

+12
-4
lines changed

2 files changed

+12
-4
lines changed

pkg/controller/perconaservermongodb/psmdb_controller.go

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,18 @@ func newReconciler(mgr manager.Manager) (reconcile.Reconciler, error) {
7575
return nil, errors.Wrap(err, "failed to get operator pod image")
7676
}
7777

78+
client, err := client.New(mgr.GetConfig(), client.Options{
79+
Scheme: mgr.GetScheme(),
80+
Cache: &client.CacheOptions{
81+
DisableFor: []client.Object{&corev1.Node{}},
82+
},
83+
})
84+
if err != nil {
85+
return nil, errors.Wrap(err, "create client")
86+
}
87+
7888
return &ReconcilePerconaServerMongoDB{
79-
client: mgr.GetClient(),
89+
client: client,
8090
scheme: mgr.GetScheme(),
8191
serverVersion: sv,
8292
reconcileIn: time.Second * 5,

pkg/psmdb/getters.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -174,9 +174,7 @@ func GetNodeLabels(ctx context.Context, cl client.Client, cr *api.PerconaServerM
174174

175175
node := &corev1.Node{}
176176

177-
err := cl.Get(ctx, client.ObjectKey{
178-
Name: pod.Spec.NodeName,
179-
}, node)
177+
err := cl.Get(ctx, client.ObjectKey{Name: pod.Spec.NodeName}, node)
180178
if err != nil {
181179
return nil, errors.Wrapf(err, "failed to get node %s", pod.Spec.NodeName)
182180
}

0 commit comments

Comments
 (0)