zk

Documentation

Index

• func New(opt option.Registry) (component.Registry, error)
• type RegistryClient
  • func (c *RegistryClient) AccessorEvents() <-chan *types.ServiceEvent
  • func (c *RegistryClient) GetCachedScopedMapping(scopedKey string) map[string]struct{}
  • func (c *RegistryClient) GetCachedService(serviceName string) *types.Service
  • func (c *RegistryClient) Instances(hostname string) []*types.Instance
  • func (c *RegistryClient) InstancesByHost(hosts []string) []*types.Instance
  • func (c *RegistryClient) Service(hostname string) *types.Service
  • func (c *RegistryClient) ServiceEvents() <-chan *types.ServiceEvent
  • func (c *RegistryClient) Services() []*types.Service
  • func (c *RegistryClient) Start() error
  • func (c *RegistryClient) Stop()

Functions

func New

func New(opt option.Registry) (component.Registry, error)

New Create a registry client for a scenario using the zookeeper

Types

type RegistryClient

type RegistryClient struct {
	// contains filtered or unexported fields
}

RegistryClient ...

func (*RegistryClient) AccessorEvents

func (c *RegistryClient) AccessorEvents() <-chan *types.ServiceEvent

AccessorEvents this channel will spawn the accessor changing events.

func (*RegistryClient) GetCachedScopedMapping

func (c *RegistryClient) GetCachedScopedMapping(scopedKey string) map[string]struct{}

GetCachedScopedMapping ...

func (*RegistryClient) GetCachedService

func (c *RegistryClient) GetCachedService(serviceName string) *types.Service

GetCachedService ...

func (*RegistryClient) Instances

func (c *RegistryClient) Instances(hostname string) []*types.Instance

Instances ...

func (*RegistryClient) InstancesByHost

func (c *RegistryClient) InstancesByHost(hosts []string) []*types.Instance

InstancesByHost ...

func (*RegistryClient) Service

func (c *RegistryClient) Service(hostname string) *types.Service

Service ...

func (*RegistryClient) ServiceEvents

func (c *RegistryClient) ServiceEvents() <-chan *types.ServiceEvent

ServiceEvents channel is a stream of Service and instance updates

func (*RegistryClient) Services

func (c *RegistryClient) Services() []*types.Service

Services ...

func (*RegistryClient) Start

func (c *RegistryClient) Start() error

Start ...

func (*RegistryClient) Stop

func (c *RegistryClient) Stop()

Stop ...