discovery

Documentation

Index

• func Close()
• func Del(key string, prefix bool)
• func GetByPrefix(key string) map[string]string
• func GetEventChannel(node Node) string
• func GetRPCChannel(node Node) string
• func Init(etcds []string)
• func Keep(key, val string)
• func UpdateLoad(ip string, port int)
• func Watch(key string, watchFunc WatchCallback, prefix bool)
• type Etcd
  • func (e *Etcd) GetResponseByPrefix(key string) (*clientv3.GetResponse, error)
• type Node
• type NodeStateType
• type ServiceNode
  • func NewServiceNode(endpoints []string, dc string) *ServiceNode
  • func (sn *ServiceNode) GetEventChannel() string
  • func (sn *ServiceNode) GetRPCChannel() string
  • func (sn *ServiceNode) NodeInfo() Node
  • func (sn *ServiceNode) RegisterNode(serviceName string, name string)
  • func (sn *ServiceNode) UnregisterNode() error
• type ServiceRegistry
  • func NewServiceRegistry(endpoints []string, scheme string) *ServiceRegistry
  • func (r *ServiceRegistry) GetServiceNodes(serviceName string) ([]Node, error)
  • func (r *ServiceRegistry) RegisterServiceNode(serviceName string, node Node) error
• type ServiceWatchCallback
• type ServiceWatcher
  • func NewServiceWatcher(endpoints []string, dc string) *ServiceWatcher
  • func (sw *ServiceWatcher) DeleteNodesByID(ID string) bool
  • func (sw *ServiceWatcher) GetNodes(service string) (map[string]Node, bool)
  • func (sw *ServiceWatcher) GetNodesByID(ID string) (*Node, bool)
  • func (sw *ServiceWatcher) WatchNode(ch clientv3.WatchChan)
  • func (sw *ServiceWatcher) WatchServiceNode(serviceName string, callback ServiceWatchCallback)
• type WatchCallback

Functions

func Close

func Close()

func Del

func Del(key string, prefix bool)

func GetByPrefix

func GetByPrefix(key string) map[string]string

func GetEventChannel

func GetEventChannel(node Node) string

GetEventChannel .

func GetRPCChannel

func GetRPCChannel(node Node) string

GetRPCChannel .

func Init

func Init(etcds []string)

func Keep

func Keep(key, val string)

func UpdateLoad

func UpdateLoad(ip string, port int)

func Watch

func Watch(key string, watchFunc WatchCallback, prefix bool)

Types

type Etcd

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

func (*Etcd) GetResponseByPrefix

func (e *Etcd) GetResponseByPrefix(key string) (*clientv3.GetResponse, error)

GetResponseByPrefix .

type Node

type Node struct {
	ID   string
	Info map[string]string
}

Node service node info

type NodeStateType

type NodeStateType int32

const (
	UP   NodeStateType = 0
	DOWN NodeStateType = 1
)

type ServiceNode

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

ServiceNode .

func NewServiceNode

func NewServiceNode(endpoints []string, dc string) *ServiceNode

NewServiceNode .

func (*ServiceNode) GetEventChannel

func (sn *ServiceNode) GetEventChannel() string

GetEventChannel .

func (*ServiceNode) GetRPCChannel

func (sn *ServiceNode) GetRPCChannel() string

GetRPCChannel .

func (*ServiceNode) NodeInfo

func (sn *ServiceNode) NodeInfo() Node

NodeInfo .

func (*ServiceNode) RegisterNode

func (sn *ServiceNode) RegisterNode(serviceName string, name string)

RegisterNode register a new node.

func (*ServiceNode) UnregisterNode

func (sn *ServiceNode) UnregisterNode() error

RegisterNode register a new node.

type ServiceRegistry

type ServiceRegistry struct {
	Scheme string
	// contains filtered or unexported fields
}

ServiceRegistry lib

func NewServiceRegistry

func NewServiceRegistry(endpoints []string, scheme string) *ServiceRegistry

NewServiceRegistry ServiceRegistry factory method

func (*ServiceRegistry) GetServiceNodes

func (r *ServiceRegistry) GetServiceNodes(serviceName string) ([]Node, error)

GetServiceNodes returns a list of active service nodes

func (*ServiceRegistry) RegisterServiceNode

func (r *ServiceRegistry) RegisterServiceNode(serviceName string, node Node) error

RegisterServiceNode .

type ServiceWatchCallback

type ServiceWatchCallback func(service string, state NodeStateType, nodes Node)

ServiceWatchCallback .

type ServiceWatcher

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

ServiceWatcher .

func NewServiceWatcher

func NewServiceWatcher(endpoints []string, dc string) *ServiceWatcher

NewServiceWatcher .

func (*ServiceWatcher) DeleteNodesByID

func (sw *ServiceWatcher) DeleteNodesByID(ID string) bool

func (*ServiceWatcher) GetNodes

func (sw *ServiceWatcher) GetNodes(service string) (map[string]Node, bool)

func (*ServiceWatcher) GetNodesByID

func (sw *ServiceWatcher) GetNodesByID(ID string) (*Node, bool)

func (*ServiceWatcher) WatchNode

func (sw *ServiceWatcher) WatchNode(ch clientv3.WatchChan)

func (*ServiceWatcher) WatchServiceNode

func (sw *ServiceWatcher) WatchServiceNode(serviceName string, callback ServiceWatchCallback)

WatchServiceNode .

type WatchCallback

type WatchCallback func(clientv3.WatchChan)