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