- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for dequeue0 (0.15 sec)
-
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
syncHandler func(groupVersion schema.GroupVersion) error syncedInitialSet chan struct{} // queue is where incoming work is placed to de-dup and to allow "easy" rate limited requeues on errors // this is actually keyed by a groupVersion queue workqueue.TypedRateLimitingInterface[schema.GroupVersion] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue.go
"k8s.io/utils/clock" ) // WorkQueue allows queuing items with a timestamp. An item is // considered ready to process if the timestamp has expired. type WorkQueue interface { // GetWork dequeues and returns all ready items. GetWork() []types.UID // Enqueue inserts a new item or overwrites an existing item. Enqueue(item types.UID, delay time.Duration) } type basicWorkQueue struct { clock clock.Clock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 1.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tpu_cluster_cleanup_attributes.cc
// device. Device attribute is used to infer the appropriate sharding // within TPUs for this op. // TODO(b/183598857): Use explicit sharding ops from the front-end. // For example, dequeue ops generated by // tensorflow/python/tpu/tpu_feed.py if (!tensorflow::IsTPUReplicatedCore(attr.getValue()) && !isa<tf_device::LaunchOp>(op)) { op->removeAttr(kDeviceAttr); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 05 23:50:19 UTC 2022 - 3K bytes - Viewed (0) -
test/chanlinear.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 2.1K bytes - Viewed (0) -
src/internal/fuzz/queue.go
} q.elems = newElems q.head = 0 } func (q *queue) enqueue(e any) { if q.len+1 > q.cap() { q.grow() } i := (q.head + q.len) % q.cap() q.elems[i] = e q.len++ } func (q *queue) dequeue() (any, bool) { if q.len == 0 { return nil, false } e := q.elems[q.head] q.elems[q.head] = nil q.head = (q.head + 1) % q.cap() q.len-- return e, true } func (q *queue) peek() (any, bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 05 21:02:45 UTC 2022 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/common/maplist.go
if !ok { return nil } if match, ok := a.keyedItems[key]; ok { return match } // keep keying items until we either find a match or run out of unkeyed items for len(a.unkeyedItems) > 0 { // dequeue an unkeyed item item := a.unkeyedItems[0] a.unkeyedItems = a.unkeyedItems[1:] // key the item mitem, ok := item.(map[string]interface{}) if !ok { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 02:56:51 UTC 2023 - 4.5K 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) -
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) -
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/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)