fake_bbs

package
v0.0.0-...-b3654af Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 25, 2014 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeAppManagerBBS 

type FakeAppManagerBBS struct {
	FileServerGetter

	DesiredLRPChangeChan chan models.DesiredLRPChange
	DesiredLRPStopChan   chan bool
	DesiredLRPErrChan    chan error

	StopLRPInstanceErr error

	DesireLRPErr error

	ActualLRPs    []models.ActualLRP
	ActualLRPsErr error

	LRPStartAuctionErr             error
	WhenRequestingLRPStartAuctions func(lrp models.LRPStartAuction) error

	LRPStopAuctionErr             error
	WhenRequestingLRPStopAuctions func(lrp models.LRPStopAuction) error

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFakeAppManagerBBS 

func NewFakeAppManagerBBS() *FakeAppManagerBBS

func (*FakeAppManagerBBS) DesireLRP 

func (fakeBBS *FakeAppManagerBBS) DesireLRP(lrp models.DesiredLRP) error

func (*FakeAppManagerBBS) DesiredLRPs 

func (fakeBBS *FakeAppManagerBBS) DesiredLRPs() []models.DesiredLRP

func (*FakeAppManagerBBS) GetActualLRPsByProcessGuid 

func (fakeBBS *FakeAppManagerBBS) GetActualLRPsByProcessGuid(string) ([]models.ActualLRP, error)

func (*FakeAppManagerBBS) GetLRPStartAuctions 

func (fakeBBS *FakeAppManagerBBS) GetLRPStartAuctions() []models.LRPStartAuction

func (*FakeAppManagerBBS) GetLRPStopAuctions 

func (fakeBBS *FakeAppManagerBBS) GetLRPStopAuctions() []models.LRPStopAuction

func (*FakeAppManagerBBS) GetRemovedDesiredLRPProcessGuids 

func (fakeBBS *FakeAppManagerBBS) GetRemovedDesiredLRPProcessGuids() []string

func (*FakeAppManagerBBS) GetStopLRPInstances 

func (fakeBBS *FakeAppManagerBBS) GetStopLRPInstances() []models.StopLRPInstance

func (*FakeAppManagerBBS) RemoveDesiredLRPByProcessGuid 

func (fakeBBS *FakeAppManagerBBS) RemoveDesiredLRPByProcessGuid(processGuid string) error

func (*FakeAppManagerBBS) RequestLRPStartAuction 

func (fakeBBS *FakeAppManagerBBS) RequestLRPStartAuction(lrp models.LRPStartAuction) error

func (*FakeAppManagerBBS) RequestLRPStopAuction 

func (fakeBBS *FakeAppManagerBBS) RequestLRPStopAuction(lrp models.LRPStopAuction) error

func (*FakeAppManagerBBS) RequestStopLRPInstance 

func (fakeBBS *FakeAppManagerBBS) RequestStopLRPInstance(lrp models.StopLRPInstance) error

func (*FakeAppManagerBBS) WatchForDesiredLRPChanges 

func (fakeBBS *FakeAppManagerBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)

type FakeAuctioneerBBS 

type FakeAuctioneerBBS struct {
	*sync.Mutex

	LRPStartAuctionChan      chan models.LRPStartAuction
	LRPStartAuctionStopChan  chan bool
	LRPStartAuctionErrorChan chan error

	LRPStopAuctionChan      chan models.LRPStopAuction
	LRPStopAuctionStopChan  chan bool
	LRPStopAuctionErrorChan chan error

	LockChannel        chan bool
	ReleaseLockChannel chan chan bool
	LockError          error

	ClaimedLRPStartAuctions   []models.LRPStartAuction
	ClaimLRPStartAuctionError error

	ResolvedLRPStartAuction     models.LRPStartAuction
	ResolveLRPStartAuctionError error

	ClaimedLRPStopAuctions   []models.LRPStopAuction
	ClaimLRPStopAuctionError error

	ResolvedLRPStopAuction     models.LRPStopAuction
	ResolveLRPStopAuctionError error

	Executors []models.ExecutorPresence
}

func NewFakeAuctioneerBBS 

func NewFakeAuctioneerBBS() *FakeAuctioneerBBS

func (*FakeAuctioneerBBS) ClaimLRPStartAuction 

func (bbs *FakeAuctioneerBBS) ClaimLRPStartAuction(auction models.LRPStartAuction) error

func (*FakeAuctioneerBBS) ClaimLRPStopAuction 

func (bbs *FakeAuctioneerBBS) ClaimLRPStopAuction(auction models.LRPStopAuction) error

func (*FakeAuctioneerBBS) GetAllExecutors 

func (bbs *FakeAuctioneerBBS) GetAllExecutors() ([]models.ExecutorPresence, error)

func (*FakeAuctioneerBBS) GetClaimedLRPStartAuctions 

func (bbs *FakeAuctioneerBBS) GetClaimedLRPStartAuctions() []models.LRPStartAuction

func (*FakeAuctioneerBBS) GetClaimedLRPStopAuctions 

func (bbs *FakeAuctioneerBBS) GetClaimedLRPStopAuctions() []models.LRPStopAuction

func (*FakeAuctioneerBBS) GetResolvedLRPStartAuction 

func (bbs *FakeAuctioneerBBS) GetResolvedLRPStartAuction() models.LRPStartAuction

func (*FakeAuctioneerBBS) GetResolvedLRPStopAuction 

func (bbs *FakeAuctioneerBBS) GetResolvedLRPStopAuction() models.LRPStopAuction

func (*FakeAuctioneerBBS) MaintainAuctioneerLock 

func (bbs *FakeAuctioneerBBS) MaintainAuctioneerLock(interval time.Duration, auctioneerID string) (<-chan bool, chan<- chan bool, error)

func (*FakeAuctioneerBBS) ResolveLRPStartAuction 

func (bbs *FakeAuctioneerBBS) ResolveLRPStartAuction(auction models.LRPStartAuction) error

func (*FakeAuctioneerBBS) ResolveLRPStopAuction 

func (bbs *FakeAuctioneerBBS) ResolveLRPStopAuction(auction models.LRPStopAuction) error

func (*FakeAuctioneerBBS) WatchForLRPStartAuction 

func (bbs *FakeAuctioneerBBS) WatchForLRPStartAuction() (<-chan models.LRPStartAuction, chan<- bool, <-chan error)

func (*FakeAuctioneerBBS) WatchForLRPStopAuction 

func (bbs *FakeAuctioneerBBS) WatchForLRPStopAuction() (<-chan models.LRPStopAuction, chan<- bool, <-chan error)

type FakeConvergerBBS 

type FakeConvergerBBS struct {
	ConvergeLockStatusChan chan bool
	ConvergeLockStopChan   chan chan bool

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFakeConvergerBBS 

func NewFakeConvergerBBS() *FakeConvergerBBS

func (*FakeConvergerBBS) CallsToConvergeLRPStartAuctions 

func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStartAuctions() int

func (*FakeConvergerBBS) CallsToConvergeLRPStopAuctions 

func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPStopAuctions() int

func (*FakeConvergerBBS) CallsToConvergeLRPs 

func (fakeBBS *FakeConvergerBBS) CallsToConvergeLRPs() int

func (*FakeConvergerBBS) CallsToConvergeTasks 

func (fakeBBS *FakeConvergerBBS) CallsToConvergeTasks() int

func (*FakeConvergerBBS) ConvergeLRPStartAuctions 

func (fakeBBS *FakeConvergerBBS) ConvergeLRPStartAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)

func (*FakeConvergerBBS) ConvergeLRPStopAuctions 

func (fakeBBS *FakeConvergerBBS) ConvergeLRPStopAuctions(kickPendingDuration time.Duration, expireClaimedDuration time.Duration)

func (*FakeConvergerBBS) ConvergeLRPs 

func (fakeBBS *FakeConvergerBBS) ConvergeLRPs()

func (*FakeConvergerBBS) ConvergeTask 

func (fakeBBS *FakeConvergerBBS) ConvergeTask(timeToClaim time.Duration, taskConvergenceInterval time.Duration)

func (*FakeConvergerBBS) ConvergeTimeToClaimTasks 

func (fakeBBS *FakeConvergerBBS) ConvergeTimeToClaimTasks() time.Duration

func (*FakeConvergerBBS) MaintainConvergeLock 

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

func (*FakeConvergerBBS) SetMaintainConvergeLockError 

func (fakeBBS *FakeConvergerBBS) SetMaintainConvergeLockError(err error)

type FakeMetricsBBS 

type FakeMetricsBBS struct {
	GetAllTasksReturns struct {
		Models []models.Task
		Err    error
	}

	GetServiceRegistrationsReturns struct {
		Registrations models.ServiceRegistrations
		Err           error
	}
}

func NewFakeMetricsBBS 

func NewFakeMetricsBBS() *FakeMetricsBBS

func (*FakeMetricsBBS) GetAllTasks 

func (bbs *FakeMetricsBBS) GetAllTasks() ([]models.Task, error)

func (*FakeMetricsBBS) GetServiceRegistrations 

func (bbs *FakeMetricsBBS) GetServiceRegistrations() (models.ServiceRegistrations, error)

type FakeNsyncBBS 

type FakeNsyncBBS struct {
	DesireLRPStub func(models.DesiredLRP) error

	RemoveDesiredLRPByProcessGuidStub func(guid string) error

	GetAllDesiredLRPsStub func() ([]models.DesiredLRP, error)

	ChangeDesiredLRPStub func(change models.DesiredLRPChange) error
	// contains filtered or unexported fields
}

func (*FakeNsyncBBS) ChangeDesiredLRP 

func (fake *FakeNsyncBBS) ChangeDesiredLRP(arg1 models.DesiredLRPChange) error

func (*FakeNsyncBBS) ChangeDesiredLRPArgsForCall 

func (fake *FakeNsyncBBS) ChangeDesiredLRPArgsForCall(i int) models.DesiredLRPChange

func (*FakeNsyncBBS) ChangeDesiredLRPCallCount 

func (fake *FakeNsyncBBS) ChangeDesiredLRPCallCount() int

func (*FakeNsyncBBS) ChangeDesiredLRPReturns 

func (fake *FakeNsyncBBS) ChangeDesiredLRPReturns(result1 error)

func (*FakeNsyncBBS) DesireLRP 

func (fake *FakeNsyncBBS) DesireLRP(arg1 models.DesiredLRP) error

func (*FakeNsyncBBS) DesireLRPArgsForCall 

func (fake *FakeNsyncBBS) DesireLRPArgsForCall(i int) models.DesiredLRP

func (*FakeNsyncBBS) DesireLRPCallCount 

func (fake *FakeNsyncBBS) DesireLRPCallCount() int

func (*FakeNsyncBBS) DesireLRPReturns 

func (fake *FakeNsyncBBS) DesireLRPReturns(result1 error)

func (*FakeNsyncBBS) GetAllDesiredLRPs 

func (fake *FakeNsyncBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)

func (*FakeNsyncBBS) GetAllDesiredLRPsCallCount 

func (fake *FakeNsyncBBS) GetAllDesiredLRPsCallCount() int

func (*FakeNsyncBBS) GetAllDesiredLRPsReturns 

func (fake *FakeNsyncBBS) GetAllDesiredLRPsReturns(result1 []models.DesiredLRP, result2 error)

func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuid 

func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuid(arg1 string) error

func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidArgsForCall 

func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidArgsForCall(i int) string

func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidCallCount 

func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidCallCount() int

func (*FakeNsyncBBS) RemoveDesiredLRPByProcessGuidReturns 

func (fake *FakeNsyncBBS) RemoveDesiredLRPByProcessGuidReturns(result1 error)

type FakePresence 

type FakePresence struct {
	MaintainStatus bool
	Maintained     bool
	Removed        bool
	// contains filtered or unexported fields
}

func (*FakePresence) Maintain 

func (p *FakePresence) Maintain(interval time.Duration) (<-chan bool, error)

func (*FakePresence) Remove 

func (p *FakePresence) Remove()

type FakeRepBBS 

type FakeRepBBS struct {
	MaintainExecutorPresenceStub func(heartbeatInterval time.Duration, executorPresence models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error)

	WatchForDesiredTaskStub func() (<-chan models.Task, chan<- bool, <-chan error)

	ClaimTaskStub func(taskGuid string, executorID string) error

	StartTaskStub func(taskGuid string, executorID string, containerHandle string) error

	CompleteTaskStub func(taskGuid string, failed bool, failureReason string, result string) error

	ReportActualLRPAsStartingStub func(lrp models.ActualLRP, executorID string) error

	ReportActualLRPAsRunningStub func(lrp models.ActualLRP, executorId string) error

	RemoveActualLRPStub func(lrp models.ActualLRP) error

	WatchForStopLRPInstanceStub func() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)

	ResolveStopLRPInstanceStub func(stopInstance models.StopLRPInstance) error
	// contains filtered or unexported fields
}

