- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for edsCacheUpdate (0.24 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
fx.Delegate.EDSUpdate(c, hostname, ns, entry) } } func (fx *Updater) EDSCacheUpdate(c model.ShardKey, hostname, ns string, entry []*model.IstioEndpoint) { select { case fx.Events <- Event{Type: "eds cache", ID: hostname, Endpoints: entry, Namespace: ns}: default: } if fx.Delegate != nil { fx.Delegate.EDSCacheUpdate(c, hostname, ns, entry) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
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) -
pilot/pkg/model/push_context.go
// must be sent. The shard name is used as a key - current implementation is using the // registry name. EDSUpdate(shard ShardKey, hostname string, namespace string, entry []*IstioEndpoint) // EDSCacheUpdate is called when the list of endpoints or labels in a Service is changed. // For each cluster and hostname, the full list of active endpoints (including empty list)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)