schedulerfakes

package
v0.0.0-...-484f906 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2016 License: Apache-2.0 Imports: 7 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 FakeBuildScheduler 

type FakeBuildScheduler struct {
	ScheduleStub func(logger lager.Logger, versions *algorithm.VersionsDB, jobConfigs atc.JobConfigs, resourceConfigs atc.ResourceConfigs, resourceTypes atc.ResourceTypes) (map[string]time.Duration, error)

	TriggerImmediatelyStub func(logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.ResourceTypes) (db.Build, scheduler.Waiter, error)

	SaveNextInputMappingStub func(logger lager.Logger, job atc.JobConfig) error
	// contains filtered or unexported fields
}

func (*FakeBuildScheduler) Invocations 

func (fake *FakeBuildScheduler) Invocations() map[string][][]interface{}

func (*FakeBuildScheduler) SaveNextInputMapping 

func (fake *FakeBuildScheduler) SaveNextInputMapping(logger lager.Logger, job atc.JobConfig) error

func (*FakeBuildScheduler) SaveNextInputMappingArgsForCall 

func (fake *FakeBuildScheduler) SaveNextInputMappingArgsForCall(i int) (lager.Logger, atc.JobConfig)

func (*FakeBuildScheduler) SaveNextInputMappingCallCount 

func (fake *FakeBuildScheduler) SaveNextInputMappingCallCount() int

func (*FakeBuildScheduler) SaveNextInputMappingReturns 

func (fake *FakeBuildScheduler) SaveNextInputMappingReturns(result1 error)

func (*FakeBuildScheduler) Schedule 

func (fake *FakeBuildScheduler) Schedule(logger lager.Logger, versions *algorithm.VersionsDB, jobConfigs atc.JobConfigs, resourceConfigs atc.ResourceConfigs, resourceTypes atc.ResourceTypes) (map[string]time.Duration, error)

func (*FakeBuildScheduler) ScheduleArgsForCall 

func (fake *FakeBuildScheduler) ScheduleArgsForCall(i int) (lager.Logger, *algorithm.VersionsDB, atc.JobConfigs, atc.ResourceConfigs, atc.ResourceTypes)

func (*FakeBuildScheduler) ScheduleCallCount 

func (fake *FakeBuildScheduler) ScheduleCallCount() int

func (*FakeBuildScheduler) ScheduleReturns 

func (fake *FakeBuildScheduler) ScheduleReturns(result1 map[string]time.Duration, result2 error)

func (*FakeBuildScheduler) TriggerImmediately 

func (fake *FakeBuildScheduler) TriggerImmediately(logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.ResourceTypes) (db.Build, scheduler.Waiter, error)

func (*FakeBuildScheduler) TriggerImmediatelyArgsForCall 

func (fake *FakeBuildScheduler) TriggerImmediatelyArgsForCall(i int) (lager.Logger, atc.JobConfig, atc.ResourceConfigs, atc.ResourceTypes)

func (*FakeBuildScheduler) TriggerImmediatelyCallCount 

func (fake *FakeBuildScheduler) TriggerImmediatelyCallCount() int

func (*FakeBuildScheduler) TriggerImmediatelyReturns 

func (fake *FakeBuildScheduler) TriggerImmediatelyReturns(result1 db.Build, result2 scheduler.Waiter, result3 error)

type FakeScanner 

type FakeScanner struct {
	ScanStub func(lager.Logger, string) error
	// contains filtered or unexported fields
}

func (*FakeScanner) Invocations 

func (fake *FakeScanner) Invocations() map[string][][]interface{}

func (*FakeScanner) Scan 

func (fake *FakeScanner) Scan(arg1 lager.Logger, arg2 string) error

func (*FakeScanner) ScanArgsForCall 

func (fake *FakeScanner) ScanArgsForCall(i int) (lager.Logger, string)

func (*FakeScanner) ScanCallCount 

func (fake *FakeScanner) ScanCallCount() int

func (*FakeScanner) ScanReturns 

func (fake *FakeScanner) ScanReturns(result1 error)

type FakeSchedulerDB 

type FakeSchedulerDB struct {
	AcquireSchedulingLockStub func(lager.Logger, time.Duration) (db.Lock, bool, error)

	LoadVersionsDBStub func() (*algorithm.VersionsDB, error)

	GetPipelineNameStub func() string

	ReloadStub func() (bool, error)

	ConfigStub func() atc.Config

	CreateJobBuildStub func(job string) (db.Build, error)

	EnsurePendingBuildExistsStub func(jobName string) error

	AcquireResourceCheckingForJobLockStub func(logger lager.Logger, job string) (db.Lock, bool, error)

	GetAllPendingBuildsStub func() (map[string][]db.Build, error)

	GetPendingBuildsForJobStub func(jobName string) ([]db.Build, error)
	// contains filtered or unexported fields
}

func (*FakeSchedulerDB) AcquireResourceCheckingForJobLock 

func (fake *FakeSchedulerDB) AcquireResourceCheckingForJobLock(logger lager.Logger, job string) (db.Lock, bool, error)

func (*FakeSchedulerDB) AcquireResourceCheckingForJobLockArgsForCall 

func (fake *FakeSchedulerDB) AcquireResourceCheckingForJobLockArgsForCall(i int) (lager.Logger, string)

func (*FakeSchedulerDB) AcquireResourceCheckingForJobLockCallCount 

func (fake *FakeSchedulerDB) AcquireResourceCheckingForJobLockCallCount() int

