commander

Documentation

Index

• Variables
• func RunHearbeat(wg *sync.WaitGroup)
• func RunWorkSender(wg *sync.WaitGroup)
• func SendHeartbeatMessage(connString string, message *pbMessages.Ping) bool
• func SendWorkMessage(connString string, message *pbMessages.WorkRequest) bool
• func StartHelloListener(wg *sync.WaitGroup)
• type Status
• type WorkerData
• type WorkerMap
  • func (wm WorkerMap) AddNetError(server string)
  • func (wm WorkerMap) AddWorker(server string)
  • func (wm WorkerMap) GetNetErrors(server string) int
  • func (wm WorkerMap) GetStatus(server string) Status
  • func (wm WorkerMap) ResetNetError(server string)
  • func (wm WorkerMap) SetStatus(server string, stat Status)

Variables

var (
	DebugLog   bool
	Commands   []common.Job
	Workers    WorkerMap
	WorkersMtx sync.Mutex
)

Functions

func RunHearbeat

func RunHearbeat(wg *sync.WaitGroup)

RunHearbeat responsible for sending ping (hearbeat) messages to workers

func RunWorkSender

func RunWorkSender(wg *sync.WaitGroup)

RunWorkSender is responsible for sending out work units to workers

func SendHeartbeatMessage

func SendHeartbeatMessage(connString string, message *pbMessages.Ping) bool

func SendWorkMessage

func SendWorkMessage(connString string, message *pbMessages.WorkRequest) bool

func StartHelloListener

func StartHelloListener(wg *sync.WaitGroup)

Start the HelloRequest listener

Types

type Status

type Status int

const (
	WORKER_ONLINE  Status = iota // 0
	WORKER_OFFLINE               // 1
)

type WorkerData

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

type WorkerMap

type WorkerMap map[string]*WorkerData

WorkerMap is a map of worker nodes and info related to each node

func (WorkerMap) AddNetError

func (wm WorkerMap) AddNetError(server string)

func (WorkerMap) AddWorker

func (wm WorkerMap) AddWorker(server string)

func (WorkerMap) GetNetErrors

func (wm WorkerMap) GetNetErrors(server string) int

func (WorkerMap) GetStatus

func (wm WorkerMap) GetStatus(server string) Status

func (WorkerMap) ResetNetError

func (wm WorkerMap) ResetNetError(server string)

func (WorkerMap) SetStatus

func (wm WorkerMap) SetStatus(server string, stat Status)