- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 142 for workqueue (0.19 sec)
-
pkg/kubelet/logs/container_log_manager_test.go
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, 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) -
pkg/kubelet/util/queue/work_queue_test.go
tests := []struct { clock clock.Clock expectedWorkQueue WorkQueue }{ { clock: clock.RealClock{}, expectedWorkQueue: &basicWorkQueue{queue: make(map[types.UID]time.Time), clock: clock.RealClock{}}, }, } for _, test := range tests { workQueue := NewBasicWorkQueue(test.clock) assert.Equal(t, test.expectedWorkQueue, workQueue) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
"k8s.io/client-go/util/workqueue" "istio.io/istio/pkg/config" istiolog "istio.io/istio/pkg/log" ) type ReconcilerFn func(key types.NamespacedName) error // Queue defines an abstraction around Kubernetes' workqueue. // Items enqueued are deduplicated; this generally means relying on ordering of events in the queue is not feasible. type Queue struct { queue workqueue.RateLimitingInterface
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DefaultWorkerExecutor.java
this.projectCacheDir = projectCacheDir; } @Override public WorkQueue noIsolation() { return noIsolation(Actions.doNothing()); } @Override public WorkQueue classLoaderIsolation() { return classLoaderIsolation(Actions.doNothing()); } @Override public WorkQueue processIsolation() { return processIsolation(Actions.doNothing()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
e := &Publisher{ client: cl, rootCA: rootCA, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "root_ca_cert_publisher", }, ), } cmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
test/typeparam/graph.go
func (g *_Graph[_Node, _Edge]) ShortestPath(from, to _Node) ([]_Edge, error) { visited := make(map[_Node]bool) visited[from] = true workqueue := []nodePath[_Node, _Edge]{nodePath[_Node, _Edge]{from, nil}} for len(workqueue) > 0 { current := workqueue workqueue = nil for _, np := range current { edges := np.node.Edges() for _, edge := range edges { a, b := edge.Nodes() if a == np.node {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
options.FieldSelector = fields.OneTermEqualSelector("metadata.name", ConfigMapName).String() }) c := &Controller{ configMapClient: cs.CoreV1(), queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "legacy_token_tracking_controller"}, ), configMapInformer: informer, configMapCache: informer.GetIndexer(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
clusterRoleClient: clusterRoleClient, clusterRoleLister: clusterRoleInformer.Lister(), clusterRolesSynced: clusterRoleInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "ClusterRoleAggregator", }, ), } c.syncHandler = c.syncClusterRole
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
ret := &DynamicCertKeyPairContent{ name: name, certFile: certFile, keyFile: keyFile, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: fmt.Sprintf("DynamicCABundle-%s", purpose)}, ), } if err := ret.loadCertKeyPair(); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
pvListerSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] } // NewPVProtectionController returns a new *Controller. func NewPVProtectionController(logger klog.Logger, pvInformer coreinformers.PersistentVolumeInformer, cl clientset.Interface) *Controller { e := &Controller{ client: cl, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0)