registry

Documentation

Index

• type Event
• type Registry
  • func New(prefix string, endpoints []string) (*Registry, error)
  • func (r *Registry) GetAddrs(ctx context.Context) ([]string, error)
  • func (r *Registry) Register(ctx context.Context, addr string) error
  • func (r *Registry) Watch(ctx context.Context) <-chan Event

Types

type Event

type Event struct {
	AddAddr    string
	DeleteAddr string
}

Event 服务变化事件

type Registry

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

Registry 名字服务

func New

func New(prefix string, endpoints []string) (*Registry, error)

func (*Registry) GetAddrs

func (r *Registry) GetAddrs(ctx context.Context) ([]string, error)

GetAddrs 获取节点地址列表

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, addr string) error

Register 注册服务

func (*Registry) Watch

func (r *Registry) Watch(ctx context.Context) <-chan Event

Watch 发现服务