func (*FakeRepBBS) ClaimTask 

func (fake *FakeRepBBS) ClaimTask(arg1 string, arg2 string) error

func (*FakeRepBBS) ClaimTaskArgsForCall 

func (fake *FakeRepBBS) ClaimTaskArgsForCall(i int) (string, string)

func (*FakeRepBBS) ClaimTaskCallCount 

func (fake *FakeRepBBS) ClaimTaskCallCount() int

func (*FakeRepBBS) ClaimTaskReturns 

func (fake *FakeRepBBS) ClaimTaskReturns(result1 error)

func (*FakeRepBBS) CompleteTask 

func (fake *FakeRepBBS) CompleteTask(arg1 string, arg2 bool, arg3 string, arg4 string) error

func (*FakeRepBBS) CompleteTaskArgsForCall 

func (fake *FakeRepBBS) CompleteTaskArgsForCall(i int) (string, bool, string, string)

func (*FakeRepBBS) CompleteTaskCallCount 

func (fake *FakeRepBBS) CompleteTaskCallCount() int

func (*FakeRepBBS) CompleteTaskReturns 

func (fake *FakeRepBBS) CompleteTaskReturns(result1 error)

func (*FakeRepBBS) MaintainExecutorPresence 

func (fake *FakeRepBBS) MaintainExecutorPresence(arg1 time.Duration, arg2 models.ExecutorPresence) (services_bbs.Presence, <-chan bool, error)

