Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PushDelayed (0.2 sec)

  1. 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)
  2. 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)
Back to top