zookeeperserviceregistry

Oct 13, 2021

Changes in this version

+ const Category

+ const Kind

+ type Spec struct

+ ConnTimeout string

+ Prefix string

+ SyncInterval string

+ ZKServices []string

+ type Status struct

+ Health string

+ ServiceInstancesNum map[string]int

+ type ZookeeperServiceRegistry struct

+ func (zk *ZookeeperServiceRegistry) ApplyServiceInstances(serviceInstances map[string]*serviceregistry.ServiceInstanceSpec) error

+ func (zk *ZookeeperServiceRegistry) Category() supervisor.ObjectCategory

+ func (zk *ZookeeperServiceRegistry) Close()

+ func (zk *ZookeeperServiceRegistry) DefaultSpec() interface{}

+ func (zk *ZookeeperServiceRegistry) DeleteServiceInstances(serviceInstances map[string]*serviceregistry.ServiceInstanceSpec) error

+ func (zk *ZookeeperServiceRegistry) GetServiceInstance(serviceName, instanceID string) (*serviceregistry.ServiceInstanceSpec, error)

+ func (zk *ZookeeperServiceRegistry) Inherit(superSpec *supervisor.Spec, previousGeneration supervisor.Object)

+ func (zk *ZookeeperServiceRegistry) Init(superSpec *supervisor.Spec)

+ func (zk *ZookeeperServiceRegistry) Kind() string

+ func (zk *ZookeeperServiceRegistry) ListAllServiceInstances() (map[string]*serviceregistry.ServiceInstanceSpec, error)

+ func (zk *ZookeeperServiceRegistry) ListServiceInstances(serviceName string) (map[string]*serviceregistry.ServiceInstanceSpec, error)

+ func (zk *ZookeeperServiceRegistry) Name() string

+ func (zk *ZookeeperServiceRegistry) Notify() <-chan *serviceregistry.RegistryEvent

+ func (zk *ZookeeperServiceRegistry) Status() *supervisor.Status