func (*FakeRepBBS) MaintainExecutorPresenceArgsForCall 

func (fake *FakeRepBBS) MaintainExecutorPresenceArgsForCall(i int) (time.Duration, models.ExecutorPresence)

func (*FakeRepBBS) MaintainExecutorPresenceCallCount 

func (fake *FakeRepBBS) MaintainExecutorPresenceCallCount() int

func (*FakeRepBBS) MaintainExecutorPresenceReturns 

func (fake *FakeRepBBS) MaintainExecutorPresenceReturns(result1 services_bbs.Presence, result2 <-chan bool, result3 error)

func (*FakeRepBBS) RemoveActualLRP 

func (fake *FakeRepBBS) RemoveActualLRP(arg1 models.ActualLRP) error

func (*FakeRepBBS) RemoveActualLRPArgsForCall 

func (fake *FakeRepBBS) RemoveActualLRPArgsForCall(i int) models.ActualLRP

func (*FakeRepBBS) RemoveActualLRPCallCount 

func (fake *FakeRepBBS) RemoveActualLRPCallCount() int

func (*FakeRepBBS) RemoveActualLRPReturns 

func (fake *FakeRepBBS) RemoveActualLRPReturns(result1 error)

func (*FakeRepBBS) ReportActualLRPAsRunning 

