discovery

Documentation

Index

• func HandleKeepAliveResp(ch <-chan *clientv3.LeaseKeepAliveResponse)
• func UserDiscovery(name string) (err error)
• func UserRegisty(srv *UserService)
• type Discovery
• type EtcdDiscovery
  • func NewEtcdDiscovery(endpoints []string) (*EtcdDiscovery, error)
  • func (d *EtcdDiscovery) GetServiceAddr(serviceName string) (string, error)
  • func (d *EtcdDiscovery) WatchService(serviceName string) error
• type EtcdRegisty
  • func NewEtcdRegisty(endpoints []string, opts ...Option) (*EtcdRegisty, error)
  • func (r *EtcdRegisty) DeRegisty() error
  • func (r *EtcdRegisty) Registy(srv Service) error
• type Option
  • func WithLeaseTTL(ttl int64) Option
• type Registry
• type Service
• type UserService
  • func NewUserService(addr string) *UserService
  • func (s UserService) Addr() string
  • func (s UserService) Name() string

Functions

func HandleKeepAliveResp

func HandleKeepAliveResp(ch <-chan *clientv3.LeaseKeepAliveResponse)

func UserDiscovery

func UserDiscovery(name string) (err error)

func UserRegisty

func UserRegisty(srv *UserService)

Types

type Discovery

type Discovery interface {
	// 获取服务器的一个地址
	GetServiceAddr(serviceName string) (string, error)
	// 监控服务地址变化
	WatchService(serviceName string) error
}

type EtcdDiscovery

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

func NewEtcdDiscovery

func NewEtcdDiscovery(endpoints []string) (*EtcdDiscovery, error)

func (*EtcdDiscovery) GetServiceAddr

func (d *EtcdDiscovery) GetServiceAddr(serviceName string) (string, error)

func (*EtcdDiscovery) WatchService

func (d *EtcdDiscovery) WatchService(serviceName string) error

type EtcdRegisty

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

基于etcd服务发现中间件，实现regisrty

func NewEtcdRegisty

func NewEtcdRegisty(endpoints []string, opts ...Option) (*EtcdRegisty, error)

func (*EtcdRegisty) DeRegisty

func (r *EtcdRegisty) DeRegisty() error

func (*EtcdRegisty) Registy

func (r *EtcdRegisty) Registy(srv Service) error

type Option

type Option func(er *EtcdRegisty)

func WithLeaseTTL

func WithLeaseTTL(ttl int64) Option

type Registry

type Registry interface {
	// 注册
	Regisrty(srv Service) error
	// 注销
	DeRegistry(srv Service) error
}

type Service

type Service interface {
	Name() string
	Addr() string
}

服务类型

type UserService

type UserService struct {
	UserName string
	UserAddr string
}

func NewUserService

func NewUserService(addr string) *UserService

func (UserService) Addr

func (s UserService) Addr() string

func (UserService) Name

func (s UserService) Name() string