- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SvcUpdate (0.11 sec)
-
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)