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 ¶
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 ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter
Index ¶
- type FakeClient
- func (fake *FakeClient) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) ([]worker.Worker, error)
- func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
- func (fake *FakeClient) AllSatisfyingCallCount() int
- func (fake *FakeClient) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeClient) CreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, ...) (worker.Container, error)
- func (fake *FakeClient) CreateContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, ...)
- func (fake *FakeClient) CreateContainerCallCount() int
- func (fake *FakeClient) CreateContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeClient) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)
- func (fake *FakeClient) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)
- func (fake *FakeClient) FindContainerForIdentifierCallCount() int
- func (fake *FakeClient) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeClient) GetWorker(workerName string) (worker.Worker, error)
- func (fake *FakeClient) GetWorkerArgsForCall(i int) string
- func (fake *FakeClient) GetWorkerCallCount() int
- func (fake *FakeClient) GetWorkerReturns(result1 worker.Worker, result2 error)
- func (fake *FakeClient) LookupContainer(arg1 lager.Logger, arg2 string) (worker.Container, bool, error)
- func (fake *FakeClient) LookupContainerArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeClient) LookupContainerCallCount() int
- func (fake *FakeClient) LookupContainerReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeClient) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)
- func (fake *FakeClient) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
- func (fake *FakeClient) SatisfyingCallCount() int
- func (fake *FakeClient) SatisfyingReturns(result1 worker.Worker, result2 error)
- type FakeContainer
- func (fake *FakeContainer) Attach(processID string, io garden.ProcessIO) (garden.Process, error)
- func (fake *FakeContainer) AttachArgsForCall(i int) (string, garden.ProcessIO)
- func (fake *FakeContainer) AttachCallCount() int
- func (fake *FakeContainer) AttachReturns(result1 garden.Process, result2 error)
- func (fake *FakeContainer) CurrentBandwidthLimits() (garden.BandwidthLimits, error)
- func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int
- func (fake *FakeContainer) CurrentBandwidthLimitsReturns(result1 garden.BandwidthLimits, result2 error)
- func (fake *FakeContainer) CurrentCPULimits() (garden.CPULimits, error)
- func (fake *FakeContainer) CurrentCPULimitsCallCount() int
- func (fake *FakeContainer) CurrentCPULimitsReturns(result1 garden.CPULimits, result2 error)
- func (fake *FakeContainer) CurrentDiskLimits() (garden.DiskLimits, error)
- func (fake *FakeContainer) CurrentDiskLimitsCallCount() int
- func (fake *FakeContainer) CurrentDiskLimitsReturns(result1 garden.DiskLimits, result2 error)
- func (fake *FakeContainer) CurrentMemoryLimits() (garden.MemoryLimits, error)
- func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int
- func (fake *FakeContainer) CurrentMemoryLimitsReturns(result1 garden.MemoryLimits, result2 error)
- func (fake *FakeContainer) Destroy() error
- func (fake *FakeContainer) DestroyCallCount() int
- func (fake *FakeContainer) DestroyReturns(result1 error)
- func (fake *FakeContainer) Handle() string
- func (fake *FakeContainer) HandleCallCount() int
- func (fake *FakeContainer) HandleReturns(result1 string)
- func (fake *FakeContainer) Info() (garden.ContainerInfo, error)
- func (fake *FakeContainer) InfoCallCount() int
- func (fake *FakeContainer) InfoReturns(result1 garden.ContainerInfo, result2 error)
- func (fake *FakeContainer) LimitBandwidth(limits garden.BandwidthLimits) error
- func (fake *FakeContainer) LimitBandwidthArgsForCall(i int) garden.BandwidthLimits
- func (fake *FakeContainer) LimitBandwidthCallCount() int
- func (fake *FakeContainer) LimitBandwidthReturns(result1 error)
- func (fake *FakeContainer) LimitCPU(limits garden.CPULimits) error
- func (fake *FakeContainer) LimitCPUArgsForCall(i int) garden.CPULimits
- func (fake *FakeContainer) LimitCPUCallCount() int
- func (fake *FakeContainer) LimitCPUReturns(result1 error)
- func (fake *FakeContainer) LimitMemory(limits garden.MemoryLimits) error
- func (fake *FakeContainer) LimitMemoryArgsForCall(i int) garden.MemoryLimits
- func (fake *FakeContainer) LimitMemoryCallCount() int
- func (fake *FakeContainer) LimitMemoryReturns(result1 error)
- func (fake *FakeContainer) Metrics() (garden.Metrics, error)
- func (fake *FakeContainer) MetricsCallCount() int
- func (fake *FakeContainer) MetricsReturns(result1 garden.Metrics, result2 error)
- func (fake *FakeContainer) NetIn(hostPort uint32, containerPort uint32) (uint32, uint32, error)
- func (fake *FakeContainer) NetInArgsForCall(i int) (uint32, uint32)
- func (fake *FakeContainer) NetInCallCount() int
- func (fake *FakeContainer) NetInReturns(result1 uint32, result2 uint32, result3 error)
- func (fake *FakeContainer) NetOut(netOutRule garden.NetOutRule) error
- func (fake *FakeContainer) NetOutArgsForCall(i int) garden.NetOutRule
- func (fake *FakeContainer) NetOutCallCount() int
- func (fake *FakeContainer) NetOutReturns(result1 error)
- func (fake *FakeContainer) Properties() (garden.Properties, error)
- func (fake *FakeContainer) PropertiesCallCount() int
- func (fake *FakeContainer) PropertiesReturns(result1 garden.Properties, result2 error)
- func (fake *FakeContainer) Property(name string) (string, error)
- func (fake *FakeContainer) PropertyArgsForCall(i int) string
- func (fake *FakeContainer) PropertyCallCount() int
- func (fake *FakeContainer) PropertyReturns(result1 string, result2 error)
- func (fake *FakeContainer) Release(arg1 *time.Duration)
- func (fake *FakeContainer) ReleaseArgsForCall(i int) *time.Duration
- func (fake *FakeContainer) ReleaseCallCount() int
- func (fake *FakeContainer) RemoveProperty(name string) error
- func (fake *FakeContainer) RemovePropertyArgsForCall(i int) string
- func (fake *FakeContainer) RemovePropertyCallCount() int
- func (fake *FakeContainer) RemovePropertyReturns(result1 error)
- func (fake *FakeContainer) Run(arg1 garden.ProcessSpec, arg2 garden.ProcessIO) (garden.Process, error)
- func (fake *FakeContainer) RunArgsForCall(i int) (garden.ProcessSpec, garden.ProcessIO)
- func (fake *FakeContainer) RunCallCount() int
- func (fake *FakeContainer) RunReturns(result1 garden.Process, result2 error)
- func (fake *FakeContainer) SetGraceTime(graceTime time.Duration) error
- func (fake *FakeContainer) SetGraceTimeArgsForCall(i int) time.Duration
- func (fake *FakeContainer) SetGraceTimeCallCount() int
- func (fake *FakeContainer) SetGraceTimeReturns(result1 error)
- func (fake *FakeContainer) SetProperty(name string, value string) error
- func (fake *FakeContainer) SetPropertyArgsForCall(i int) (string, string)
- func (fake *FakeContainer) SetPropertyCallCount() int
- func (fake *FakeContainer) SetPropertyReturns(result1 error)
- func (fake *FakeContainer) Stop(kill bool) error
- func (fake *FakeContainer) StopArgsForCall(i int) bool
- func (fake *FakeContainer) StopCallCount() int
- func (fake *FakeContainer) StopReturns(result1 error)
- func (fake *FakeContainer) StreamIn(spec garden.StreamInSpec) error
- func (fake *FakeContainer) StreamInArgsForCall(i int) garden.StreamInSpec
- func (fake *FakeContainer) StreamInCallCount() int
- func (fake *FakeContainer) StreamInReturns(result1 error)
- func (fake *FakeContainer) StreamOut(spec garden.StreamOutSpec) (io.ReadCloser, error)
- func (fake *FakeContainer) StreamOutArgsForCall(i int) garden.StreamOutSpec
- func (fake *FakeContainer) StreamOutCallCount() int
- func (fake *FakeContainer) StreamOutReturns(result1 io.ReadCloser, result2 error)
- func (fake *FakeContainer) VolumeMounts() []worker.VolumeMount
- func (fake *FakeContainer) VolumeMountsCallCount() int
- func (fake *FakeContainer) VolumeMountsReturns(result1 []worker.VolumeMount)
- func (fake *FakeContainer) Volumes() []worker.Volume
- func (fake *FakeContainer) VolumesCallCount() int
- func (fake *FakeContainer) VolumesReturns(result1 []worker.Volume)
- type FakeGardenConnectionFactory
- func (fake *FakeGardenConnectionFactory) BuildConnection() gconn.Connection
- func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int
- func (fake *FakeGardenConnectionFactory) BuildConnectionFromDB() (gconn.Connection, error)
- func (fake *FakeGardenConnectionFactory) BuildConnectionFromDBCallCount() int
- func (fake *FakeGardenConnectionFactory) BuildConnectionFromDBReturns(result1 gconn.Connection, result2 error)
- func (fake *FakeGardenConnectionFactory) BuildConnectionReturns(result1 gconn.Connection)
- type FakeGardenConnectionFactoryDB
- func (fake *FakeGardenConnectionFactoryDB) GetWorker(arg1 string) (db.SavedWorker, bool, error)
- func (fake *FakeGardenConnectionFactoryDB) GetWorkerArgsForCall(i int) string
- func (fake *FakeGardenConnectionFactoryDB) GetWorkerCallCount() int
- func (fake *FakeGardenConnectionFactoryDB) GetWorkerReturns(result1 db.SavedWorker, result2 bool, result3 error)
- type FakeGardenWorkerDB
- func (fake *FakeGardenWorkerDB) CreateContainer(arg1 db.Container, arg2 time.Duration) (db.SavedContainer, error)
- func (fake *FakeGardenWorkerDB) CreateContainerArgsForCall(i int) (db.Container, time.Duration)
- func (fake *FakeGardenWorkerDB) CreateContainerCallCount() int
- func (fake *FakeGardenWorkerDB) CreateContainerReturns(result1 db.SavedContainer, result2 error)
- func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
- func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)
- func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerCallCount() int
- func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)
- type FakeImage
- func (fake *FakeImage) Metadata() worker.ImageMetadata
- func (fake *FakeImage) MetadataCallCount() int
- func (fake *FakeImage) MetadataReturns(result1 worker.ImageMetadata)
- func (fake *FakeImage) Release(arg1 *time.Duration)
- func (fake *FakeImage) ReleaseArgsForCall(i int) *time.Duration
- func (fake *FakeImage) ReleaseCallCount() int
- func (fake *FakeImage) Volume() worker.Volume
- func (fake *FakeImage) VolumeCallCount() int
- func (fake *FakeImage) VolumeReturns(result1 worker.Volume)
- type FakeImageFetcher
- func (fake *FakeImageFetcher) FetchImage(arg1 lager.Logger, arg2 atc.TaskImageConfig, arg3 <-chan os.Signal, ...) (worker.Image, error)
- func (fake *FakeImageFetcher) FetchImageArgsForCall(i int) (lager.Logger, atc.TaskImageConfig, <-chan os.Signal, worker.Identifier, ...)
- func (fake *FakeImageFetcher) FetchImageCallCount() int
- func (fake *FakeImageFetcher) FetchImageReturns(result1 worker.Image, result2 error)
- type FakeImageFetchingDelegate
- func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 db.VolumeIdentifier) error
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) db.VolumeIdentifier
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)
- func (fake *FakeImageFetchingDelegate) Stderr() io.Writer
- func (fake *FakeImageFetchingDelegate) StderrCallCount() int
- func (fake *FakeImageFetchingDelegate) StderrReturns(result1 io.Writer)
- type FakeRetryPolicy
- type FakeSaveWorkerDB
- func (fake *FakeSaveWorkerDB) SaveWorker(arg1 db.WorkerInfo, arg2 time.Duration) (db.SavedWorker, error)
- func (fake *FakeSaveWorkerDB) SaveWorkerArgsForCall(i int) (db.WorkerInfo, time.Duration)
- func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int
- func (fake *FakeSaveWorkerDB) SaveWorkerReturns(result1 db.SavedWorker, result2 error)
- type FakeSleeper
- type FakeVolume
- func (fake *FakeVolume) Expiration() (time.Duration, time.Time, error)
- func (fake *FakeVolume) ExpirationCallCount() int
- func (fake *FakeVolume) ExpirationReturns(result1 time.Duration, result2 time.Time, result3 error)
- func (fake *FakeVolume) Handle() string
- func (fake *FakeVolume) HandleCallCount() int
- func (fake *FakeVolume) HandleReturns(result1 string)
- func (fake *FakeVolume) Path() string
- func (fake *FakeVolume) PathCallCount() int
- func (fake *FakeVolume) PathReturns(result1 string)
- func (fake *FakeVolume) Properties() (baggageclaim.VolumeProperties, error)
- func (fake *FakeVolume) PropertiesCallCount() int
- func (fake *FakeVolume) PropertiesReturns(result1 baggageclaim.VolumeProperties, result2 error)
- func (fake *FakeVolume) Release(arg1 *time.Duration)
- func (fake *FakeVolume) ReleaseArgsForCall(i int) *time.Duration
- func (fake *FakeVolume) ReleaseCallCount() int
- func (fake *FakeVolume) SetProperty(key string, value string) error
- func (fake *FakeVolume) SetPropertyArgsForCall(i int) (string, string)
- func (fake *FakeVolume) SetPropertyCallCount() int
- func (fake *FakeVolume) SetPropertyReturns(result1 error)
- func (fake *FakeVolume) SetTTL(arg1 time.Duration) error
- func (fake *FakeVolume) SetTTLArgsForCall(i int) time.Duration
- func (fake *FakeVolume) SetTTLCallCount() int
- func (fake *FakeVolume) SetTTLReturns(result1 error)
- type FakeVolumeFactory
- func (fake *FakeVolumeFactory) Build(arg1 lager.Logger, arg2 baggageclaim.Volume) (worker.Volume, error)
- func (fake *FakeVolumeFactory) BuildArgsForCall(i int) (lager.Logger, baggageclaim.Volume)
- func (fake *FakeVolumeFactory) BuildCallCount() int
- func (fake *FakeVolumeFactory) BuildReturns(result1 worker.Volume, result2 error)
- type FakeVolumeFactoryDB
- func (fake *FakeVolumeFactoryDB) GetVolumeTTL(volumeHandle string) (time.Duration, error)
- func (fake *FakeVolumeFactoryDB) GetVolumeTTLArgsForCall(i int) string
- func (fake *FakeVolumeFactoryDB) GetVolumeTTLCallCount() int
- func (fake *FakeVolumeFactoryDB) GetVolumeTTLReturns(result1 time.Duration, result2 error)
- func (fake *FakeVolumeFactoryDB) ReapVolume(handle string) error
- func (fake *FakeVolumeFactoryDB) ReapVolumeArgsForCall(i int) string
- func (fake *FakeVolumeFactoryDB) ReapVolumeCallCount() int
- func (fake *FakeVolumeFactoryDB) ReapVolumeReturns(result1 error)
- func (fake *FakeVolumeFactoryDB) SetVolumeTTL(arg1 string, arg2 time.Duration) error
- func (fake *FakeVolumeFactoryDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)
- func (fake *FakeVolumeFactoryDB) SetVolumeTTLCallCount() int
- func (fake *FakeVolumeFactoryDB) SetVolumeTTLReturns(result1 error)
- type FakeWorker
- func (fake *FakeWorker) ActiveContainers() int
- func (fake *FakeWorker) ActiveContainersCallCount() int
- func (fake *FakeWorker) ActiveContainersReturns(result1 int)
- func (fake *FakeWorker) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) ([]worker.Worker, error)
- func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
- func (fake *FakeWorker) AllSatisfyingCallCount() int
- func (fake *FakeWorker) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeWorker) CreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, ...) (worker.Container, error)
- func (fake *FakeWorker) CreateContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, ...)
- func (fake *FakeWorker) CreateContainerCallCount() int
- func (fake *FakeWorker) CreateContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeWorker) Description() string
- func (fake *FakeWorker) DescriptionCallCount() int
- func (fake *FakeWorker) DescriptionReturns(result1 string)
- func (fake *FakeWorker) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)
- func (fake *FakeWorker) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)
- func (fake *FakeWorker) FindContainerForIdentifierCallCount() int
- func (fake *FakeWorker) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeWorker) GetWorker(workerName string) (worker.Worker, error)
- func (fake *FakeWorker) GetWorkerArgsForCall(i int) string
- func (fake *FakeWorker) GetWorkerCallCount() int
- func (fake *FakeWorker) GetWorkerReturns(result1 worker.Worker, result2 error)
- func (fake *FakeWorker) LookupContainer(arg1 lager.Logger, arg2 string) (worker.Container, bool, error)
- func (fake *FakeWorker) LookupContainerArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeWorker) LookupContainerCallCount() int
- func (fake *FakeWorker) LookupContainerReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeWorker) Name() string
- func (fake *FakeWorker) NameCallCount() int
- func (fake *FakeWorker) NameReturns(result1 string)
- func (fake *FakeWorker) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)
- func (fake *FakeWorker) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
- func (fake *FakeWorker) SatisfyingCallCount() int
- func (fake *FakeWorker) SatisfyingReturns(result1 worker.Worker, result2 error)
- func (fake *FakeWorker) VolumeManager() (baggageclaim.Client, bool)
- func (fake *FakeWorker) VolumeManagerCallCount() int
- func (fake *FakeWorker) VolumeManagerReturns(result1 baggageclaim.Client, result2 bool)
- type FakeWorkerDB
- func (fake *FakeWorkerDB) CreateContainer(arg1 db.Container, arg2 time.Duration) (db.SavedContainer, error)
- func (fake *FakeWorkerDB) CreateContainerArgsForCall(i int) (db.Container, time.Duration)
- func (fake *FakeWorkerDB) CreateContainerCallCount() int
- func (fake *FakeWorkerDB) CreateContainerReturns(result1 db.SavedContainer, result2 error)
- func (fake *FakeWorkerDB) FindContainerByIdentifier(arg1 db.ContainerIdentifier) (db.SavedContainer, bool, error)
- func (fake *FakeWorkerDB) FindContainerByIdentifierArgsForCall(i int) db.ContainerIdentifier
- func (fake *FakeWorkerDB) FindContainerByIdentifierCallCount() int
- func (fake *FakeWorkerDB) FindContainerByIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)
- func (fake *FakeWorkerDB) GetContainer(arg1 string) (db.SavedContainer, bool, error)
- func (fake *FakeWorkerDB) GetContainerArgsForCall(i int) string
- func (fake *FakeWorkerDB) GetContainerCallCount() int
- func (fake *FakeWorkerDB) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)
- func (fake *FakeWorkerDB) GetVolumeTTL(volumeHandle string) (time.Duration, error)
- func (fake *FakeWorkerDB) GetVolumeTTLArgsForCall(i int) string
- func (fake *FakeWorkerDB) GetVolumeTTLCallCount() int
- func (fake *FakeWorkerDB) GetVolumeTTLReturns(result1 time.Duration, result2 error)
- func (fake *FakeWorkerDB) GetWorker(arg1 string) (db.SavedWorker, bool, error)
- func (fake *FakeWorkerDB) GetWorkerArgsForCall(i int) string
- func (fake *FakeWorkerDB) GetWorkerCallCount() int
- func (fake *FakeWorkerDB) GetWorkerReturns(result1 db.SavedWorker, result2 bool, result3 error)
- func (fake *FakeWorkerDB) ReapContainer(handle string) error
- func (fake *FakeWorkerDB) ReapContainerArgsForCall(i int) string
- func (fake *FakeWorkerDB) ReapContainerCallCount() int
- func (fake *FakeWorkerDB) ReapContainerReturns(result1 error)
- func (fake *FakeWorkerDB) ReapVolume(handle string) error
- func (fake *FakeWorkerDB) ReapVolumeArgsForCall(i int) string
- func (fake *FakeWorkerDB) ReapVolumeCallCount() int
- func (fake *FakeWorkerDB) ReapVolumeReturns(result1 error)
- func (fake *FakeWorkerDB) SetVolumeTTL(arg1 string, arg2 time.Duration) error
- func (fake *FakeWorkerDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)
- func (fake *FakeWorkerDB) SetVolumeTTLCallCount() int
- func (fake *FakeWorkerDB) SetVolumeTTLReturns(result1 error)
- func (fake *FakeWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
- func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)
- func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerCallCount() int
- func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)
- func (fake *FakeWorkerDB) Workers() ([]db.SavedWorker, error)
- func (fake *FakeWorkerDB) WorkersCallCount() int
- func (fake *FakeWorkerDB) WorkersReturns(result1 []db.SavedWorker, result2 error)
- type FakeWorkerProvider
- func (fake *FakeWorkerProvider) FindContainerForIdentifier(arg1 worker.Identifier) (db.SavedContainer, bool, error)
- func (fake *FakeWorkerProvider) FindContainerForIdentifierArgsForCall(i int) worker.Identifier
- func (fake *FakeWorkerProvider) FindContainerForIdentifierCallCount() int
- func (fake *FakeWorkerProvider) FindContainerForIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) GetContainer(arg1 string) (db.SavedContainer, bool, error)
- func (fake *FakeWorkerProvider) GetContainerArgsForCall(i int) string
- func (fake *FakeWorkerProvider) GetContainerCallCount() int
- func (fake *FakeWorkerProvider) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) GetWorker(arg1 string) (worker.Worker, bool, error)
- func (fake *FakeWorkerProvider) GetWorkerArgsForCall(i int) string
- func (fake *FakeWorkerProvider) GetWorkerCallCount() int
- func (fake *FakeWorkerProvider) GetWorkerReturns(result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) ReapContainer(arg1 string) error
- func (fake *FakeWorkerProvider) ReapContainerArgsForCall(i int) string
- func (fake *FakeWorkerProvider) ReapContainerCallCount() int
- func (fake *FakeWorkerProvider) ReapContainerReturns(result1 error)
- func (fake *FakeWorkerProvider) Workers() ([]worker.Worker, error)
- func (fake *FakeWorkerProvider) WorkersCallCount() int
- func (fake *FakeWorkerProvider) WorkersReturns(result1 []worker.Worker, result2 error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeClient ¶
type FakeClient struct { CreateContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes) (worker.Container, error) FindContainerForIdentifierStub func(lager.Logger, worker.Identifier) (worker.Container, bool, error) LookupContainerStub func(lager.Logger, string) (worker.Container, bool, error) SatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) (worker.Worker, error) AllSatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) ([]worker.Worker, error) GetWorkerStub func(workerName string) (worker.Worker, error) // contains filtered or unexported fields }
func (*FakeClient) AllSatisfying ¶
func (fake *FakeClient) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) ([]worker.Worker, error)
func (*FakeClient) AllSatisfyingArgsForCall ¶
func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
func (*FakeClient) AllSatisfyingCallCount ¶
func (fake *FakeClient) AllSatisfyingCallCount() int
func (*FakeClient) AllSatisfyingReturns ¶
func (fake *FakeClient) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
func (*FakeClient) CreateContainer ¶
func (fake *FakeClient) CreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 worker.Identifier, arg5 worker.Metadata, arg6 worker.ContainerSpec, arg7 atc.ResourceTypes) (worker.Container, error)
func (*FakeClient) CreateContainerArgsForCall ¶
func (fake *FakeClient) CreateContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes)
func (*FakeClient) CreateContainerCallCount ¶
func (fake *FakeClient) CreateContainerCallCount() int
func (*FakeClient) CreateContainerReturns ¶
func (fake *FakeClient) CreateContainerReturns(result1 worker.Container, result2 error)
func (*FakeClient) FindContainerForIdentifier ¶
func (fake *FakeClient) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)
func (*FakeClient) FindContainerForIdentifierArgsForCall ¶
func (fake *FakeClient) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)
func (*FakeClient) FindContainerForIdentifierCallCount ¶
func (fake *FakeClient) FindContainerForIdentifierCallCount() int
func (*FakeClient) FindContainerForIdentifierReturns ¶
func (fake *FakeClient) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeClient) GetWorker ¶
func (fake *FakeClient) GetWorker(workerName string) (worker.Worker, error)
func (*FakeClient) GetWorkerArgsForCall ¶
func (fake *FakeClient) GetWorkerArgsForCall(i int) string
func (*FakeClient) GetWorkerCallCount ¶
func (fake *FakeClient) GetWorkerCallCount() int
func (*FakeClient) GetWorkerReturns ¶
func (fake *FakeClient) GetWorkerReturns(result1 worker.Worker, result2 error)
func (*FakeClient) LookupContainer ¶
func (*FakeClient) LookupContainerArgsForCall ¶
func (fake *FakeClient) LookupContainerArgsForCall(i int) (lager.Logger, string)
func (*FakeClient) LookupContainerCallCount ¶
func (fake *FakeClient) LookupContainerCallCount() int
func (*FakeClient) LookupContainerReturns ¶
func (fake *FakeClient) LookupContainerReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeClient) Satisfying ¶
func (fake *FakeClient) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)
func (*FakeClient) SatisfyingArgsForCall ¶
func (fake *FakeClient) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
func (*FakeClient) SatisfyingCallCount ¶
func (fake *FakeClient) SatisfyingCallCount() int
func (*FakeClient) SatisfyingReturns ¶
func (fake *FakeClient) SatisfyingReturns(result1 worker.Worker, result2 error)
type FakeContainer ¶
type FakeContainer struct { HandleStub func() string StopStub func(kill bool) error InfoStub func() (garden.ContainerInfo, error) StreamInStub func(spec garden.StreamInSpec) error StreamOutStub func(spec garden.StreamOutSpec) (io.ReadCloser, error) LimitBandwidthStub func(limits garden.BandwidthLimits) error CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error) LimitCPUStub func(limits garden.CPULimits) error CurrentCPULimitsStub func() (garden.CPULimits, error) CurrentDiskLimitsStub func() (garden.DiskLimits, error) LimitMemoryStub func(limits garden.MemoryLimits) error CurrentMemoryLimitsStub func() (garden.MemoryLimits, error) NetInStub func(hostPort, containerPort uint32) (uint32, uint32, error) NetOutStub func(netOutRule garden.NetOutRule) error RunStub func(garden.ProcessSpec, garden.ProcessIO) (garden.Process, error) AttachStub func(processID string, io garden.ProcessIO) (garden.Process, error) MetricsStub func() (garden.Metrics, error) SetGraceTimeStub func(graceTime time.Duration) error PropertiesStub func() (garden.Properties, error) PropertyStub func(name string) (string, error) SetPropertyStub func(name string, value string) error RemovePropertyStub func(name string) error DestroyStub func() error ReleaseStub func(*time.Duration) VolumesStub func() []worker.Volume VolumeMountsStub func() []worker.VolumeMount // contains filtered or unexported fields }
func (*FakeContainer) AttachArgsForCall ¶
func (fake *FakeContainer) AttachArgsForCall(i int) (string, garden.ProcessIO)
func (*FakeContainer) AttachCallCount ¶
func (fake *FakeContainer) AttachCallCount() int
func (*FakeContainer) AttachReturns ¶
func (fake *FakeContainer) AttachReturns(result1 garden.Process, result2 error)
func (*FakeContainer) CurrentBandwidthLimits ¶
func (fake *FakeContainer) CurrentBandwidthLimits() (garden.BandwidthLimits, error)
func (*FakeContainer) CurrentBandwidthLimitsCallCount ¶
func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int
func (*FakeContainer) CurrentBandwidthLimitsReturns ¶
func (fake *FakeContainer) CurrentBandwidthLimitsReturns(result1 garden.BandwidthLimits, result2 error)
func (*FakeContainer) CurrentCPULimits ¶
func (fake *FakeContainer) CurrentCPULimits() (garden.CPULimits, error)
func (*FakeContainer) CurrentCPULimitsCallCount ¶
func (fake *FakeContainer) CurrentCPULimitsCallCount() int
func (*FakeContainer) CurrentCPULimitsReturns ¶
func (fake *FakeContainer) CurrentCPULimitsReturns(result1 garden.CPULimits, result2 error)
func (*FakeContainer) CurrentDiskLimits ¶
func (fake *FakeContainer) CurrentDiskLimits() (garden.DiskLimits, error)
func (*FakeContainer) CurrentDiskLimitsCallCount ¶
func (fake *FakeContainer) CurrentDiskLimitsCallCount() int
func (*FakeContainer) CurrentDiskLimitsReturns ¶
func (fake *FakeContainer) CurrentDiskLimitsReturns(result1 garden.DiskLimits, result2 error)
func (*FakeContainer) CurrentMemoryLimits ¶
func (fake *FakeContainer) CurrentMemoryLimits() (garden.MemoryLimits, error)
func (*FakeContainer) CurrentMemoryLimitsCallCount ¶
func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int
func (*FakeContainer) CurrentMemoryLimitsReturns ¶
func (fake *FakeContainer) CurrentMemoryLimitsReturns(result1 garden.MemoryLimits, result2 error)
func (*FakeContainer) Destroy ¶
func (fake *FakeContainer) Destroy() error
func (*FakeContainer) DestroyCallCount ¶
func (fake *FakeContainer) DestroyCallCount() int
func (*FakeContainer) DestroyReturns ¶
func (fake *FakeContainer) DestroyReturns(result1 error)
func (*FakeContainer) Handle ¶
func (fake *FakeContainer) Handle() string
func (*FakeContainer) HandleCallCount ¶
func (fake *FakeContainer) HandleCallCount() int
func (*FakeContainer) HandleReturns ¶
func (fake *FakeContainer) HandleReturns(result1 string)
func (*FakeContainer) Info ¶
func (fake *FakeContainer) Info() (garden.ContainerInfo, error)
func (*FakeContainer) InfoCallCount ¶
func (fake *FakeContainer) InfoCallCount() int
func (*FakeContainer) InfoReturns ¶
func (fake *FakeContainer) InfoReturns(result1 garden.ContainerInfo, result2 error)
func (*FakeContainer) LimitBandwidth ¶
func (fake *FakeContainer) LimitBandwidth(limits garden.BandwidthLimits) error
func (*FakeContainer) LimitBandwidthArgsForCall ¶
func (fake *FakeContainer) LimitBandwidthArgsForCall(i int) garden.BandwidthLimits
func (*FakeContainer) LimitBandwidthCallCount ¶
func (fake *FakeContainer) LimitBandwidthCallCount() int
func (*FakeContainer) LimitBandwidthReturns ¶
func (fake *FakeContainer) LimitBandwidthReturns(result1 error)
func (*FakeContainer) LimitCPUArgsForCall ¶
func (fake *FakeContainer) LimitCPUArgsForCall(i int) garden.CPULimits
func (*FakeContainer) LimitCPUCallCount ¶
func (fake *FakeContainer) LimitCPUCallCount() int
func (*FakeContainer) LimitCPUReturns ¶
func (fake *FakeContainer) LimitCPUReturns(result1 error)
func (*FakeContainer) LimitMemory ¶
func (fake *FakeContainer) LimitMemory(limits garden.MemoryLimits) error
func (*FakeContainer) LimitMemoryArgsForCall ¶
func (fake *FakeContainer) LimitMemoryArgsForCall(i int) garden.MemoryLimits
func (*FakeContainer) LimitMemoryCallCount ¶
func (fake *FakeContainer) LimitMemoryCallCount() int
func (*FakeContainer) LimitMemoryReturns ¶
func (fake *FakeContainer) LimitMemoryReturns(result1 error)
func (*FakeContainer) MetricsCallCount ¶
func (fake *FakeContainer) MetricsCallCount() int
func (*FakeContainer) MetricsReturns ¶
func (fake *FakeContainer) MetricsReturns(result1 garden.Metrics, result2 error)
func (*FakeContainer) NetInArgsForCall ¶
func (fake *FakeContainer) NetInArgsForCall(i int) (uint32, uint32)
func (*FakeContainer) NetInCallCount ¶
func (fake *FakeContainer) NetInCallCount() int
func (*FakeContainer) NetInReturns ¶
func (fake *FakeContainer) NetInReturns(result1 uint32, result2 uint32, result3 error)
func (*FakeContainer) NetOut ¶
func (fake *FakeContainer) NetOut(netOutRule garden.NetOutRule) error
func (*FakeContainer) NetOutArgsForCall ¶
func (fake *FakeContainer) NetOutArgsForCall(i int) garden.NetOutRule
func (*FakeContainer) NetOutCallCount ¶
func (fake *FakeContainer) NetOutCallCount() int
func (*FakeContainer) NetOutReturns ¶
func (fake *FakeContainer) NetOutReturns(result1 error)
func (*FakeContainer) Properties ¶
func (fake *FakeContainer) Properties() (garden.Properties, error)
func (*FakeContainer) PropertiesCallCount ¶
func (fake *FakeContainer) PropertiesCallCount() int
func (*FakeContainer) PropertiesReturns ¶
func (fake *FakeContainer) PropertiesReturns(result1 garden.Properties, result2 error)
func (*FakeContainer) PropertyArgsForCall ¶
func (fake *FakeContainer) PropertyArgsForCall(i int) string
func (*FakeContainer) PropertyCallCount ¶
func (fake *FakeContainer) PropertyCallCount() int
func (*FakeContainer) PropertyReturns ¶
func (fake *FakeContainer) PropertyReturns(result1 string, result2 error)
func (*FakeContainer) Release ¶
func (fake *FakeContainer) Release(arg1 *time.Duration)
func (*FakeContainer) ReleaseArgsForCall ¶
func (fake *FakeContainer) ReleaseArgsForCall(i int) *time.Duration
func (*FakeContainer) ReleaseCallCount ¶
func (fake *FakeContainer) ReleaseCallCount() int
func (*FakeContainer) RemoveProperty ¶
func (fake *FakeContainer) RemoveProperty(name string) error
func (*FakeContainer) RemovePropertyArgsForCall ¶
func (fake *FakeContainer) RemovePropertyArgsForCall(i int) string
func (*FakeContainer) RemovePropertyCallCount ¶
func (fake *FakeContainer) RemovePropertyCallCount() int
func (*FakeContainer) RemovePropertyReturns ¶
func (fake *FakeContainer) RemovePropertyReturns(result1 error)
func (*FakeContainer) Run ¶
func (fake *FakeContainer) Run(arg1 garden.ProcessSpec, arg2 garden.ProcessIO) (garden.Process, error)
func (*FakeContainer) RunArgsForCall ¶
func (fake *FakeContainer) RunArgsForCall(i int) (garden.ProcessSpec, garden.ProcessIO)
func (*FakeContainer) RunCallCount ¶
func (fake *FakeContainer) RunCallCount() int
func (*FakeContainer) RunReturns ¶
func (fake *FakeContainer) RunReturns(result1 garden.Process, result2 error)
func (*FakeContainer) SetGraceTime ¶
func (fake *FakeContainer) SetGraceTime(graceTime time.Duration) error
func (*FakeContainer) SetGraceTimeArgsForCall ¶
func (fake *FakeContainer) SetGraceTimeArgsForCall(i int) time.Duration
func (*FakeContainer) SetGraceTimeCallCount ¶
func (fake *FakeContainer) SetGraceTimeCallCount() int
func (*FakeContainer) SetGraceTimeReturns ¶
func (fake *FakeContainer) SetGraceTimeReturns(result1 error)
func (*FakeContainer) SetProperty ¶
func (fake *FakeContainer) SetProperty(name string, value string) error
func (*FakeContainer) SetPropertyArgsForCall ¶
func (fake *FakeContainer) SetPropertyArgsForCall(i int) (string, string)
func (*FakeContainer) SetPropertyCallCount ¶
func (fake *FakeContainer) SetPropertyCallCount() int
func (*FakeContainer) SetPropertyReturns ¶
func (fake *FakeContainer) SetPropertyReturns(result1 error)
func (*FakeContainer) Stop ¶
func (fake *FakeContainer) Stop(kill bool) error
func (*FakeContainer) StopArgsForCall ¶
func (fake *FakeContainer) StopArgsForCall(i int) bool
func (*FakeContainer) StopCallCount ¶
func (fake *FakeContainer) StopCallCount() int
func (*FakeContainer) StopReturns ¶
func (fake *FakeContainer) StopReturns(result1 error)
func (*FakeContainer) StreamIn ¶
func (fake *FakeContainer) StreamIn(spec garden.StreamInSpec) error
func (*FakeContainer) StreamInArgsForCall ¶
func (fake *FakeContainer) StreamInArgsForCall(i int) garden.StreamInSpec
func (*FakeContainer) StreamInCallCount ¶
func (fake *FakeContainer) StreamInCallCount() int
func (*FakeContainer) StreamInReturns ¶
func (fake *FakeContainer) StreamInReturns(result1 error)
func (*FakeContainer) StreamOut ¶
func (fake *FakeContainer) StreamOut(spec garden.StreamOutSpec) (io.ReadCloser, error)
func (*FakeContainer) StreamOutArgsForCall ¶
func (fake *FakeContainer) StreamOutArgsForCall(i int) garden.StreamOutSpec
func (*FakeContainer) StreamOutCallCount ¶
func (fake *FakeContainer) StreamOutCallCount() int
func (*FakeContainer) StreamOutReturns ¶
func (fake *FakeContainer) StreamOutReturns(result1 io.ReadCloser, result2 error)
func (*FakeContainer) VolumeMounts ¶
func (fake *FakeContainer) VolumeMounts() []worker.VolumeMount
func (*FakeContainer) VolumeMountsCallCount ¶
func (fake *FakeContainer) VolumeMountsCallCount() int
func (*FakeContainer) VolumeMountsReturns ¶
func (fake *FakeContainer) VolumeMountsReturns(result1 []worker.VolumeMount)
func (*FakeContainer) Volumes ¶
func (fake *FakeContainer) Volumes() []worker.Volume
func (*FakeContainer) VolumesCallCount ¶
func (fake *FakeContainer) VolumesCallCount() int
func (*FakeContainer) VolumesReturns ¶
func (fake *FakeContainer) VolumesReturns(result1 []worker.Volume)
type FakeGardenConnectionFactory ¶
type FakeGardenConnectionFactory struct { BuildConnectionStub func() gconn.Connection BuildConnectionFromDBStub func() (gconn.Connection, error) // contains filtered or unexported fields }
func (*FakeGardenConnectionFactory) BuildConnection ¶
func (fake *FakeGardenConnectionFactory) BuildConnection() gconn.Connection
func (*FakeGardenConnectionFactory) BuildConnectionCallCount ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int
func (*FakeGardenConnectionFactory) BuildConnectionFromDB ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionFromDB() (gconn.Connection, error)
func (*FakeGardenConnectionFactory) BuildConnectionFromDBCallCount ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionFromDBCallCount() int
func (*FakeGardenConnectionFactory) BuildConnectionFromDBReturns ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionFromDBReturns(result1 gconn.Connection, result2 error)
func (*FakeGardenConnectionFactory) BuildConnectionReturns ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionReturns(result1 gconn.Connection)
type FakeGardenConnectionFactoryDB ¶
type FakeGardenConnectionFactoryDB struct { GetWorkerStub func(string) (db.SavedWorker, bool, error) // contains filtered or unexported fields }
func (*FakeGardenConnectionFactoryDB) GetWorker ¶
func (fake *FakeGardenConnectionFactoryDB) GetWorker(arg1 string) (db.SavedWorker, bool, error)
func (*FakeGardenConnectionFactoryDB) GetWorkerArgsForCall ¶
func (fake *FakeGardenConnectionFactoryDB) GetWorkerArgsForCall(i int) string
func (*FakeGardenConnectionFactoryDB) GetWorkerCallCount ¶
func (fake *FakeGardenConnectionFactoryDB) GetWorkerCallCount() int
func (*FakeGardenConnectionFactoryDB) GetWorkerReturns ¶
func (fake *FakeGardenConnectionFactoryDB) GetWorkerReturns(result1 db.SavedWorker, result2 bool, result3 error)
type FakeGardenWorkerDB ¶
type FakeGardenWorkerDB struct { CreateContainerStub func(db.Container, time.Duration) (db.SavedContainer, error) UpdateExpiresAtOnContainerStub func(handle string, ttl time.Duration) error // contains filtered or unexported fields }
func (*FakeGardenWorkerDB) CreateContainer ¶
func (fake *FakeGardenWorkerDB) CreateContainer(arg1 db.Container, arg2 time.Duration) (db.SavedContainer, error)
func (*FakeGardenWorkerDB) CreateContainerArgsForCall ¶
func (*FakeGardenWorkerDB) CreateContainerCallCount ¶
func (fake *FakeGardenWorkerDB) CreateContainerCallCount() int
func (*FakeGardenWorkerDB) CreateContainerReturns ¶
func (fake *FakeGardenWorkerDB) CreateContainerReturns(result1 db.SavedContainer, result2 error)
func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainer ¶
func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerArgsForCall ¶
func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)
func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerCallCount ¶
func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerCallCount() int
func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerReturns ¶
func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)
type FakeImage ¶
type FakeImage struct { VolumeStub func() worker.Volume MetadataStub func() worker.ImageMetadata ReleaseStub func(*time.Duration) // contains filtered or unexported fields }
func (*FakeImage) Metadata ¶
func (fake *FakeImage) Metadata() worker.ImageMetadata
func (*FakeImage) MetadataCallCount ¶
func (*FakeImage) MetadataReturns ¶
func (fake *FakeImage) MetadataReturns(result1 worker.ImageMetadata)
func (*FakeImage) ReleaseArgsForCall ¶
func (*FakeImage) ReleaseCallCount ¶
func (*FakeImage) VolumeCallCount ¶
func (*FakeImage) VolumeReturns ¶
type FakeImageFetcher ¶
type FakeImageFetcher struct { FetchImageStub func(lager.Logger, atc.TaskImageConfig, <-chan os.Signal, worker.Identifier, worker.Metadata, worker.ImageFetchingDelegate, worker.Client, atc.Tags, atc.ResourceTypes) (worker.Image, error) // contains filtered or unexported fields }
func (*FakeImageFetcher) FetchImage ¶
func (fake *FakeImageFetcher) FetchImage(arg1 lager.Logger, arg2 atc.TaskImageConfig, arg3 <-chan os.Signal, arg4 worker.Identifier, arg5 worker.Metadata, arg6 worker.ImageFetchingDelegate, arg7 worker.Client, arg8 atc.Tags, arg9 atc.ResourceTypes) (worker.Image, error)
func (*FakeImageFetcher) FetchImageArgsForCall ¶
func (fake *FakeImageFetcher) FetchImageArgsForCall(i int) (lager.Logger, atc.TaskImageConfig, <-chan os.Signal, worker.Identifier, worker.Metadata, worker.ImageFetchingDelegate, worker.Client, atc.Tags, atc.ResourceTypes)
func (*FakeImageFetcher) FetchImageCallCount ¶
func (fake *FakeImageFetcher) FetchImageCallCount() int
func (*FakeImageFetcher) FetchImageReturns ¶
func (fake *FakeImageFetcher) FetchImageReturns(result1 worker.Image, result2 error)
type FakeImageFetchingDelegate ¶
type FakeImageFetchingDelegate struct { StderrStub func() io.Writer ImageVersionDeterminedStub func(db.VolumeIdentifier) error // contains filtered or unexported fields }
func (*FakeImageFetchingDelegate) ImageVersionDetermined ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 db.VolumeIdentifier) error
func (*FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) db.VolumeIdentifier
func (*FakeImageFetchingDelegate) ImageVersionDeterminedCallCount ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int
func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturns ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)
func (*FakeImageFetchingDelegate) Stderr ¶
func (fake *FakeImageFetchingDelegate) Stderr() io.Writer
func (*FakeImageFetchingDelegate) StderrCallCount ¶
func (fake *FakeImageFetchingDelegate) StderrCallCount() int
func (*FakeImageFetchingDelegate) StderrReturns ¶
func (fake *FakeImageFetchingDelegate) StderrReturns(result1 io.Writer)
type FakeRetryPolicy ¶
type FakeRetryPolicy struct { DelayForStub func(uint) (time.Duration, bool) // contains filtered or unexported fields }
func (*FakeRetryPolicy) DelayFor ¶
func (fake *FakeRetryPolicy) DelayFor(arg1 uint) (time.Duration, bool)
func (*FakeRetryPolicy) DelayForArgsForCall ¶
func (fake *FakeRetryPolicy) DelayForArgsForCall(i int) uint
func (*FakeRetryPolicy) DelayForCallCount ¶
func (fake *FakeRetryPolicy) DelayForCallCount() int
func (*FakeRetryPolicy) DelayForReturns ¶
func (fake *FakeRetryPolicy) DelayForReturns(result1 time.Duration, result2 bool)
type FakeSaveWorkerDB ¶
type FakeSaveWorkerDB struct { SaveWorkerStub func(db.WorkerInfo, time.Duration) (db.SavedWorker, error) // contains filtered or unexported fields }
func (*FakeSaveWorkerDB) SaveWorker ¶
func (fake *FakeSaveWorkerDB) SaveWorker(arg1 db.WorkerInfo, arg2 time.Duration) (db.SavedWorker, error)
func (*FakeSaveWorkerDB) SaveWorkerArgsForCall ¶
func (fake *FakeSaveWorkerDB) SaveWorkerArgsForCall(i int) (db.WorkerInfo, time.Duration)
func (*FakeSaveWorkerDB) SaveWorkerCallCount ¶
func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int
func (*FakeSaveWorkerDB) SaveWorkerReturns ¶
func (fake *FakeSaveWorkerDB) SaveWorkerReturns(result1 db.SavedWorker, result2 error)
type FakeSleeper ¶
func (*FakeSleeper) Sleep ¶
func (fake *FakeSleeper) Sleep(arg1 time.Duration)
func (*FakeSleeper) SleepArgsForCall ¶
func (fake *FakeSleeper) SleepArgsForCall(i int) time.Duration
func (*FakeSleeper) SleepCallCount ¶
func (fake *FakeSleeper) SleepCallCount() int
type FakeVolume ¶
type FakeVolume struct { HandleStub func() string PathStub func() string SetTTLStub func(time.Duration) error SetPropertyStub func(key string, value string) error ExpirationStub func() (time.Duration, time.Time, error) PropertiesStub func() (baggageclaim.VolumeProperties, error) ReleaseStub func(*time.Duration) // contains filtered or unexported fields }
func (*FakeVolume) Expiration ¶
func (*FakeVolume) ExpirationCallCount ¶
func (fake *FakeVolume) ExpirationCallCount() int
func (*FakeVolume) ExpirationReturns ¶
func (*FakeVolume) Handle ¶
func (fake *FakeVolume) Handle() string
func (*FakeVolume) HandleCallCount ¶
func (fake *FakeVolume) HandleCallCount() int
func (*FakeVolume) HandleReturns ¶
func (fake *FakeVolume) HandleReturns(result1 string)
func (*FakeVolume) Path ¶
func (fake *FakeVolume) Path() string
func (*FakeVolume) PathCallCount ¶
func (fake *FakeVolume) PathCallCount() int
func (*FakeVolume) PathReturns ¶
func (fake *FakeVolume) PathReturns(result1 string)
func (*FakeVolume) Properties ¶
func (fake *FakeVolume) Properties() (baggageclaim.VolumeProperties, error)
func (*FakeVolume) PropertiesCallCount ¶
func (fake *FakeVolume) PropertiesCallCount() int
func (*FakeVolume) PropertiesReturns ¶
func (fake *FakeVolume) PropertiesReturns(result1 baggageclaim.VolumeProperties, result2 error)
func (*FakeVolume) Release ¶
func (fake *FakeVolume) Release(arg1 *time.Duration)
func (*FakeVolume) ReleaseArgsForCall ¶
func (fake *FakeVolume) ReleaseArgsForCall(i int) *time.Duration
func (*FakeVolume) ReleaseCallCount ¶
func (fake *FakeVolume) ReleaseCallCount() int
func (*FakeVolume) SetProperty ¶
func (fake *FakeVolume) SetProperty(key string, value string) error
func (*FakeVolume) SetPropertyArgsForCall ¶
func (fake *FakeVolume) SetPropertyArgsForCall(i int) (string, string)
func (*FakeVolume) SetPropertyCallCount ¶
func (fake *FakeVolume) SetPropertyCallCount() int
func (*FakeVolume) SetPropertyReturns ¶
func (fake *FakeVolume) SetPropertyReturns(result1 error)
func (*FakeVolume) SetTTLArgsForCall ¶
func (fake *FakeVolume) SetTTLArgsForCall(i int) time.Duration
func (*FakeVolume) SetTTLCallCount ¶
func (fake *FakeVolume) SetTTLCallCount() int
func (*FakeVolume) SetTTLReturns ¶
func (fake *FakeVolume) SetTTLReturns(result1 error)
type FakeVolumeFactory ¶
type FakeVolumeFactory struct { BuildStub func(lager.Logger, baggageclaim.Volume) (worker.Volume, error) // contains filtered or unexported fields }
func (*FakeVolumeFactory) Build ¶
func (fake *FakeVolumeFactory) Build(arg1 lager.Logger, arg2 baggageclaim.Volume) (worker.Volume, error)
func (*FakeVolumeFactory) BuildArgsForCall ¶
func (fake *FakeVolumeFactory) BuildArgsForCall(i int) (lager.Logger, baggageclaim.Volume)
func (*FakeVolumeFactory) BuildCallCount ¶
func (fake *FakeVolumeFactory) BuildCallCount() int
func (*FakeVolumeFactory) BuildReturns ¶
func (fake *FakeVolumeFactory) BuildReturns(result1 worker.Volume, result2 error)
type FakeVolumeFactoryDB ¶
type FakeVolumeFactoryDB struct { GetVolumeTTLStub func(volumeHandle string) (time.Duration, error) ReapVolumeStub func(handle string) error SetVolumeTTLStub func(string, time.Duration) error // contains filtered or unexported fields }
func (*FakeVolumeFactoryDB) GetVolumeTTL ¶
func (fake *FakeVolumeFactoryDB) GetVolumeTTL(volumeHandle string) (time.Duration, error)
func (*FakeVolumeFactoryDB) GetVolumeTTLArgsForCall ¶
func (fake *FakeVolumeFactoryDB) GetVolumeTTLArgsForCall(i int) string
func (*FakeVolumeFactoryDB) GetVolumeTTLCallCount ¶
func (fake *FakeVolumeFactoryDB) GetVolumeTTLCallCount() int
func (*FakeVolumeFactoryDB) GetVolumeTTLReturns ¶
func (fake *FakeVolumeFactoryDB) GetVolumeTTLReturns(result1 time.Duration, result2 error)
func (*FakeVolumeFactoryDB) ReapVolume ¶
func (fake *FakeVolumeFactoryDB) ReapVolume(handle string) error
func (*FakeVolumeFactoryDB) ReapVolumeArgsForCall ¶
func (fake *FakeVolumeFactoryDB) ReapVolumeArgsForCall(i int) string
func (*FakeVolumeFactoryDB) ReapVolumeCallCount ¶
func (fake *FakeVolumeFactoryDB) ReapVolumeCallCount() int
func (*FakeVolumeFactoryDB) ReapVolumeReturns ¶
func (fake *FakeVolumeFactoryDB) ReapVolumeReturns(result1 error)
func (*FakeVolumeFactoryDB) SetVolumeTTL ¶
func (fake *FakeVolumeFactoryDB) SetVolumeTTL(arg1 string, arg2 time.Duration) error
func (*FakeVolumeFactoryDB) SetVolumeTTLArgsForCall ¶
func (fake *FakeVolumeFactoryDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)
func (*FakeVolumeFactoryDB) SetVolumeTTLCallCount ¶
func (fake *FakeVolumeFactoryDB) SetVolumeTTLCallCount() int
func (*FakeVolumeFactoryDB) SetVolumeTTLReturns ¶
func (fake *FakeVolumeFactoryDB) SetVolumeTTLReturns(result1 error)
type FakeWorker ¶
type FakeWorker struct { CreateContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes) (worker.Container, error) FindContainerForIdentifierStub func(lager.Logger, worker.Identifier) (worker.Container, bool, error) LookupContainerStub func(lager.Logger, string) (worker.Container, bool, error) SatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) (worker.Worker, error) AllSatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) ([]worker.Worker, error) GetWorkerStub func(workerName string) (worker.Worker, error) ActiveContainersStub func() int DescriptionStub func() string NameStub func() string VolumeManagerStub func() (baggageclaim.Client, bool) // contains filtered or unexported fields }
func (*FakeWorker) ActiveContainers ¶
func (fake *FakeWorker) ActiveContainers() int
func (*FakeWorker) ActiveContainersCallCount ¶
func (fake *FakeWorker) ActiveContainersCallCount() int
func (*FakeWorker) ActiveContainersReturns ¶
func (fake *FakeWorker) ActiveContainersReturns(result1 int)
func (*FakeWorker) AllSatisfying ¶
func (fake *FakeWorker) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) ([]worker.Worker, error)
func (*FakeWorker) AllSatisfyingArgsForCall ¶
func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
func (*FakeWorker) AllSatisfyingCallCount ¶
func (fake *FakeWorker) AllSatisfyingCallCount() int
func (*FakeWorker) AllSatisfyingReturns ¶
func (fake *FakeWorker) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
func (*FakeWorker) CreateContainer ¶
func (fake *FakeWorker) CreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 worker.Identifier, arg5 worker.Metadata, arg6 worker.ContainerSpec, arg7 atc.ResourceTypes) (worker.Container, error)
func (*FakeWorker) CreateContainerArgsForCall ¶
func (fake *FakeWorker) CreateContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes)
func (*FakeWorker) CreateContainerCallCount ¶
func (fake *FakeWorker) CreateContainerCallCount() int
func (*FakeWorker) CreateContainerReturns ¶
func (fake *FakeWorker) CreateContainerReturns(result1 worker.Container, result2 error)
func (*FakeWorker) Description ¶
func (fake *FakeWorker) Description() string
func (*FakeWorker) DescriptionCallCount ¶
func (fake *FakeWorker) DescriptionCallCount() int
func (*FakeWorker) DescriptionReturns ¶
func (fake *FakeWorker) DescriptionReturns(result1 string)
func (*FakeWorker) FindContainerForIdentifier ¶
func (fake *FakeWorker) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)
func (*FakeWorker) FindContainerForIdentifierArgsForCall ¶
func (fake *FakeWorker) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)
func (*FakeWorker) FindContainerForIdentifierCallCount ¶
func (fake *FakeWorker) FindContainerForIdentifierCallCount() int
func (*FakeWorker) FindContainerForIdentifierReturns ¶
func (fake *FakeWorker) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeWorker) GetWorker ¶
func (fake *FakeWorker) GetWorker(workerName string) (worker.Worker, error)
func (*FakeWorker) GetWorkerArgsForCall ¶
func (fake *FakeWorker) GetWorkerArgsForCall(i int) string
func (*FakeWorker) GetWorkerCallCount ¶
func (fake *FakeWorker) GetWorkerCallCount() int
func (*FakeWorker) GetWorkerReturns ¶
func (fake *FakeWorker) GetWorkerReturns(result1 worker.Worker, result2 error)
func (*FakeWorker) LookupContainer ¶
func (*FakeWorker) LookupContainerArgsForCall ¶
func (fake *FakeWorker) LookupContainerArgsForCall(i int) (lager.Logger, string)
func (*FakeWorker) LookupContainerCallCount ¶
func (fake *FakeWorker) LookupContainerCallCount() int
func (*FakeWorker) LookupContainerReturns ¶
func (fake *FakeWorker) LookupContainerReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeWorker) Name ¶
func (fake *FakeWorker) Name() string
func (*FakeWorker) NameCallCount ¶
func (fake *FakeWorker) NameCallCount() int
func (*FakeWorker) NameReturns ¶
func (fake *FakeWorker) NameReturns(result1 string)
func (*FakeWorker) Satisfying ¶
func (fake *FakeWorker) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)
func (*FakeWorker) SatisfyingArgsForCall ¶
func (fake *FakeWorker) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)
func (*FakeWorker) SatisfyingCallCount ¶
func (fake *FakeWorker) SatisfyingCallCount() int
func (*FakeWorker) SatisfyingReturns ¶
func (fake *FakeWorker) SatisfyingReturns(result1 worker.Worker, result2 error)
func (*FakeWorker) VolumeManager ¶
func (fake *FakeWorker) VolumeManager() (baggageclaim.Client, bool)
func (*FakeWorker) VolumeManagerCallCount ¶
func (fake *FakeWorker) VolumeManagerCallCount() int
func (*FakeWorker) VolumeManagerReturns ¶
func (fake *FakeWorker) VolumeManagerReturns(result1 baggageclaim.Client, result2 bool)
type FakeWorkerDB ¶
type FakeWorkerDB struct { WorkersStub func() ([]db.SavedWorker, error) GetWorkerStub func(string) (db.SavedWorker, bool, error) CreateContainerStub func(db.Container, time.Duration) (db.SavedContainer, error) GetContainerStub func(string) (db.SavedContainer, bool, error) FindContainerByIdentifierStub func(db.ContainerIdentifier) (db.SavedContainer, bool, error) UpdateExpiresAtOnContainerStub func(handle string, ttl time.Duration) error ReapContainerStub func(handle string) error GetVolumeTTLStub func(volumeHandle string) (time.Duration, error) ReapVolumeStub func(handle string) error SetVolumeTTLStub func(string, time.Duration) error // contains filtered or unexported fields }
func (*FakeWorkerDB) CreateContainer ¶
func (fake *FakeWorkerDB) CreateContainer(arg1 db.Container, arg2 time.Duration) (db.SavedContainer, error)
func (*FakeWorkerDB) CreateContainerArgsForCall ¶
func (*FakeWorkerDB) CreateContainerCallCount ¶
func (fake *FakeWorkerDB) CreateContainerCallCount() int
func (*FakeWorkerDB) CreateContainerReturns ¶
func (fake *FakeWorkerDB) CreateContainerReturns(result1 db.SavedContainer, result2 error)
func (*FakeWorkerDB) FindContainerByIdentifier ¶
func (fake *FakeWorkerDB) FindContainerByIdentifier(arg1 db.ContainerIdentifier) (db.SavedContainer, bool, error)
func (*FakeWorkerDB) FindContainerByIdentifierArgsForCall ¶
func (fake *FakeWorkerDB) FindContainerByIdentifierArgsForCall(i int) db.ContainerIdentifier
func (*FakeWorkerDB) FindContainerByIdentifierCallCount ¶
func (fake *FakeWorkerDB) FindContainerByIdentifierCallCount() int
func (*FakeWorkerDB) FindContainerByIdentifierReturns ¶
func (fake *FakeWorkerDB) FindContainerByIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)
func (*FakeWorkerDB) GetContainer ¶
func (fake *FakeWorkerDB) GetContainer(arg1 string) (db.SavedContainer, bool, error)
func (*FakeWorkerDB) GetContainerArgsForCall ¶
func (fake *FakeWorkerDB) GetContainerArgsForCall(i int) string
func (*FakeWorkerDB) GetContainerCallCount ¶
func (fake *FakeWorkerDB) GetContainerCallCount() int
func (*FakeWorkerDB) GetContainerReturns ¶
func (fake *FakeWorkerDB) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)
func (*FakeWorkerDB) GetVolumeTTL ¶
func (fake *FakeWorkerDB) GetVolumeTTL(volumeHandle string) (time.Duration, error)
func (*FakeWorkerDB) GetVolumeTTLArgsForCall ¶
func (fake *FakeWorkerDB) GetVolumeTTLArgsForCall(i int) string
func (*FakeWorkerDB) GetVolumeTTLCallCount ¶
func (fake *FakeWorkerDB) GetVolumeTTLCallCount() int
func (*FakeWorkerDB) GetVolumeTTLReturns ¶
func (fake *FakeWorkerDB) GetVolumeTTLReturns(result1 time.Duration, result2 error)
func (*FakeWorkerDB) GetWorker ¶
func (fake *FakeWorkerDB) GetWorker(arg1 string) (db.SavedWorker, bool, error)
func (*FakeWorkerDB) GetWorkerArgsForCall ¶
func (fake *FakeWorkerDB) GetWorkerArgsForCall(i int) string
func (*FakeWorkerDB) GetWorkerCallCount ¶
func (fake *FakeWorkerDB) GetWorkerCallCount() int
func (*FakeWorkerDB) GetWorkerReturns ¶
func (fake *FakeWorkerDB) GetWorkerReturns(result1 db.SavedWorker, result2 bool, result3 error)
func (*FakeWorkerDB) ReapContainer ¶
func (fake *FakeWorkerDB) ReapContainer(handle string) error
func (*FakeWorkerDB) ReapContainerArgsForCall ¶
func (fake *FakeWorkerDB) ReapContainerArgsForCall(i int) string
func (*FakeWorkerDB) ReapContainerCallCount ¶
func (fake *FakeWorkerDB) ReapContainerCallCount() int
func (*FakeWorkerDB) ReapContainerReturns ¶
func (fake *FakeWorkerDB) ReapContainerReturns(result1 error)
func (*FakeWorkerDB) ReapVolume ¶
func (fake *FakeWorkerDB) ReapVolume(handle string) error
func (*FakeWorkerDB) ReapVolumeArgsForCall ¶
func (fake *FakeWorkerDB) ReapVolumeArgsForCall(i int) string
func (*FakeWorkerDB) ReapVolumeCallCount ¶
func (fake *FakeWorkerDB) ReapVolumeCallCount() int
func (*FakeWorkerDB) ReapVolumeReturns ¶
func (fake *FakeWorkerDB) ReapVolumeReturns(result1 error)
func (*FakeWorkerDB) SetVolumeTTL ¶
func (fake *FakeWorkerDB) SetVolumeTTL(arg1 string, arg2 time.Duration) error
func (*FakeWorkerDB) SetVolumeTTLArgsForCall ¶
func (fake *FakeWorkerDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)
func (*FakeWorkerDB) SetVolumeTTLCallCount ¶
func (fake *FakeWorkerDB) SetVolumeTTLCallCount() int
func (*FakeWorkerDB) SetVolumeTTLReturns ¶
func (fake *FakeWorkerDB) SetVolumeTTLReturns(result1 error)
func (*FakeWorkerDB) UpdateExpiresAtOnContainer ¶
func (fake *FakeWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
func (*FakeWorkerDB) UpdateExpiresAtOnContainerArgsForCall ¶
func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)
func (*FakeWorkerDB) UpdateExpiresAtOnContainerCallCount ¶
func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerCallCount() int
func (*FakeWorkerDB) UpdateExpiresAtOnContainerReturns ¶
func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)
func (*FakeWorkerDB) Workers ¶
func (fake *FakeWorkerDB) Workers() ([]db.SavedWorker, error)
func (*FakeWorkerDB) WorkersCallCount ¶
func (fake *FakeWorkerDB) WorkersCallCount() int
func (*FakeWorkerDB) WorkersReturns ¶
func (fake *FakeWorkerDB) WorkersReturns(result1 []db.SavedWorker, result2 error)
type FakeWorkerProvider ¶
type FakeWorkerProvider struct { WorkersStub func() ([]worker.Worker, error) GetWorkerStub func(string) (worker.Worker, bool, error) FindContainerForIdentifierStub func(worker.Identifier) (db.SavedContainer, bool, error) GetContainerStub func(string) (db.SavedContainer, bool, error) ReapContainerStub func(string) error // contains filtered or unexported fields }
func (*FakeWorkerProvider) FindContainerForIdentifier ¶
func (fake *FakeWorkerProvider) FindContainerForIdentifier(arg1 worker.Identifier) (db.SavedContainer, bool, error)
func (*FakeWorkerProvider) FindContainerForIdentifierArgsForCall ¶
func (fake *FakeWorkerProvider) FindContainerForIdentifierArgsForCall(i int) worker.Identifier
func (*FakeWorkerProvider) FindContainerForIdentifierCallCount ¶
func (fake *FakeWorkerProvider) FindContainerForIdentifierCallCount() int
func (*FakeWorkerProvider) FindContainerForIdentifierReturns ¶
func (fake *FakeWorkerProvider) FindContainerForIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)
func (*FakeWorkerProvider) GetContainer ¶
func (fake *FakeWorkerProvider) GetContainer(arg1 string) (db.SavedContainer, bool, error)
func (*FakeWorkerProvider) GetContainerArgsForCall ¶
func (fake *FakeWorkerProvider) GetContainerArgsForCall(i int) string
func (*FakeWorkerProvider) GetContainerCallCount ¶
func (fake *FakeWorkerProvider) GetContainerCallCount() int
func (*FakeWorkerProvider) GetContainerReturns ¶
func (fake *FakeWorkerProvider) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)
func (*FakeWorkerProvider) GetWorkerArgsForCall ¶
func (fake *FakeWorkerProvider) GetWorkerArgsForCall(i int) string
func (*FakeWorkerProvider) GetWorkerCallCount ¶
func (fake *FakeWorkerProvider) GetWorkerCallCount() int
func (*FakeWorkerProvider) GetWorkerReturns ¶
func (fake *FakeWorkerProvider) GetWorkerReturns(result1 worker.Worker, result2 bool, result3 error)
func (*FakeWorkerProvider) ReapContainer ¶
func (fake *FakeWorkerProvider) ReapContainer(arg1 string) error
func (*FakeWorkerProvider) ReapContainerArgsForCall ¶
func (fake *FakeWorkerProvider) ReapContainerArgsForCall(i int) string
func (*FakeWorkerProvider) ReapContainerCallCount ¶
func (fake *FakeWorkerProvider) ReapContainerCallCount() int
func (*FakeWorkerProvider) ReapContainerReturns ¶
func (fake *FakeWorkerProvider) ReapContainerReturns(result1 error)
func (*FakeWorkerProvider) Workers ¶
func (fake *FakeWorkerProvider) Workers() ([]worker.Worker, error)
func (*FakeWorkerProvider) WorkersCallCount ¶
func (fake *FakeWorkerProvider) WorkersCallCount() int
func (*FakeWorkerProvider) WorkersReturns ¶
func (fake *FakeWorkerProvider) WorkersReturns(result1 []worker.Worker, result2 error)
Source Files ¶
- fake_client.go
- fake_container.go
- fake_garden_connection_factory.go
- fake_garden_connection_factory_db.go
- fake_garden_worker_db.go
- fake_image.go
- fake_image_fetcher.go
- fake_image_fetching_delegate.go
- fake_retry_policy.go
- fake_save_worker_db.go
- fake_sleeper.go
- fake_volume.go
- fake_volume_factory.go
- fake_volume_factory_db.go
- fake_worker.go
- fake_worker_db.go
- fake_worker_provider.go
Click to show internal directories.
Click to hide internal directories.