- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for PushDelayed (0.23 sec)
-
pkg/queue/delay_test.go
defer close(stop) go dq.Run(stop) mu := sync.Mutex{} var t0, t1, t2 time.Time done := make(chan struct{}) dq.PushDelayed(func() error { mu.Lock() defer mu.Unlock() defer close(done) t2 = time.Now() return nil }, 200*time.Millisecond) dq.PushDelayed(func() error { mu.Lock() defer mu.Unlock() t1 = time.Now() return nil }, 100*time.Millisecond) dq.Push(func() error {
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/queue/delay.go
type Delayed interface { baseInstance PushDelayed(t Task, delay time.Duration) } var _ Delayed = &delayQueue{} // DelayQueueOption configure the behavior of the queue. Must be applied before Run. type DelayQueueOption func(*delayQueue) // DelayQueueBuffer sets maximum number of tasks awaiting execution. If this limit is reached, Push and PushDelayed // will block until there is room.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
if workItem.autoCreated { autoRegistrationUnregistrations.Increment() } // after grace period, check if the workload ever reconnected ns := workItem.proxy.Metadata.Namespace c.cleanupQueue.PushDelayed(func() error { wle := c.store.Get(gvk.WorkloadEntry, workItem.entryName, ns) if wle == nil { return nil } if c.shouldCleanupEntry(*wle) { c.cleanupEntry(*wle, false) } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache.go
return } sc.cache.SetWorkload(&item) resourceLog(item.ResourceName).Debugf("scheduled certificate for rotation in %v", delay) sc.queue.PushDelayed(func() error { // In case `UpdateConfigTrustBundle` called, it will resign workload cert. // Check if this is a stale scheduled rotating task. if cached := sc.cache.GetWorkload(); cached != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0)