chore: Add readiness check on cache sync (#1593)

kubernetes-sigs · Aug 27, 2024 · dccd9c8 · dccd9c8
1 parent d7c8ccf
commit dccd9c8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/operator/operator.go b/pkg/operator/operator.go
@@ -204,7 +204,9 @@ func NewOperator() (context.Context, *Operator) {
 	lo.Must0(mgr.GetFieldIndexer().IndexField(ctx, &storagev1.VolumeAttachment{}, "spec.nodeName", func(o client.Object) []string {
 		return []string{o.(*storagev1.VolumeAttachment).Spec.NodeName}
 	}), "failed to setup volumeattachment indexer")
-
+	lo.Must0(mgr.AddReadyzCheck("manager", func(req *http.Request) error {
+		return lo.Ternary(mgr.GetCache().WaitForCacheSync(req.Context()), nil, fmt.Errorf("failed to sync caches"))
+	}))
 	lo.Must0(mgr.AddHealthzCheck("healthz", healthz.Ping))
 	lo.Must0(mgr.AddReadyzCheck("readyz", healthz.Ping))