schedulerfakes

package
v0.0.0-...-7f11b89 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 2017 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

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 FakeBuildFactory 

type FakeBuildFactory struct {
	CreateStub func(atc.JobConfig, atc.ResourceConfigs, atc.VersionedResourceTypes, []db.BuildInput) (atc.Plan, error)
	// contains filtered or unexported fields
}

func (*FakeBuildFactory) Create 

func (fake *FakeBuildFactory) Create(arg1 atc.JobConfig, arg2 atc.ResourceConfigs, arg3 atc.VersionedResourceTypes, arg4 []db.BuildInput) (atc.Plan, error)

func (*FakeBuildFactory) CreateArgsForCall 

func (fake *FakeBuildFactory) CreateArgsForCall(i int) (atc.JobConfig, atc.ResourceConfigs, atc.VersionedResourceTypes, []db.BuildInput)

func (*FakeBuildFactory) CreateCallCount 

func (fake *FakeBuildFactory) CreateCallCount() int

func (*FakeBuildFactory) CreateReturns 

func (fake *FakeBuildFactory) CreateReturns(result1 atc.Plan, result2 error)

func (*FakeBuildFactory) CreateReturnsOnCall 

func (fake *FakeBuildFactory) CreateReturnsOnCall(i int, result1 atc.Plan, result2 error)

func (*FakeBuildFactory) Invocations 

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

type FakeBuildScheduler 

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

	TriggerImmediatelyStub func(logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes) (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) SaveNextInputMappingReturnsOnCall 

func (fake *FakeBuildScheduler) SaveNextInputMappingReturnsOnCall(i int, result1 error)

func (*FakeBuildScheduler) Schedule 

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

func (*FakeBuildScheduler) ScheduleArgsForCall 

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

func (*FakeBuildScheduler) ScheduleCallCount 

func (fake *FakeBuildScheduler) ScheduleCallCount() int

func (*FakeBuildScheduler) ScheduleReturns 

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

func (*FakeBuildScheduler) ScheduleReturnsOnCall 

func (fake *FakeBuildScheduler) ScheduleReturnsOnCall(i int, 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.VersionedResourceTypes) (db.Build, scheduler.Waiter, error)

func (*FakeBuildScheduler) TriggerImmediatelyArgsForCall 

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

func (*FakeBuildScheduler) TriggerImmediatelyCallCount 

func (fake *FakeBuildScheduler) TriggerImmediatelyCallCount() int

func (*FakeBuildScheduler) TriggerImmediatelyReturns 

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

func (*FakeBuildScheduler) TriggerImmediatelyReturnsOnCall 

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

type FakeBuildStarter 

type FakeBuildStarter struct {
	TryStartPendingBuildsForJobStub func(logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes, nextPendingBuilds []db.Build) error
	// contains filtered or unexported fields
}

func (*FakeBuildStarter) Invocations 

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

func (*FakeBuildStarter) TryStartPendingBuildsForJob 

func (fake *FakeBuildStarter) TryStartPendingBuildsForJob(logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes, nextPendingBuilds []db.Build) error

func (*FakeBuildStarter) TryStartPendingBuildsForJobArgsForCall 

func (fake *FakeBuildStarter) TryStartPendingBuildsForJobArgsForCall(i int) (lager.Logger, atc.JobConfig, atc.ResourceConfigs, atc.VersionedResourceTypes, []db.Build)

func (*FakeBuildStarter) TryStartPendingBuildsForJobCallCount 

func (fake *FakeBuildStarter) TryStartPendingBuildsForJobCallCount() int

func (*FakeBuildStarter) TryStartPendingBuildsForJobReturns 

func (fake *FakeBuildStarter) TryStartPendingBuildsForJobReturns(result1 error)

func (*FakeBuildStarter) TryStartPendingBuildsForJobReturnsOnCall 

func (fake *FakeBuildStarter) TryStartPendingBuildsForJobReturnsOnCall(i int, result1 error)

type FakeBuildStarterBuildsDB 

type FakeBuildStarterBuildsDB struct {
	FinishBuildStub func(buildID int, pipelineID int, status db.Status) error
	// contains filtered or unexported fields
}

func (*FakeBuildStarterBuildsDB) FinishBuild 

