- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for edsCacheUpdate (0.15 sec)
-
pilot/pkg/xds/eds.go
ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: serviceName, Namespace: namespace}), Reason: model.NewReasonStats(model.EndpointUpdate), }) } } // EDSCacheUpdate computes destination address membership across all clusters and networks. // This is the main method implementing EDS. // It replaces InstancesByPort in model - instead of iterating over all endpoints it uses
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
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)