- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ShardKeyFromRegistry (0.21 sec)
-
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
// Re-build the endpoints for this service with a new discoverability policy. // 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) } }
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/model/endpointshards.go
// shardRegistry is a simplified interface for registries that can produce a shard key type shardRegistry interface { Cluster() cluster.ID Provider() provider.ID } // ShardKeyFromRegistry computes the shard key based on provider type and cluster id. func ShardKeyFromRegistry(instance shardRegistry) ShardKey { return ShardKey{Cluster: instance.Cluster(), Provider: instance.Provider()} }
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
log.Warnf("queue for removed kube registry %q may not be done processing: %v", c.Cluster(), err) } if c.opts.XDSUpdater != nil { c.opts.XDSUpdater.RemoveShard(model.ShardKeyFromRegistry(c)) } // Unregister networks handler if c.networksHandlerRegistration != nil { c.opts.MeshNetworksWatcher.DeleteNetworksHandler(c.networksHandlerRegistration) } return nil }
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.go
s.serviceInstances.addInstances(configKeyWithParent{configKey: ckey, parent: key}, value) } s.serviceInstances.updateServiceEntryInstances(key, serviceInstancesByConfig) } shard := model.ShardKeyFromRegistry(s) for _, svc := range addedSvcs { s.XdsUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, model.EventAdd) configsUpdated.Insert(makeConfigKey(svc)) }
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
v1beta1.LabelServiceName: name, }).AsSelectorPreValidated().Add(*endpointSliceRequirement) } func (esc *endpointSliceController) pushEDS(hostnames []host.Name, namespace string) { shard := model.ShardKeyFromRegistry(esc.c) // Even though we just read from the cache, we need the full lock to ensure pushEDS // runs sequentially when `EnableK8SServiceSelectWorkloadEntries` is enabled. Otherwise,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0)