- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for SvcUpdate (0.28 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
fx.Delegate.EDSCacheUpdate(c, hostname, ns, entry) } } // SvcUpdate is called when a service port mapping definition is updated. // This interface is WIP - labels, annotations and other changes to service may be // updated to force a EDS and CDS recomputation and incremental push, as it doesn't affect // LDS/RDS. func (fx *Updater) SvcUpdate(c model.ShardKey, hostname string, ns string, ev model.Event) { select {
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
"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) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
} expectServiceInstances(t, sd, httpStaticOverlayUpdatedNs, 0, instances) // svcUpdate is not triggered since `httpStatic` is there and has instances, so we should // not delete the endpoints shards of "*.google.com". We xpect a full push as the service has changed. expectEvents(t, events,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
EDSCacheUpdate(shard ShardKey, hostname string, namespace string, entry []*IstioEndpoint) // SvcUpdate is called when a service definition is updated/deleted. SvcUpdate(shard ShardKey, hostname string, namespace string, event Event) // ConfigUpdate is called to notify the XDS server of config updates and request a push.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/events.go
PvcAdd = framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add, Label: "PvcAdd"} // PvcUpdate is the event when a persistent volume claim is updated in the cluster. PvcUpdate = framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Update, Label: "PvcUpdate"} // StorageClassAdd is the event when a StorageClass is added in the cluster.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
} events := []framework.ClusterEvent{ NodeAdd, NodeTaintChange, NodeAllocatableChange, NodeConditionChange, NodeLabelChange, NodeAnnotationChange, PvcAdd, PvcUpdate, PvAdd, PvUpdate, StorageClassAdd, StorageClassUpdate, CSINodeAdd, CSINodeUpdate, CSIDriverAdd, CSIDriverUpdate, CSIStorageCapacityAdd, CSIStorageCapacityUpdate,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)