Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for syncSecret (0.34 sec)

  1. 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)
  2. 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)
Back to top