Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 Changes in this version + const DefaultSuffix + const PODNAMESPACE type EnvoyDSClient + func (c *EnvoyDSClient) GetHostsByKey(serviceKey string, tags map[string]string) (*Hosts, error) v0.5.1 May 31, 2018 Changes in this version + const BaseRoot + const DefaultAddr + const DefaultExpireTime + const DefaultLevel + const DefaultRefreshInterval + const DefaultStatus + const Istio + const PilotPlugin + var ErrNoneAvailable = errors.New("No available") + func ToMicroService(scs *Service) *registry.MicroService + func ToMicroServiceInstance(ins *Host) *registry.MicroServiceInstance + type CacheManager struct + func (c *CacheManager) AutoSync() + func (c *CacheManager) MakeIPIndex() error + type EnvoyDSClient struct + Options Options + func (c *EnvoyDSClient) Close() error + func (c *EnvoyDSClient) GetAllServices() ([]*Service, error) + func (c *EnvoyDSClient) GetServiceHosts(serviceName string) (*Hosts, error) + func (c *EnvoyDSClient) Initialize(options Options) (err error) + type Host struct + Address string + Port int + Tags *Tags + type Hosts struct + Hosts []*Host + type Next func() (string, error) + func RoundRobin(eps []string) Next + type Options struct + Addrs []string + TLSConfig *tls.Config + type Registrator struct + Name string + func (r *Registrator) Close() error + type Service struct + Hosts []*Host + ServiceKey string + type ServiceDiscovery struct + Name string + func (r *ServiceDiscovery) AutoSync() + func (r *ServiceDiscovery) Close() error + func (r *ServiceDiscovery) FindMicroServiceInstances(consumerID, appID, microServiceName, version, env string) ([]*registry.MicroServiceInstance, error) + func (r *ServiceDiscovery) GetAllMicroServices() ([]*registry.MicroService, error) + func (r *ServiceDiscovery) GetMicroService(microServiceID string) (*registry.MicroService, error) + func (r *ServiceDiscovery) GetMicroServiceID(appID, microServiceName, version, env string) (string, error) + func (r *ServiceDiscovery) GetMicroServiceInstances(consumerID, providerID string) ([]*registry.MicroServiceInstance, error) + type Tags struct + AZ string + Canary bool + Weight int