- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for syncSecret (0.46 sec)
-
pkg/controller/serviceaccount/tokens_controller.go
return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, e.syncServiceAccount, 0) go wait.UntilWithContext(ctx, e.syncSecret, 0) } <-ctx.Done() logger.V(1).Info("Shutting down") } func (e *TokensController) queueServiceAccountSync(obj interface{}) { if serviceAccount, ok := obj.(*v1.ServiceAccount); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller_test.go
for { if controller.syncServiceAccountQueue.Len() > 0 { controller.syncServiceAccount(ctx) } if controller.syncSecretQueue.Len() > 0 { controller.syncSecret(ctx) } // The queues still have things to work on if controller.syncServiceAccountQueue.Len() > 0 || controller.syncSecretQueue.Len() > 0 { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 21.5K bytes - Viewed (0)