zookeeper

Documentation

Index

• Variables
• type Option
  • func WithDigestACL(user string, password string) Option
  • func WithRootPath(path string) Option
• type Registry
  • func New(conn *zk.Conn, opts ...Option) *Registry
  • func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) GetService(_ context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (r *Registry) Register(_ context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Variables

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

Types

type Option

type Option func(o *options)

Option is etcd registry option.

func WithDigestACL

func WithDigestACL(user string, password string) Option

WithDigestACL with registry password.

func WithRootPath

func WithRootPath(path string) Option

WithRootPath with registry root path.

type Registry

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

Registry is consul registry

func New

func New(conn *zk.Conn, opts ...Option) *Registry

func (*Registry) Deregister

func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error

Deregister registry service to zookeeper.

func (*Registry) GetService

func (r *Registry) GetService(_ context.Context, serviceName string) ([]*registry.ServiceInstance, error)

GetService get services from zookeeper

func (*Registry) Register

func (r *Registry) Register(_ context.Context, service *registry.ServiceInstance) error

func (*Registry) Watch

func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)