Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for NewTypedRateLimitingQueueWithConfig (0.48 sec)

  1. pkg/kubelet/logs/container_log_manager_test.go

    			MaxSize:  testMaxSize,
    			MaxFiles: testMaxFiles,
    		},
    		osInterface: container.RealOS{},
    		clock:       testingclock.NewFakeClock(now),
    		mutex:       sync.Mutex{},
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "kubelet_log_rotate_manager"},
    		),
    		maxWorkers:       10,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pkg/controller/storageversiongc/gc_controller.go

    		storageVersionSynced: storageVersionInformer.Informer().HasSynced,
    		leaseQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "storage_version_garbage_collector_leases"},
    		),
    		storageVersionQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/controller/repairip.go

    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    		cidrQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "servicecidrs"},
    		),
    		svcQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  4. pkg/controller/serviceaccount/tokens_controller.go

    		rootCA: options.RootCA,
    
    		syncServiceAccountQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[serviceAccountQueueKey](),
    			workqueue.TypedRateLimitingQueueConfig[serviceAccountQueueKey]{Name: "serviceaccount_tokens_service"},
    		),
    		syncSecretQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[secretQueueKey](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go

    	c := &DynamicServingCertificateController{
    		baseTLSConfig: baseTLSConfig,
    		clientCA:      clientCA,
    		servingCert:   servingCert,
    		sniCerts:      sniCerts,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "DynamicServingCertificateController"},
    		),
    		eventRecorder: eventRecorder,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. pkg/controller/resourcequota/resource_quota_controller.go

    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resourcequota_primary"},
    		),
    		missingUsageQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  7. pkg/controller/deployment/progress_test.go

    			nowFn:    func() time.Time { return metav1.Date(2017, 2, 15, 18, 51, 00, 00, time.UTC).Time },
    			expected: time.Duration(0),
    		},
    	}
    
    	dc := &DeploymentController{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "doesnt_matter",
    			},
    		),
    	}
    	dc.enqueueDeployment = dc.enqueue
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/graph_builder.go

    	attemptToDelete := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    		workqueue.TypedRateLimitingQueueConfig[*node]{
    			Name: "garbage_collector_attempt_to_delete",
    		},
    	)
    	attemptToOrphan := workqueue.NewTypedRateLimitingQueueWithConfig(
    		workqueue.DefaultTypedControllerRateLimiter[*node](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

    		groupHeadersKey:        groupHeadersKey,
    		extraHeaderPrefixesKey: extraHeaderPrefixesKey,
    		allowedClientNamesKey:  allowedClientNamesKey,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "RequestHeaderAuthRequestController"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    		groupHandler:    groupHandler,
    		resourceManager: resourceManager,
    		crdLister:       crdInformer.Lister(),
    		crdsSynced:      crdInformer.Informer().HasSynced,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "DiscoveryController"},
    		),
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top