Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewDelayed (0.13 sec)

  1. pilot/pkg/autoregistration/controller.go

    		}
    	}
    	c := &Controller{
    		instanceID:       instanceID,
    		store:            store,
    		cleanupLimit:     rate.NewLimiter(rate.Limit(20), 1),
    		cleanupQueue:     queue.NewDelayed(),
    		adsConnections:   newAdsConnections(),
    		maxConnectionAge: maxConnAge,
    	}
    	c.queue = controllers.NewQueue("unregister_workloadentry",
    		controllers.WithMaxAttempts(maxRetries),
    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

    	watcher, err := fsnotify.NewWatcher()
    	if err != nil {
    		return nil, err
    	}
    
    	ret := &SecretManagerClient{
    		queue:         queue.NewDelayed(queue.DelayQueueBuffer(0)),
    		caClient:      caClient,
    		configOptions: options,
    		existingCertificateFile: security.SdsCertificateConfig{
    			CertificatePath:   options.CertChainFilePath,
    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