zookeeper

Documentation

Index

• Variables
• type ZookeeperDiscovery
  • func NewZookeeperDiscovery(options *regOps.DiscoveryOptions) *ZookeeperDiscovery
  • func (d *ZookeeperDiscovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (d *ZookeeperDiscovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Variables

var ErrWatcherStopped = errors.New("watcher stopped")

Types

type ZookeeperDiscovery

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

func NewZookeeperDiscovery

func NewZookeeperDiscovery(options *regOps.DiscoveryOptions) *ZookeeperDiscovery

func (*ZookeeperDiscovery) GetService

func (d *ZookeeperDiscovery) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)

GetService get services from zookeeper

func (*ZookeeperDiscovery) Watch

func (d *ZookeeperDiscovery) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)