- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for EDSUpdate (0.07 sec)
-
pilot/pkg/serviceregistry/serviceentry/controller.go
s.mutex.RUnlock() s.edsUpdate(allInstances) // HACK to workaround Service syncing after WorkloadEntry: https://github.com/istio/istio/issues/45114 s.workloadInstances.ForEach(func(wi *model.WorkloadInstance) { if wi.Kind == model.WorkloadEntryKind { s.NotifyWorkloadInstanceHandlers(wi, model.EventAdd) } }) } // edsUpdate triggers an EDS push serially such that we can prevent all instances
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/serviceregistry/kube/controller/endpointslice.go
} else { log.Debugf("Handle EDS endpoint: skip collecting workload entry endpoints, service %s/ has not been populated", hostname) } } esc.c.opts.XDSUpdater.EDSUpdate(shard, string(hostname), namespace, endpoints) } } // getPod fetches a pod by name or IP address. // A pod may be missing (nil) for two reasons:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
func NewEndpointIndexUpdater(ei *EndpointIndex) *EndpointIndexUpdater { return &EndpointIndexUpdater{Index: ei} } func (f *EndpointIndexUpdater) ConfigUpdate(*PushRequest) {} func (f *EndpointIndexUpdater) EDSUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) { pushType := 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)