client

Documentation

Index

• func GetServiceInfo(ev *clientv3.Event) *server.ServiceInfo
• type Master
  • func NewMaster(endpoints []string, watchPath string) (*Master, error)
  • func (m *Master) AddNode(key string, info *server.ServiceInfo)
  • func (m *Master) WatchNodes()
• type Node

Functions

func GetServiceInfo

func GetServiceInfo(ev *clientv3.Event) *server.ServiceInfo

GetServiceInfo get service info message

Types

type Master

type Master struct {
	Path   string
	Nodes  map[string]*Node
	Client *clientv3.Client
	sync.Mutex
}

Master master node message

func NewMaster

func NewMaster(endpoints []string, watchPath string) (*Master, error)

NewMaster init the struct

func (*Master) AddNode

func (m *Master) AddNode(key string, info *server.ServiceInfo)

AddNode add node message into the map

func (*Master) WatchNodes

func (m *Master) WatchNodes()

WatchNodes watch node message

type Node

type Node struct {
	State bool
	Key   string
	Info  *server.ServiceInfo
}

Node node message