etcd

README

ETCD服务注册与发现模块

Documentation

Index

• type EtcdConfig
• type EtcdDiscover
  • func (d *EtcdDiscover) GetServices(ctx context.Context, sn string) ([]*discov.Service, error)
  • func (d EtcdDiscover) Watch(ctx context.Context) error
• type EtcdRegister
  • func NewEtcdRegister(eps []string, key, value string) *EtcdRegister
  • func (e *EtcdRegister) Deregister(ctx context.Context)
  • func (e *EtcdRegister) Register(ctx context.Context) error

Types

type EtcdConfig

type EtcdConfig struct {
	Key       string   `yaml:"key"`
	Endpoints []string `yaml:"endpoints"`
}

type EtcdDiscover

type EtcdDiscover struct{}

func (*EtcdDiscover) GetServices

func (d *EtcdDiscover) GetServices(ctx context.Context, sn string) ([]*discov.Service, error)

func (EtcdDiscover) Watch

func (d EtcdDiscover) Watch(ctx context.Context) error

type EtcdRegister

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

func NewEtcdRegister

func NewEtcdRegister(eps []string, key, value string) *EtcdRegister

func (*EtcdRegister) Deregister

func (e *EtcdRegister) Deregister(ctx context.Context)

func (*EtcdRegister) Register

func (e *EtcdRegister) Register(ctx context.Context) error