fakebbs

Documentation

Index

• type FakeExecutorBBS
  • func NewFakeExecutorBBS() *FakeExecutorBBS
  • func (fakeBBS *FakeExecutorBBS) ClaimRunOnce(runOnce models.RunOnce) error
  • func (fakeBBS *FakeExecutorBBS) CompleteRunOnce(runOnce models.RunOnce) error
  • func (fakeBBS *FakeExecutorBBS) ConvergeRunOnce(timeToClaim time.Duration)
  • func (fakeBBS *FakeExecutorBBS) MaintainConvergeLock(interval time.Duration, executorID string) (<-chan bool, chan<- chan bool, error)
  • func (fakeBBS *FakeExecutorBBS) MaintainExecutorPresence(heartbeatInterval time.Duration, executorID string) (bbs.PresenceInterface, <-chan bool, error)
  • func (fakeBBS *FakeExecutorBBS) StartRunOnce(runOnce models.RunOnce) error
  • func (fakeBBS *FakeExecutorBBS) WatchForDesiredRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)
• type FakePresence
  • func (p *FakePresence) Remove()
• type FakeStagerBBS
  • func NewFakeStagerBBS() *FakeStagerBBS
  • func (fakeBBS *FakeStagerBBS) DesireRunOnce(runOnce models.RunOnce) error
  • func (fakeBBS *FakeStagerBBS) GetAvailableFileServer() (string, error)
  • func (fakeBBS *FakeStagerBBS) ResolveRunOnce(runOnce models.RunOnce) error
  • func (fakeBBS *FakeStagerBBS) WatchForCompletedRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)

Types

type FakeExecutorBBS

type FakeExecutorBBS struct {
	CallsToConverge int

	MaintainConvergeInterval    time.Duration
	MaintainConvergeExecutorID  string
	MaintainConvergeLostChannel <-chan bool
	MaintainConvergeStopChannel chan<- chan bool
	MaintainConvergeLockError   error

	MaintainingPresenceHeartbeatInterval time.Duration
	MaintainingPresenceExecutorID        string
	MaintainingPresencePresence          *FakePresence
	MaintainingPresenceErrorChannel      chan bool
	MaintainingPresenceError             error

	ClaimedRunOnce  models.RunOnce
	ClaimRunOnceErr error

	StartedRunOnce  models.RunOnce
	StartRunOnceErr error

	CompletedRunOnce           models.RunOnce
	CompleteRunOnceErr         error
	ConvergeRunOnceTimeToClaim time.Duration
}

func NewFakeExecutorBBS

func NewFakeExecutorBBS() *FakeExecutorBBS

func (*FakeExecutorBBS) ClaimRunOnce

func (fakeBBS *FakeExecutorBBS) ClaimRunOnce(runOnce models.RunOnce) error

func (*FakeExecutorBBS) CompleteRunOnce

func (fakeBBS *FakeExecutorBBS) CompleteRunOnce(runOnce models.RunOnce) error

func (*FakeExecutorBBS) ConvergeRunOnce

func (fakeBBS *FakeExecutorBBS) ConvergeRunOnce(timeToClaim time.Duration)

func (*FakeExecutorBBS) MaintainConvergeLock

func (fakeBBS *FakeExecutorBBS) MaintainConvergeLock(interval time.Duration, executorID string) (<-chan bool, chan<- chan bool, error)

func (*FakeExecutorBBS) MaintainExecutorPresence

func (fakeBBS *FakeExecutorBBS) MaintainExecutorPresence(heartbeatInterval time.Duration, executorID string) (bbs.PresenceInterface, <-chan bool, error)

func (*FakeExecutorBBS) StartRunOnce

func (fakeBBS *FakeExecutorBBS) StartRunOnce(runOnce models.RunOnce) error

func (*FakeExecutorBBS) WatchForDesiredRunOnce

func (fakeBBS *FakeExecutorBBS) WatchForDesiredRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)

type FakePresence

type FakePresence struct {
	Removed bool
}

func (*FakePresence) Remove

func (p *FakePresence) Remove()

type FakeStagerBBS

type FakeStagerBBS struct {
	ResolvedRunOnce   models.RunOnce
	ResolveRunOnceErr error

	CalledCompletedRunOnce  chan bool
	CompletedRunOnceChan    chan models.RunOnce
	CompletedRunOnceErrChan chan error
}

func NewFakeStagerBBS

func NewFakeStagerBBS() *FakeStagerBBS

func (*FakeStagerBBS) DesireRunOnce

func (fakeBBS *FakeStagerBBS) DesireRunOnce(runOnce models.RunOnce) error

func (*FakeStagerBBS) GetAvailableFileServer

func (fakeBBS *FakeStagerBBS) GetAvailableFileServer() (string, error)

func (*FakeStagerBBS) ResolveRunOnce

func (fakeBBS *FakeStagerBBS) ResolveRunOnce(runOnce models.RunOnce) error

func (*FakeStagerBBS) WatchForCompletedRunOnce

func (fakeBBS *FakeStagerBBS) WatchForCompletedRunOnce() (<-chan models.RunOnce, chan<- bool, <-chan error)