- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 121 for dequeue1 (0.13 sec)
-
pilot/pkg/xds/monitoring.go
[]float64{.01, .1, 1, 3, 5, 10, 20, 30}, ) proxiesQueueTime = monitoring.NewDistribution( "pilot_proxy_queue_time", "Time in seconds, a proxy is in the push queue before being dequeued.", []float64{.1, .5, 1, 3, 5, 10, 20, 30}, ) pushTriggers = monitoring.NewSum( "pilot_push_triggers", "Total number of times a push was triggered, labeled by reason for the push.", )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
return } logger.V(3).Info("Delete event for unscheduled pod", "pod", klog.KObj(pod)) if err := sched.SchedulingQueue.Delete(pod); err != nil { utilruntime.HandleError(fmt.Errorf("unable to dequeue %T: %v", obj, err)) } fwk, err := sched.frameworkForPod(pod) if err != nil { // This shouldn't happen, because we only accept for scheduling the pods
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
src/runtime/mgcwork.go
flushed = true } n := copy(wbuf.obj[wbuf.nobj:], obj) wbuf.nobj += n obj = obj[n:] } if flushed && gcphase == _GCmark { gcController.enlistWorker() } } // tryGet dequeues a pointer for the garbage collector to trace. // // If there are no pointers remaining in this gcWork or in the global // queue, tryGet returns 0. Note that there may still be pointers in
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
switch { case errors.IsNotFound(err): // may be cronjob is deleted, don't need to requeue this key logger.V(4).Info("CronJob not found, may be it is deleted", "cronjob", klog.KObj(cronJob), "err", err) return nil, nil case err != nil: // for other transient apiserver error requeue with exponential backoff return nil, err } jobsToBeReconciled, err := jm.getJobsToBeReconciled(cronJob)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
// entropy as it shuffle-shards the request into a queue. The // descr1 and descr2 values play no role in the logic but appear // in log messages. This method always returns quickly (without // waiting for the request to be dequeued). If this method // returns a nil Request value then caller should reject the // request and the returned bool indicates whether the QueueSet // was idle at the moment of the return. Otherwise idle==false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
key, err := controller.KeyFunc(obj) if err != nil { utilruntime.HandleError(err) return } tc.queue.Add(key) } // worker runs a thread that dequeues secrets, handles them, and marks them done. func (tc *TokenCleaner) worker(ctx context.Context) { for tc.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
src/runtime/tracebuf.go
func (q *traceBufQueue) push(buf *traceBuf) { buf.link = nil if q.head == nil { q.head = buf } else { q.tail.link = buf } q.tail = buf } // pop dequeues from the queue of buffers. func (q *traceBufQueue) pop() *traceBuf { buf := q.head if buf == nil { return nil } q.head = buf.link if q.head == nil { q.tail = nil } buf.link = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/certificates/cleaner/cleaner.go
defer logger.Info("Shutting down CSR cleaner controller") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ccc.worker, pollingInterval) } <-ctx.Done() } // worker runs a thread that dequeues CSRs, handles them, and marks them done. func (ccc *CSRCleanerController) worker(ctx context.Context) { logger := klog.FromContext(ctx) csrs, err := ccc.csrLister.List(labels.Everything()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 8K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
rs.OwnerReferences = nil f.objects = append(f.objects, rs) f.rsLister = append(f.rsLister, rs) // Expect to only recheck DeletionTimestamp. f.expectGetDeploymentAction(d) // Sync should fail and requeue to let cache catch up. // Don't start informers, since we don't want cache to catch up for this test. f.runExpectError(ctx, testutil.GetKey(d, t), false) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0)