- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newTokenCleaner (0.18 sec)
-
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) -
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) -
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)