- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for SvcUpdate (0.29 sec)
-
pilot/pkg/xds/eds.go
"istio.io/istio/pilot/pkg/util/protoconv" "istio.io/istio/pilot/pkg/xds/endpoints" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/util/sets" ) // SvcUpdate is a callback from service discovery when service info changes. func (s *DiscoveryServer) SvcUpdate(shard model.ShardKey, hostname string, namespace string, event model.Event) { // When a service deleted, we should cleanup the endpoint shards and also remove keys from EndpointIndex to
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/memory/discovery.go
event := model.EventAdd if o, f := sd.services[svc.Hostname]; f { old = o event = model.EventUpdate } sd.services[svc.Hostname] = svc if sd.XdsUpdater != nil { sd.XdsUpdater.SvcUpdate(sd.shardKey(), string(svc.Hostname), svc.Attributes.Namespace, model.EventAdd) } sd.handlers.NotifyServiceHandlers(old, svc, event) sd.mutex.Unlock() } // RemoveService removes an in-memory service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
s.XdsUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, model.EventAdd) configsUpdated.Insert(makeConfigKey(svc)) } for _, svc := range updatedSvcs { s.XdsUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, model.EventUpdate) configsUpdated.Insert(makeConfigKey(svc)) } // If service entry is deleted, call SvcUpdate to cleanup endpoint shards for services.
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
func (f *EndpointIndexUpdater) EDSCacheUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) { f.Index.UpdateServiceEndpoints(shard, serviceName, namespace, eps) } func (f *EndpointIndexUpdater) SvcUpdate(shard ShardKey, hostname string, namespace string, event Event) { if event == EventDelete { f.Index.DeleteServiceShard(shard, hostname, namespace, false) } }
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.opts.XDSUpdater.ConfigUpdate(&model.PushRequest{Full: true, Reason: model.NewReasonStats(model.NetworksTrigger)}) } shard := model.ShardKeyFromRegistry(c) event := model.EventDelete c.opts.XDSUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, event) c.handlers.NotifyServiceHandlers(nil, svc, event) } // recomputeServiceForPod is called when a pod changes and service endpoints need to be recomputed.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)