etcd_api

Documentation

Index

• type Discovery
  • func NewDiscovery(info *NodeInfo, conf clientv3.Config, mgr *NodesManager) (dis *Discovery, err error)
  • func (d *Discovery) Pull()
  • func (d *Discovery) Watch()
• type NodeInfo
• type NodesManager
  • func NewNodeManager() (m *NodesManager)
  • func (n *NodesManager) AddNode(node *NodeInfo)
  • func (n *NodesManager) DelNode(id string)
  • func (n *NodesManager) Dump()
  • func (n *NodesManager) Pick(name string) *NodeInfo
• type Register
  • func NewRegister(info *NodeInfo, conf clientv3.Config) (reg *Register, err error)
  • func (r *Register) Run()
  • func (r *Register) Stop()

Types

type Discovery

type Discovery struct {
	Nodes *NodesManager
	// contains filtered or unexported fields
}

func NewDiscovery

func NewDiscovery(info *NodeInfo, conf clientv3.Config, mgr *NodesManager) (dis *Discovery, err error)

func (*Discovery) Pull

func (d *Discovery) Pull()

func (*Discovery) Watch

func (d *Discovery) Watch()

type NodeInfo

type NodeInfo struct {
	Addr     string `json:"server_host"`
	Name     string `json:"server_name"`
	UniqueId string `json:"server_id"`
}

type NodesManager

type NodesManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNodeManager

func NewNodeManager() (m *NodesManager)

func (*NodesManager) AddNode

func (n *NodesManager) AddNode(node *NodeInfo)

func (*NodesManager) DelNode

func (n *NodesManager) DelNode(id string)

func (*NodesManager) Dump

func (n *NodesManager) Dump()

func (*NodesManager) Pick

func (n *NodesManager) Pick(name string) *NodeInfo

type Register

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

func NewRegister

func NewRegister(info *NodeInfo, conf clientv3.Config) (reg *Register, err error)

func (*Register) Run

func (r *Register) Run()

func (*Register) Stop

func (r *Register) Stop()