bbs

type BBS struct {
	ExecutorBBS
	StagerBBS
	FileServerBBS
	// contains filtered or unexported fields
}

type ExecutorBBS interface {
	MaintainExecutorPresence(
		heartbeatInterval time.Duration,
		executorID string,
	) (presence PresenceInterface, disappeared <-chan bool, err error)

	WatchForDesiredRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)

	ClaimRunOnce(models.RunOnce) error
	StartRunOnce(models.RunOnce) error
	CompleteRunOnce(models.RunOnce) error

	ConvergeRunOnce(timeToClaim time.Duration)
	MaintainConvergeLock(interval time.Duration, executorID string) (disappeared <-chan bool, stop chan<- chan bool, err error)
}

type FileServerBBS interface {
	MaintainFileServerPresence(
		heartbeatInterval time.Duration,
		fileServerURL string,
		fileServerId string,
	) (presence PresenceInterface, disappeared <-chan bool, err error)
}

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

type PresenceInterface interface {
	Remove()
}

type StagerBBS interface {
	WatchForCompletedRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)

	DesireRunOnce(models.RunOnce) error
	ResolveRunOnce(models.RunOnce) error

	GetAvailableFileServer() (string, error)
}