registry

Documentation

Index

• type Option
  • func WithContext(ctx context.Context) Option
  • func WithRootPath(path string) Option
  • func WithTimeout(timeout time.Duration) Option
• type Registry
  • func New(zkServers []string, opts ...Option) (*Registry, error)
  • func (r *Registry) Deregister(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (r *Registry) Register(ctx context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Types

type Option

type Option func(o *options)

Option is etcd registry option.

func WithContext

func WithContext(ctx context.Context) Option

WithContext with registry context.

func WithRootPath

func WithRootPath(path string) Option

WithRootPath with registry root path.

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout with registry timeout.

type Registry

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

Registry is consul registry

func New

func New(zkServers []string, opts ...Option) (*Registry, error)

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(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)

GetService get services from zookeeper

func (*Registry) Register

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

func (*Registry) Watch

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