func (fake *FakeBuildStarterBuildsDB) FinishBuild(buildID int, pipelineID int, status db.Status) error

func (*FakeBuildStarterBuildsDB) FinishBuildArgsForCall 

func (fake *FakeBuildStarterBuildsDB) FinishBuildArgsForCall(i int) (int, int, db.Status)

func (*FakeBuildStarterBuildsDB) FinishBuildCallCount 

func (fake *FakeBuildStarterBuildsDB) FinishBuildCallCount() int

func (*FakeBuildStarterBuildsDB) FinishBuildReturns 

func (fake *FakeBuildStarterBuildsDB) FinishBuildReturns(result1 error)

func (*FakeBuildStarterBuildsDB) FinishBuildReturnsOnCall 

func (fake *FakeBuildStarterBuildsDB) FinishBuildReturnsOnCall(i int, result1 error)

func (*FakeBuildStarterBuildsDB) Invocations 

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

type FakeBuildStarterDB 

type FakeBuildStarterDB struct {
	GetNextBuildInputsStub func(jobName string) ([]db.BuildInput, bool, error)

	IsPausedStub func() (bool, error)

	GetJobStub func(job string) (db.SavedJob, bool, error)

	UpdateBuildToScheduledStub func(int) (bool, error)

	UseInputsForBuildStub func(buildID int, inputs []db.BuildInput) error

	LoadVersionsDBStub func() (*algorithm.VersionsDB, error)
	// contains filtered or unexported fields
}

func (*FakeBuildStarterDB) GetJob 

func (fake *FakeBuildStarterDB) GetJob(job string) (db.SavedJob, bool, error)

func (*FakeBuildStarterDB) GetJobArgsForCall 

func (fake *FakeBuildStarterDB) GetJobArgsForCall(i int) string

func (*FakeBuildStarterDB) GetJobCallCount 

func (fake *FakeBuildStarterDB) GetJobCallCount() int

func (*FakeBuildStarterDB) GetJobReturns 

func (fake *FakeBuildStarterDB) GetJobReturns(result1 db.SavedJob, result2 bool, result3 error)

func (*FakeBuildStarterDB) GetJobReturnsOnCall 

func (fake *FakeBuildStarterDB) GetJobReturnsOnCall(i int, result1 db.SavedJob, result2 bool, result3 error)

func (*FakeBuildStarterDB) GetNextBuildInputs 

func (fake *FakeBuildStarterDB) GetNextBuildInputs(jobName string) ([]db.BuildInput, bool, error)

func (*FakeBuildStarterDB) GetNextBuildInputsArgsForCall 

func (fake *FakeBuildStarterDB) GetNextBuildInputsArgsForCall(i int) string

func (*FakeBuildStarterDB) GetNextBuildInputsCallCount 

func (fake *FakeBuildStarterDB) GetNextBuildInputsCallCount() int

func (*FakeBuildStarterDB) GetNextBuildInputsReturns 

func (fake *FakeBuildStarterDB) GetNextBuildInputsReturns(result1 []db.BuildInput, result2 bool, result3 error)

func (*FakeBuildStarterDB) GetNextBuildInputsReturnsOnCall 

func (fake *FakeBuildStarterDB) GetNextBuildInputsReturnsOnCall(i int, result1 []db.BuildInput, result2 bool, result3 error)

func (*FakeBuildStarterDB) Invocations 

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

func (*FakeBuildStarterDB) IsPaused 

func (fake *FakeBuildStarterDB) IsPaused() (bool, error)

func (*FakeBuildStarterDB) IsPausedCallCount 

func (fake *FakeBuildStarterDB) IsPausedCallCount() int

func (*FakeBuildStarterDB) IsPausedReturns 

func (fake *FakeBuildStarterDB) IsPausedReturns(result1 bool, result2 error)

func (*FakeBuildStarterDB) IsPausedReturnsOnCall 

func (fake *FakeBuildStarterDB) IsPausedReturnsOnCall(i int, result1 bool, result2 error)

func (*FakeBuildStarterDB) LoadVersionsDB 

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

func (*FakeBuildStarterDB) LoadVersionsDBCallCount 

func (fake *FakeBuildStarterDB) LoadVersionsDBCallCount() int

