Versions in this module Expand all Collapse all v1 v1.0.0 May 15, 2020 Changes in this version + const DefaultRefreshInterval + const PilotV2Registry + var InstanceIP string + var PodName string + var PodNamespace string + func NewDiscoveryService(options registry.Options) registry.ServiceDiscovery + type CacheManager struct + func NewCacheManager(xdsClient *istioinfra.XdsClient) (*CacheManager, error) + func (cm *CacheManager) AutoSync() + func (cm *CacheManager) MakeIPIndex() error + type EndpointCache struct + func (c *EndpointCache) Delete(clusterName string) + func (c *EndpointCache) GetWithTags(serviceName string, tags map[string]string) []*registry.MicroServiceInstance + func (c *EndpointCache) Set(clusterName string, subset EndpointSubset) + type EndpointSubset struct + type ServiceDiscovery struct + Name string + func (discovery *ServiceDiscovery) AutoSync() + func (discovery *ServiceDiscovery) Close() error + func (discovery *ServiceDiscovery) FindMicroServiceInstances(consumerID, microServiceName string, tags utiltags.Tags) ([]*registry.MicroServiceInstance, error) + func (discovery *ServiceDiscovery) GetAllMicroServices() ([]*registry.MicroService, error) + func (discovery *ServiceDiscovery) GetMicroService(microServiceID string) (*registry.MicroService, error) + func (discovery *ServiceDiscovery) GetMicroServiceID(appID, microServiceName, version, env string) (string, error) + func (discovery *ServiceDiscovery) GetMicroServiceInstances(consumerID, providerID string) ([]*registry.MicroServiceInstance, error)
Go to main page