- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 112 for dequeue0 (1 sec)
-
guava/src/com/google/common/base/FinalizableReferenceQueue.java
import java.net.URL; import java.net.URLClassLoader; import java.util.logging.Level; import java.util.logging.Logger; import javax.annotation.CheckForNull; /** * A reference queue with an associated background thread that dequeues references and invokes * {@link FinalizableReference#finalizeReferent()} on them. * * <p>Keep a strong reference to this object until all of the associated referents have been
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/queue/delay_test.go
sorted := []*delayTask{t1, t2, t3, t4} // fill in an unsorted order unsorted := []*delayTask{t4, t2, t3, t1} for _, task := range unsorted { heap.Push(pq, task) } // dequeue should be in order for i, task := range sorted { peeked := pq.Peek() popped := heap.Pop(pq) if task != popped { t.Fatalf("pop %d was not in order", i) } if peeked != popped {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
import java.net.URL; import java.net.URLClassLoader; import java.util.logging.Level; import java.util.logging.Logger; import javax.annotation.CheckForNull; /** * A reference queue with an associated background thread that dequeues references and invokes * {@link FinalizableReference#finalizeReferent()} on them. * * <p>Keep a strong reference to this object until all of the associated referents have been
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/controller/cronjob/utils.go
return earliestTime, nil, missedSchedules, nil } return earliestTime, &mostRecentTime, missedSchedules, nil } // nextScheduleTimeDuration returns the time duration to requeue based on // the schedule and last schedule time. It adds a 100ms padding to the next requeue to account // for Network Time Protocol(NTP) time skews. If the time drifts the adjustment, which in most
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
configMapLister corev1listers.ConfigMapLister configMapClient corev1client.ConfigMapsGetter namespaceClient corev1client.NamespacesGetter // queue is where incoming work is placed to de-dup and to allow "easy" rate limited requeues on errors. // we only ever place one entry in here, but it is keyed as usual: namespace/name queue workqueue.TypedRateLimitingInterface[string] // kubeSystemConfigMapInformer is tracked so that we can start these on Run
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
expected: time.Duration(-1), }, { name: "complete deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 3, nil), status: newDeploymentStatus(3, 3, 3), expected: time.Duration(-1), }, { name: "already failed deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 0, failed), status: newDeploymentStatus(3, 3, 0),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
// Reconcile reads that state of the cluster for a IstioOperator object and makes changes based on the state read // and what is in the IstioOperator.Spec // Note: // The Controller will requeue the Request to be processed again if the returned error is non-nil or // Result.Requeue is true, otherwise upon completion it will remove the work from the queue. func (r *ReconcileIstioOperator) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, cc.worker, time.Second) } <-ctx.Done() } // worker runs a thread that dequeues CSRs, handles them, and marks them done. func (cc *CertificateController) worker(ctx context.Context) { for cc.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %#v: %v", ss, err)) return } ssc.queue.AddAfter(key, duration) } // processNextWorkItem dequeues items, processes them, and marks them done. It enforces that the syncHandler is never // invoked concurrently with the same key. func (ssc *StatefulSetController) processNextWorkItem(ctx context.Context) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
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)