Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for queueEdsEvent (0.17 sec)

  1. pilot/pkg/serviceregistry/serviceentry/controller.go

    	keys := map[instancesKey]struct{}{}
    	for _, i := range instances {
    		keys[makeInstanceKey(i)] = struct{}{}
    	}
    	s.queueEdsEvent(keys, s.doEdsCacheUpdate)
    }
    
    // queueEdsEvent processes eds events sequentially for the passed keys and invokes the passed function.
    func (s *Controller) queueEdsEvent(keys sets.Set[instancesKey], edsFn func(keys sets.Set[instancesKey])) {
    	// wait for the cache update finished
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top