zookeeper

package module

v0.2.2 Latest Latest Go to latest Published: Dec 21, 2025 License: MIT Imports: 12 Imported by: 1

Details

This section is empty.

View Source

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

func NewDiscovery(c *conf.Registry) (registry.Discovery, error)

func NewRegistrar(c *conf.Registry) (registry.Registrar, error)

type Option func(o *options)

Option is etcd registry option.

func WithDigestACL(user string, password string) Option

WithDigestACL with registry password.

func WithRootPath(path string) Option

WithRootPath with registry root path.

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

Registry is consul registry

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

func NewRegistry(c *conf.Registry) (*Registry, error)

NewRegistry 创建一个注册发现客户端 - ZooKeeper

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

Deregister registry service to zookeeper.

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

GetService get services from zookeeper

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

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