cluster

type Cluster struct {
	Config         *config.Config
	Log            log.FieldLogger
	DirectorState  bool
	DirectorLock   *sync.Mutex
	MemberID       string
	DalClient      dal.IDal // etcd client is/should-be thread safe
	Hostname       string
	StateChan      chan<- bool
	DistributeChan chan<- bool
	OverwatchChan  chan<- *overwatch.Message

	DirectorMonitorLooper   looper.Looper
	DirectorHeartbeatLooper looper.Looper
	MemberHeartbeatLooper   looper.Looper

	base.Component
	// contains filtered or unexported fields
}

type DirectorJSON struct {
	MemberID   string
	LastUpdate time.Time
}

type ICluster interface {
	Start() error
	// contains filtered or unexported methods
}

type MemberJSON struct {
	MemberID      string
	Hostname      string
	ListenAddress string
	LastUpdated   time.Time
	Tags          []string
	Version       string
	SemVer        string
}