func (fake *FakeRepBBS) ReportActualLRPAsRunning(arg1 models.ActualLRP, arg2 string) error

func (*FakeRepBBS) ReportActualLRPAsRunningArgsForCall 

func (fake *FakeRepBBS) ReportActualLRPAsRunningArgsForCall(i int) (models.ActualLRP, string)

func (*FakeRepBBS) ReportActualLRPAsRunningCallCount 

func (fake *FakeRepBBS) ReportActualLRPAsRunningCallCount() int

func (*FakeRepBBS) ReportActualLRPAsRunningReturns 

func (fake *FakeRepBBS) ReportActualLRPAsRunningReturns(result1 error)

func (*FakeRepBBS) ReportActualLRPAsStarting 

func (fake *FakeRepBBS) ReportActualLRPAsStarting(arg1 models.ActualLRP, arg2 string) error

func (*FakeRepBBS) ReportActualLRPAsStartingArgsForCall 

func (fake *FakeRepBBS) ReportActualLRPAsStartingArgsForCall(i int) (models.ActualLRP, string)

func (*FakeRepBBS) ReportActualLRPAsStartingCallCount 

func (fake *FakeRepBBS) ReportActualLRPAsStartingCallCount() int

func (*FakeRepBBS) ReportActualLRPAsStartingReturns 

