- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for EDSCacheUpdate (0.28 sec)
-
pilot/pkg/serviceregistry/serviceentry/controller.go
keys.Insert(makeInstanceKey(i)) } s.queueEdsEvent(keys, s.doEdsUpdate) } // edsCacheUpdate updates eds cache serially such that we can prevent allinstances // got at t1 can accidentally override that got at t2 if multiple threads are // running this function. Queueing ensures latest updated wins. func (s *Controller) edsCacheUpdate(instances []*model.ServiceInstance) { // Find all keys we need to lookup
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
ConfigsUpdated: sets.New(ConfigKey{Kind: kind.ServiceEntry, Name: serviceName, Namespace: namespace}), Reason: NewReasonStats(EndpointUpdate), }) } } func (f *EndpointIndexUpdater) EDSCacheUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) { f.Index.UpdateServiceEndpoints(shard, serviceName, namespace, eps) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
c.Unlock() if !f { return } shard := model.ShardKeyFromRegistry(c) endpoints := c.buildEndpointsForService(conv, true) if len(endpoints) > 0 { c.opts.XDSUpdater.EDSCacheUpdate(shard, string(hostname), svc.Namespace, endpoints) } cu.Insert(model.ConfigKey{ Kind: kind.ServiceEntry, Name: string(hostname), Namespace: svc.Namespace, }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)