schedulerfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeBuildFactory
  • func (fake *FakeBuildFactory) Create(arg1 atc.JobConfig, arg2 atc.ResourceConfigs, arg3 atc.VersionedResourceTypes, ...) (atc.Plan, error)
  • func (fake *FakeBuildFactory) CreateArgsForCall(i int) (atc.JobConfig, atc.ResourceConfigs, atc.VersionedResourceTypes, ...)
  • func (fake *FakeBuildFactory) CreateCallCount() int
  • func (fake *FakeBuildFactory) CreateReturns(result1 atc.Plan, result2 error)
  • func (fake *FakeBuildFactory) CreateReturnsOnCall(i int, result1 atc.Plan, result2 error)
  • func (fake *FakeBuildFactory) Invocations() map[string][][]interface{}
• type FakeBuildScheduler
  • func (fake *FakeBuildScheduler) Invocations() map[string][][]interface{}
  • func (fake *FakeBuildScheduler) SaveNextInputMapping(logger lager.Logger, job db.Job) error
  • func (fake *FakeBuildScheduler) SaveNextInputMappingArgsForCall(i int) (lager.Logger, db.Job)
  • func (fake *FakeBuildScheduler) SaveNextInputMappingCallCount() int
  • func (fake *FakeBuildScheduler) SaveNextInputMappingReturns(result1 error)
  • func (fake *FakeBuildScheduler) SaveNextInputMappingReturnsOnCall(i int, result1 error)
  • func (fake *FakeBuildScheduler) Schedule(logger lager.Logger, versions *algorithm.VersionsDB, jobs []db.Job, ...) (map[string]time.Duration, error)
  • func (fake *FakeBuildScheduler) ScheduleArgsForCall(i int) (lager.Logger, *algorithm.VersionsDB, []db.Job, db.Resources, ...)
  • func (fake *FakeBuildScheduler) ScheduleCallCount() int
  • func (fake *FakeBuildScheduler) ScheduleReturns(result1 map[string]time.Duration, result2 error)
  • func (fake *FakeBuildScheduler) ScheduleReturnsOnCall(i int, result1 map[string]time.Duration, result2 error)
  • func (fake *FakeBuildScheduler) TriggerImmediately(logger lager.Logger, job db.Job, resources db.Resources, ...) (db.Build, scheduler.Waiter, error)
  • func (fake *FakeBuildScheduler) TriggerImmediatelyArgsForCall(i int) (lager.Logger, db.Job, db.Resources, atc.VersionedResourceTypes)
  • func (fake *FakeBuildScheduler) TriggerImmediatelyCallCount() int
  • func (fake *FakeBuildScheduler) TriggerImmediatelyReturns(result1 db.Build, result2 scheduler.Waiter, result3 error)
  • func (fake *FakeBuildScheduler) TriggerImmediatelyReturnsOnCall(i int, result1 db.Build, result2 scheduler.Waiter, result3 error)
• type FakeBuildStarter
  • func (fake *FakeBuildStarter) Invocations() map[string][][]interface{}
  • func (fake *FakeBuildStarter) TryStartPendingBuildsForJob(logger lager.Logger, job db.Job, resources db.Resources, ...) error
  • func (fake *FakeBuildStarter) TryStartPendingBuildsForJobArgsForCall(i int) (lager.Logger, db.Job, db.Resources, atc.VersionedResourceTypes, []db.Build)
  • func (fake *FakeBuildStarter) TryStartPendingBuildsForJobCallCount() int
  • func (fake *FakeBuildStarter) TryStartPendingBuildsForJobReturns(result1 error)
  • func (fake *FakeBuildStarter) TryStartPendingBuildsForJobReturnsOnCall(i int, result1 error)
• type FakeScanner
  • func (fake *FakeScanner) Invocations() map[string][][]interface{}
  • func (fake *FakeScanner) Scan(arg1 lager.Logger, arg2 string) error
  • func (fake *FakeScanner) ScanArgsForCall(i int) (lager.Logger, string)
  • func (fake *FakeScanner) ScanCallCount() int
  • func (fake *FakeScanner) ScanReturns(result1 error)
  • func (fake *FakeScanner) ScanReturnsOnCall(i int, result1 error)

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, jobs []db.Job, resources db.Resources, resourceTypes atc.VersionedResourceTypes) (map[string]time.Duration, error)

	TriggerImmediatelyStub func(logger lager.Logger, job db.Job, resources db.Resources, resourceTypes atc.VersionedResourceTypes) (db.Build, scheduler.Waiter, error)

	SaveNextInputMappingStub func(logger lager.Logger, job db.Job) 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 db.Job) error

func (*FakeBuildScheduler) SaveNextInputMappingArgsForCall

func (fake *FakeBuildScheduler) SaveNextInputMappingArgsForCall(i int) (lager.Logger, db.Job)

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, jobs []db.Job, resources db.Resources, resourceTypes atc.VersionedResourceTypes) (map[string]time.Duration, error)

func (*FakeBuildScheduler) ScheduleArgsForCall

func (fake *FakeBuildScheduler) ScheduleArgsForCall(i int) (lager.Logger, *algorithm.VersionsDB, []db.Job, db.Resources, 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, job db.Job, resources db.Resources, resourceTypes atc.VersionedResourceTypes) (db.Build, scheduler.Waiter, error)

func (*FakeBuildScheduler) TriggerImmediatelyArgsForCall

func (fake *FakeBuildScheduler) TriggerImmediatelyArgsForCall(i int) (lager.Logger, db.Job, db.Resources, 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, job db.Job, resources db.Resources, 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, job db.Job, resources db.Resources, resourceTypes atc.VersionedResourceTypes, nextPendingBuilds []db.Build) error

func (*FakeBuildStarter) TryStartPendingBuildsForJobArgsForCall

func (fake *FakeBuildStarter) TryStartPendingBuildsForJobArgsForCall(i int) (lager.Logger, db.Job, db.Resources, 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 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)