func (*FakeSchedulerDB) AcquireResourceCheckingForJobLockReturns 

func (fake *FakeSchedulerDB) AcquireResourceCheckingForJobLockReturns(result1 db.Lock, result2 bool, result3 error)

func (*FakeSchedulerDB) AcquireSchedulingLock 

func (fake *FakeSchedulerDB) AcquireSchedulingLock(arg1 lager.Logger, arg2 time.Duration) (db.Lock, bool, error)

func (*FakeSchedulerDB) AcquireSchedulingLockArgsForCall 

func (fake *FakeSchedulerDB) AcquireSchedulingLockArgsForCall(i int) (lager.Logger, time.Duration)

func (*FakeSchedulerDB) AcquireSchedulingLockCallCount 

func (fake *FakeSchedulerDB) AcquireSchedulingLockCallCount() int

func (*FakeSchedulerDB) AcquireSchedulingLockReturns 

func (fake *FakeSchedulerDB) AcquireSchedulingLockReturns(result1 db.Lock, result2 bool, result3 error)

func (*FakeSchedulerDB) Config 

func (fake *FakeSchedulerDB) Config() atc.Config

func (*FakeSchedulerDB) ConfigCallCount 

func (fake *FakeSchedulerDB) ConfigCallCount() int

func (*FakeSchedulerDB) ConfigReturns 

func (fake *FakeSchedulerDB) ConfigReturns(result1 atc.Config)

func (*FakeSchedulerDB) CreateJobBuild 

func (fake *FakeSchedulerDB) CreateJobBuild(job string) (db.Build, error)

func (*FakeSchedulerDB) CreateJobBuildArgsForCall 

func (fake *FakeSchedulerDB) CreateJobBuildArgsForCall(i int) string

func (*FakeSchedulerDB) CreateJobBuildCallCount 

func (fake *FakeSchedulerDB) CreateJobBuildCallCount() int

func (*FakeSchedulerDB) CreateJobBuildReturns 

func (fake *FakeSchedulerDB) CreateJobBuildReturns(result1 db.Build, result2 error)

func (*FakeSchedulerDB) EnsurePendingBuildExists 

func (fake *FakeSchedulerDB) EnsurePendingBuildExists(jobName string) error

func (*FakeSchedulerDB) EnsurePendingBuildExistsArgsForCall 

func (fake *FakeSchedulerDB) EnsurePendingBuildExistsArgsForCall(i int) string

func (*FakeSchedulerDB) EnsurePendingBuildExistsCallCount 

func (fake *FakeSchedulerDB) EnsurePendingBuildExistsCallCount() int

func (*FakeSchedulerDB) EnsurePendingBuildExistsReturns 

func (fake *FakeSchedulerDB) EnsurePendingBuildExistsReturns(result1 error)

func (*FakeSchedulerDB) GetAllPendingBuilds 

func (fake *FakeSchedulerDB) GetAllPendingBuilds() (map[string][]db.Build, error)

func (*FakeSchedulerDB) GetAllPendingBuildsCallCount 

func (fake *FakeSchedulerDB) GetAllPendingBuildsCallCount() int

func (*FakeSchedulerDB) GetAllPendingBuildsReturns 

func (fake *FakeSchedulerDB) GetAllPendingBuildsReturns(result1 map[string][]db.Build, result2 error)

func (*FakeSchedulerDB) GetPendingBuildsForJob 

func (fake *FakeSchedulerDB) GetPendingBuildsForJob(jobName string) ([]db.Build, error)

func (*FakeSchedulerDB) GetPendingBuildsForJobArgsForCall 

func (fake *FakeSchedulerDB) GetPendingBuildsForJobArgsForCall(i int) string

func (*FakeSchedulerDB) GetPendingBuildsForJobCallCount 

func (fake *FakeSchedulerDB) GetPendingBuildsForJobCallCount() int

func (*FakeSchedulerDB) GetPendingBuildsForJobReturns 

func (fake *FakeSchedulerDB) GetPendingBuildsForJobReturns(result1 []db.Build, result2 error)

func (*FakeSchedulerDB) GetPipelineName 

func (fake *FakeSchedulerDB) GetPipelineName() string

func (*FakeSchedulerDB) GetPipelineNameCallCount 

func (fake *FakeSchedulerDB) GetPipelineNameCallCount() int

func (*FakeSchedulerDB) GetPipelineNameReturns 

func (fake *FakeSchedulerDB) GetPipelineNameReturns(result1 string)

func (*FakeSchedulerDB) Invocations 

func (fake *FakeSchedulerDB) Invocations() map[string][][]interface{}

func (*FakeSchedulerDB) LoadVersionsDB 

func (fake *FakeSchedulerDB) LoadVersionsDB() (*algorithm.VersionsDB, error)

func (*FakeSchedulerDB) LoadVersionsDBCallCount 

func (fake *FakeSchedulerDB) LoadVersionsDBCallCount() int

func (*FakeSchedulerDB) LoadVersionsDBReturns 

func (fake *FakeSchedulerDB) LoadVersionsDBReturns(result1 *algorithm.VersionsDB, result2 error)

func (*FakeSchedulerDB) Reload 

func (fake *FakeSchedulerDB) Reload() (bool, error)

func (*FakeSchedulerDB) ReloadCallCount 

func (fake *FakeSchedulerDB) ReloadCallCount() int

func (*FakeSchedulerDB) ReloadReturns 

func (fake *FakeSchedulerDB) ReloadReturns(result1 bool, result2 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.