Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newTokenCleaner (0.24 sec)

  1. pkg/controller/bootstrap/tokencleaner_test.go

    	api "k8s.io/kubernetes/pkg/apis/core"
    )
    
    func newTokenCleaner() (*TokenCleaner, *fake.Clientset, coreinformers.SecretInformer, error) {
    	options := DefaultTokenCleanerOptions()
    	cl := fake.NewSimpleClientset()
    	informerFactory := informers.NewSharedInformerFactory(cl, options.SecretResync)
    	secrets := informerFactory.Core().V1().Secrets()
    	tcc, err := NewTokenCleaner(cl, secrets, options)
    	if err != nil {
    		return nil, nil, nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  2. pkg/controller/bootstrap/tokencleaner.go

    	secretLister corelisters.SecretLister
    
    	// secretSynced returns true if the secret shared informer has been synced at least once.
    	secretSynced cache.InformerSynced
    
    	queue workqueue.TypedRateLimitingInterface[string]
    }
    
    // NewTokenCleaner returns a new *NewTokenCleaner.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. cmd/kube-controller-manager/app/bootstrap.go

    		isDisabledByDefault: true,
    	}
    }
    func startTokenCleanerController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) {
    	tcc, err := bootstrap.NewTokenCleaner(
    		controllerContext.ClientBuilder.ClientOrDie("token-cleaner"),
    		controllerContext.InformerFactory.Core().V1().Secrets(),
    		bootstrap.DefaultTokenCleanerOptions(),
    	)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 11:28:02 UTC 2023
    - 2.4K bytes
    - Viewed (0)
Back to top