func (fake *FakeRepBBS) ReportActualLRPAsStartingReturns(result1 error)

func (*FakeRepBBS) ResolveStopLRPInstance 

func (fake *FakeRepBBS) ResolveStopLRPInstance(arg1 models.StopLRPInstance) error

func (*FakeRepBBS) ResolveStopLRPInstanceArgsForCall 

func (fake *FakeRepBBS) ResolveStopLRPInstanceArgsForCall(i int) models.StopLRPInstance

func (*FakeRepBBS) ResolveStopLRPInstanceCallCount 

func (fake *FakeRepBBS) ResolveStopLRPInstanceCallCount() int

func (*FakeRepBBS) ResolveStopLRPInstanceReturns 

func (fake *FakeRepBBS) ResolveStopLRPInstanceReturns(result1 error)

func (*FakeRepBBS) StartTask 

func (fake *FakeRepBBS) StartTask(arg1 string, arg2 string, arg3 string) error

func (*FakeRepBBS) StartTaskArgsForCall 

func (fake *FakeRepBBS) StartTaskArgsForCall(i int) (string, string, string)

func (*FakeRepBBS) StartTaskCallCount 

func (fake *FakeRepBBS) StartTaskCallCount() int

func (*FakeRepBBS) StartTaskReturns 

func (fake *FakeRepBBS) StartTaskReturns(result1 error)

func (*FakeRepBBS) WatchForDesiredTask 

func (fake *FakeRepBBS) WatchForDesiredTask() (<-chan models.Task, chan<- bool, <-chan error)

func (*FakeRepBBS) WatchForDesiredTaskCallCount 

func (fake *FakeRepBBS) WatchForDesiredTaskCallCount() int

func (*FakeRepBBS) WatchForDesiredTaskReturns 

func (fake *FakeRepBBS) WatchForDesiredTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)

func (*FakeRepBBS) WatchForStopLRPInstance 

func (fake *FakeRepBBS) WatchForStopLRPInstance() (<-chan models.StopLRPInstance, chan<- bool, <-chan error)

func (*FakeRepBBS) WatchForStopLRPInstanceCallCount 

func (fake *FakeRepBBS) WatchForStopLRPInstanceCallCount() int

func (*FakeRepBBS) WatchForStopLRPInstanceReturns 

func (fake *FakeRepBBS) WatchForStopLRPInstanceReturns(result1 <-chan models.StopLRPInstance, result2 chan<- bool, result3 <-chan error)

type FakeRouteEmitterBBS 

type FakeRouteEmitterBBS struct {
	DesiredLRPChangeChan chan models.DesiredLRPChange

	ActualLRPChangeChan chan models.ActualLRPChange

	AllDesiredLRPs []models.DesiredLRP
	AllActualLRPs  []models.ActualLRP

	DesiredLRP models.DesiredLRP
	ActualLRPs []models.ActualLRP

	WhenGettingRunningActualLRPs func() ([]models.ActualLRP, error)
	WhenGettingAllDesiredLRPs    func() ([]models.DesiredLRP, error)

	WhenGettingActualLRPsByProcessGuid func(string) ([]models.ActualLRP, error)
	WhenGettingDesiredLRPByProcessGuid func(string) (models.DesiredLRP, error)
	// contains filtered or unexported fields
}

func NewFakeRouteEmitterBBS 

func NewFakeRouteEmitterBBS() *FakeRouteEmitterBBS

func (*FakeRouteEmitterBBS) GetAllDesiredLRPs 

func (fakeBBS *FakeRouteEmitterBBS) GetAllDesiredLRPs() ([]models.DesiredLRP, error)

func (*FakeRouteEmitterBBS) GetDesiredLRPByProcessGuid 

func (fakeBBS *FakeRouteEmitterBBS) GetDesiredLRPByProcessGuid(processGuid string) (models.DesiredLRP, error)

func (*FakeRouteEmitterBBS) GetRunningActualLRPs 

func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPs() ([]models.ActualLRP, error)

func (*FakeRouteEmitterBBS) GetRunningActualLRPsByProcessGuid 

func (fakeBBS *FakeRouteEmitterBBS) GetRunningActualLRPsByProcessGuid(processGuid string) ([]models.ActualLRP, error)

