- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for PushDelayed (0.2 sec)
-
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)