Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for DefaultTypedControllerRateLimiter (0.45 sec)

  1. pkg/kubelet/logs/container_log_manager_test.go

    		},
    		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,
    		monitoringPeriod: v1.Duration{Duration: 10 * time.Second},
    	}
    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

    		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

    		cidrQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "servicecidrs"},
    		),
    		svcQueue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "services"},
    		),
    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

    		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/authentication/request/headerrequest/requestheader_controller.go

    		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)
  6. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go

    		baseTLSConfig: baseTLSConfig,
    		clientCA:      clientCA,
    		servingCert:   servingCert,
    		sniCerts:      sniCerts,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "DynamicServingCertificateController"},
    		),
    		eventRecorder: eventRecorder,
    	}
    
    	return c
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. 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](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "resourcequota_priority"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  8. pkg/controller/deployment/progress_test.go

    			expected: time.Duration(0),
    		},
    	}
    
    	dc := &DeploymentController{
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{
    				Name: "doesnt_matter",
    			},
    		),
    	}
    	dc.enqueueDeployment = dc.enqueue
    
    	for _, test := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. 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](),
    		workqueue.TypedRateLimitingQueueConfig[*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)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    		resourceManager: resourceManager,
    		crdLister:       crdInformer.Lister(),
    		crdsSynced:      crdInformer.Informer().HasSynced,
    
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](),
    			workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "DiscoveryController"},
    		),
    	}
    
    	crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    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