func (*FakeRouteEmitterBBS) SendWatchForActualLRPChangesError 

func (fakeBBS *FakeRouteEmitterBBS) SendWatchForActualLRPChangesError(err error)

func (*FakeRouteEmitterBBS) SendWatchForDesiredLRPChangesError 

func (fakeBBS *FakeRouteEmitterBBS) SendWatchForDesiredLRPChangesError(err error)

func (*FakeRouteEmitterBBS) WatchForActualLRPChanges 

func (fakeBBS *FakeRouteEmitterBBS) WatchForActualLRPChanges() (<-chan models.ActualLRPChange, chan<- bool, <-chan error)

func (*FakeRouteEmitterBBS) WatchForDesiredLRPChanges 

func (fakeBBS *FakeRouteEmitterBBS) WatchForDesiredLRPChanges() (<-chan models.DesiredLRPChange, chan<- bool, <-chan error)

type FakeStagerBBS 

type FakeStagerBBS struct {
	WatchForCompletedTaskStub func() (<-chan models.Task, chan<- bool, <-chan error)

	DesireTaskStub func(models.Task) error

	ResolvingTaskStub func(taskGuid string) error

	ResolveTaskStub func(taskGuid string) error

	GetAvailableFileServerStub func() (string, error)
	// contains filtered or unexported fields
}

func (*FakeStagerBBS) DesireTask 

func (fake *FakeStagerBBS) DesireTask(arg1 models.Task) error

func (*FakeStagerBBS) DesireTaskArgsForCall 

func (fake *FakeStagerBBS) DesireTaskArgsForCall(i int) models.Task

func (*FakeStagerBBS) DesireTaskCallCount 

func (fake *FakeStagerBBS) DesireTaskCallCount() int

func (*FakeStagerBBS) DesireTaskReturns 

func (fake *FakeStagerBBS) DesireTaskReturns(result1 error)

func (*FakeStagerBBS) GetAvailableFileServer 

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

func (*FakeStagerBBS) GetAvailableFileServerCallCount 

func (fake *FakeStagerBBS) GetAvailableFileServerCallCount() int

func (*FakeStagerBBS) GetAvailableFileServerReturns 

func (fake *FakeStagerBBS) GetAvailableFileServerReturns(result1 string, result2 error)

func (*FakeStagerBBS) ResolveTask 

func (fake *FakeStagerBBS) ResolveTask(arg1 string) error

func (*FakeStagerBBS) ResolveTaskArgsForCall 

func (fake *FakeStagerBBS) ResolveTaskArgsForCall(i int) string

func (*FakeStagerBBS) ResolveTaskCallCount 

func (fake *FakeStagerBBS) ResolveTaskCallCount() int

func (*FakeStagerBBS) ResolveTaskReturns 

func (fake *FakeStagerBBS) ResolveTaskReturns(result1 error)

func (*FakeStagerBBS) ResolvingTask 

func (fake *FakeStagerBBS) ResolvingTask(arg1 string) error

func (*FakeStagerBBS) ResolvingTaskArgsForCall 

func (fake *FakeStagerBBS) ResolvingTaskArgsForCall(i int) string

func (*FakeStagerBBS) ResolvingTaskCallCount 

func (fake *FakeStagerBBS) ResolvingTaskCallCount() int

func (*FakeStagerBBS) ResolvingTaskReturns 

func (fake *FakeStagerBBS) ResolvingTaskReturns(result1 error)

func (*FakeStagerBBS) WatchForCompletedTask 

func (fake *FakeStagerBBS) WatchForCompletedTask() (<-chan models.Task, chan<- bool, <-chan error)

func (*FakeStagerBBS) WatchForCompletedTaskCallCount 

func (fake *FakeStagerBBS) WatchForCompletedTaskCallCount() int

func (*FakeStagerBBS) WatchForCompletedTaskReturns 

func (fake *FakeStagerBBS) WatchForCompletedTaskReturns(result1 <-chan models.Task, result2 chan<- bool, result3 <-chan error)

type FileServerGetter 

type FileServerGetter struct {
	WhenGettingAvailableFileServer func() (string, error)
}

func (*FileServerGetter) GetAvailableFileServer 

func (fs *FileServerGetter) GetAvailableFileServer() (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.