- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewQueueWithID (0.17 sec)
-
pkg/queue/instance.go
id string metrics *queueMetrics } // NewQueue instantiates a queue with a processing function func NewQueue(errorDelay time.Duration) Instance { return NewQueueWithID(errorDelay, rand.String(10)) } func NewQueueWithID(errorDelay time.Duration, name string) Instance { return &queueImpl{ delay: errorDelay, tasks: make([]*queueTask, 0), closing: false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
func NewController(kubeClient kubelib.Client, options Options) *Controller { c := &Controller{ opts: options, client: kubeClient, queue: queue.NewQueueWithID(1*time.Second, string(options.ClusterID)), servicesMap: make(map[host.Name]*model.Service), nodeSelectorsForServices: make(map[host.Name]labels.Instance),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)