func (*FakeBuildStarterDB) LoadVersionsDBReturns 

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

func (*FakeBuildStarterDB) LoadVersionsDBReturnsOnCall 

func (fake *FakeBuildStarterDB) LoadVersionsDBReturnsOnCall(i int, result1 *algorithm.VersionsDB, result2 error)

func (*FakeBuildStarterDB) UpdateBuildToScheduled 

func (fake *FakeBuildStarterDB) UpdateBuildToScheduled(arg1 int) (bool, error)

func (*FakeBuildStarterDB) UpdateBuildToScheduledArgsForCall 

func (fake *FakeBuildStarterDB) UpdateBuildToScheduledArgsForCall(i int) int

func (*FakeBuildStarterDB) UpdateBuildToScheduledCallCount 

func (fake *FakeBuildStarterDB) UpdateBuildToScheduledCallCount() int

func (*FakeBuildStarterDB) UpdateBuildToScheduledReturns 

func (fake *FakeBuildStarterDB) UpdateBuildToScheduledReturns(result1 bool, result2 error)

func (*FakeBuildStarterDB) UpdateBuildToScheduledReturnsOnCall 

func (fake *FakeBuildStarterDB) UpdateBuildToScheduledReturnsOnCall(i int, result1 bool, result2 error)

func (*FakeBuildStarterDB) UseInputsForBuild 

func (fake *FakeBuildStarterDB) UseInputsForBuild(buildID int, inputs []db.BuildInput) error

func (*FakeBuildStarterDB) UseInputsForBuildArgsForCall 

func (fake *FakeBuildStarterDB) UseInputsForBuildArgsForCall(i int) (int, []db.BuildInput)

func (*FakeBuildStarterDB) UseInputsForBuildCallCount 

func (fake *FakeBuildStarterDB) UseInputsForBuildCallCount() int

func (*FakeBuildStarterDB) UseInputsForBuildReturns 

func (fake *FakeBuildStarterDB) UseInputsForBuildReturns(result1 error)

func (*FakeBuildStarterDB) UseInputsForBuildReturnsOnCall 

func (fake *FakeBuildStarterDB) UseInputsForBuildReturnsOnCall(i int, result1 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)

func (*FakeScanner) ScanReturnsOnCall 

func (fake *FakeScanner) ScanReturnsOnCall(i int, result1 error)

type FakeSchedulerDB 

type FakeSchedulerDB struct {
	AcquireSchedulingLockStub func(lager.Logger, time.Duration) (lock.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

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

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

func (*FakeSchedulerDB) AcquireSchedulingLock 

func (fake *FakeSchedulerDB) AcquireSchedulingLock(arg1 lager.Logger, arg2 time.Duration) (lock.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 lock.Lock, result2 bool, result3 error)

func (*FakeSchedulerDB) AcquireSchedulingLockReturnsOnCall 

func (fake *FakeSchedulerDB) AcquireSchedulingLockReturnsOnCall(i int, result1 lock.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) ConfigReturnsOnCall 

func (fake *FakeSchedulerDB) ConfigReturnsOnCall(i int, 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) CreateJobBuildReturnsOnCall 

func (fake *FakeSchedulerDB) CreateJobBuildReturnsOnCall(i int, 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) EnsurePendingBuildExistsReturnsOnCall 

func (fake *FakeSchedulerDB) EnsurePendingBuildExistsReturnsOnCall(i int, 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) GetAllPendingBuildsReturnsOnCall 

func (fake *FakeSchedulerDB) GetAllPendingBuildsReturnsOnCall(i int, 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) GetPendingBuildsForJobReturnsOnCall 

func (fake *FakeSchedulerDB) GetPendingBuildsForJobReturnsOnCall(i int, 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) GetPipelineNameReturnsOnCall 

func (fake *FakeSchedulerDB) GetPipelineNameReturnsOnCall(i int, 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) LoadVersionsDBReturnsOnCall 

func (fake *FakeSchedulerDB) LoadVersionsDBReturnsOnCall(i int, 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)

func (*FakeSchedulerDB) ReloadReturnsOnCall 

func (fake *FakeSchedulerDB) ReloadReturnsOnCall(i int, 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.