discovery

Documentation

Index

• type Master
  • func NewMaster(endpoints []string) *Master
  • func (m *Master) AddWorker(info *WorkerInfo)
  • func (m *Master) UpdateWorker(info *WorkerInfo)
  • func (m *Master) WatchWorkers()
• type Member
• type Worker
  • func NewWorker(name, IP string, endpoints []string) *Worker
  • func (w *Worker) HeartBeat()
• type WorkerInfo
  • func NodeToWorkerInfo(node *client.Node) *WorkerInfo

Types

type Master

type Master struct {
	KeysAPI client.KeysAPI
	// contains filtered or unexported fields
}

func NewMaster

func NewMaster(endpoints []string) *Master

func (*Master) AddWorker

func (m *Master) AddWorker(info *WorkerInfo)

func (*Master) UpdateWorker

func (m *Master) UpdateWorker(info *WorkerInfo)

func (*Master) WatchWorkers

func (m *Master) WatchWorkers()

type Member

type Member struct {
	InGroup bool
	IP      string
	Name    string
	CPU     int
}

Member is a client machine

type Worker

type Worker struct {
	Name    string
	IP      string
	KeysAPI client.KeysAPI
}

func NewWorker

func NewWorker(name, IP string, endpoints []string) *Worker

func (*Worker) HeartBeat

func (w *Worker) HeartBeat()

type WorkerInfo

type WorkerInfo struct {
	Name string
	IP   string
	CPU  int
}

workerInfo is the service register information to etcdx

func NodeToWorkerInfo

func NodeToWorkerInfo(node *client.Node) *WorkerInfo