- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for EDSUpdate (0.16 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
// EndpointCount, used in matches only EndpointCount int } func (fx *Updater) EDSUpdate(c model.ShardKey, hostname string, ns string, entry []*model.IstioEndpoint) { select { case fx.Events <- Event{Type: "eds", ID: hostname, Endpoints: entry, Namespace: ns}: default: } if fx.Delegate != nil { fx.Delegate.EDSUpdate(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
if event == model.EventDelete { inboundServiceDeletes.Increment() s.Env.EndpointIndex.DeleteServiceShard(shard, hostname, namespace, false) } else { inboundServiceUpdates.Increment() } } // EDSUpdate 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
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/memory/discovery.go
key := fmt.Sprintf("%s:%s", service, port.Name) for _, i := range sd.instancesByPortName[key] { eps = append(eps, i.Endpoint) } } if sd.XdsUpdater != nil { sd.XdsUpdater.EDSUpdate(sd.shardKey(), string(service), svc.Attributes.Namespace, eps) } } // AddEndpoint adds an endpoint to a 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/kube/controller/serviceexportcache.go
// Also update any internal caching. endpoints := ec.buildEndpointsForService(svc, true) shard := model.ShardKeyFromRegistry(ec) ec.opts.XDSUpdater.EDSUpdate(shard, svc.Hostname.String(), se.GetNamespace(), endpoints) } } func (ec *serviceExportCacheImpl) EndpointDiscoverabilityPolicy(svc *model.Service) model.EndpointDiscoverabilityPolicy { if svc == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K 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) -
pilot/pkg/model/push_context.go
type XDSUpdater interface { // EDSUpdate 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) // 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)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)