discovery

Documentation

Index

• type EndpointInfo
  • func UnMarshal(data []byte) (*EndpointInfo, error)
  • func (edi *EndpointInfo) Marshal() string
• type ServiceDiscovery
  • func NewServiceDiscovery(ctx *context.Context) *ServiceDiscovery
  • func (s *ServiceDiscovery) Close() error
  • func (s *ServiceDiscovery) WatchService(prefix string, set, del func(key, value string)) error
• type ServiceRegister
  • func NewServiceRegister(ctx *context.Context, key string, endPointInfo *EndpointInfo, lease int64) (*ServiceRegister, error)
  • func (s *ServiceRegister) Close() error
  • func (s *ServiceRegister) ListenLeaseRespChan()
  • func (s *ServiceRegister) UpdateValue(val *EndpointInfo) error

Types

type EndpointInfo

type EndpointInfo struct {
	IP       string                 `json:"ip"`
	Port     string                 `json:"port"`
	MetaData map[string]interface{} `json:"meta"`
}

func UnMarshal

func UnMarshal(data []byte) (*EndpointInfo, error)

[]byte -> endpointInfo

func (*EndpointInfo) Marshal

func (edi *EndpointInfo) Marshal() string

endpointInfo -> []byte -> string

type ServiceDiscovery

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

服务发现

func NewServiceDiscovery

func NewServiceDiscovery(ctx *context.Context) *ServiceDiscovery

新建服务发现

func (*ServiceDiscovery) Close

func (s *ServiceDiscovery) Close() error

func (*ServiceDiscovery) WatchService

func (s *ServiceDiscovery) WatchService(prefix string, set, del func(key, value string)) error

初始化服务列表和监视

type ServiceRegister

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

创建租约注册服务

func NewServiceRegister

func NewServiceRegister(ctx *context.Context, key string, endPointInfo *EndpointInfo, lease int64) (*ServiceRegister, error)

新建注册服务

func (*ServiceRegister) Close

func (s *ServiceRegister) Close() error

func (*ServiceRegister) ListenLeaseRespChan

func (s *ServiceRegister) ListenLeaseRespChan()

监听/续租情况

func (*ServiceRegister) UpdateValue

func (s *ServiceRegister) UpdateValue(val *EndpointInfo) error