zookeeper

Documentation

Index

• type Option
  • func WithDigestACL(user string, password string) Option
  • func WithRootPath(path string) Option
• type ZookeeperRegistry
  • func NewDefaultZookeeperRegistry(reg *regOps.RegistryOptions, opts ...Option) *ZookeeperRegistry
  • func NewZookeeperRegistry(conn *zk.Conn, opts ...Option) *ZookeeperRegistry
  • func (r *ZookeeperRegistry) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *ZookeeperRegistry) Register(_ context.Context, service *registry.ServiceInstance) error

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 ZookeeperRegistry

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

ZookeeperRegistry is consul registry

func NewDefaultZookeeperRegistry

func NewDefaultZookeeperRegistry(reg *regOps.RegistryOptions, opts ...Option) *ZookeeperRegistry

func NewZookeeperRegistry

func NewZookeeperRegistry(conn *zk.Conn, opts ...Option) *ZookeeperRegistry

func (*ZookeeperRegistry) Deregister

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

Deregister registry service to zookeeper.

func (*ZookeeperRegistry) Register

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