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 ¶
This file was generated by counterfeiter
Index ¶
- type FakeArtifactDestination
- func (fake *FakeArtifactDestination) Invocations() map[string][][]interface{}
- func (fake *FakeArtifactDestination) StreamIn(arg1 string, arg2 io.Reader) error
- func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (string, io.Reader)
- func (fake *FakeArtifactDestination) StreamInCallCount() int
- func (fake *FakeArtifactDestination) StreamInReturns(result1 error)
- func (fake *FakeArtifactDestination) StreamInReturnsOnCall(i int, result1 error)
- type FakeArtifactSource
- func (fake *FakeArtifactSource) Invocations() map[string][][]interface{}
- func (fake *FakeArtifactSource) StreamFile(path string) (io.ReadCloser, error)
- func (fake *FakeArtifactSource) StreamFileArgsForCall(i int) string
- func (fake *FakeArtifactSource) StreamFileCallCount() int
- func (fake *FakeArtifactSource) StreamFileReturns(result1 io.ReadCloser, result2 error)
- func (fake *FakeArtifactSource) StreamFileReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
- func (fake *FakeArtifactSource) StreamTo(arg1 worker.ArtifactDestination) error
- func (fake *FakeArtifactSource) StreamToArgsForCall(i int) worker.ArtifactDestination
- func (fake *FakeArtifactSource) StreamToCallCount() int
- func (fake *FakeArtifactSource) StreamToReturns(result1 error)
- func (fake *FakeArtifactSource) StreamToReturnsOnCall(i int, result1 error)
- func (fake *FakeArtifactSource) VolumeOn(arg1 worker.Worker) (worker.Volume, bool, error)
- func (fake *FakeArtifactSource) VolumeOnArgsForCall(i int) worker.Worker
- func (fake *FakeArtifactSource) VolumeOnCallCount() int
- func (fake *FakeArtifactSource) VolumeOnReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeArtifactSource) VolumeOnReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- type FakeClient
- func (fake *FakeClient) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) ([]worker.Worker, error)
- func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
- func (fake *FakeClient) AllSatisfyingCallCount() int
- func (fake *FakeClient) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeClient) AllSatisfyingReturnsOnCall(i int, result1 []worker.Worker, result2 error)
- func (fake *FakeClient) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeClient) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeClient) CreateResourceGetContainerCallCount() int
- func (fake *FakeClient) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeClient) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeClient) CreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, ...) (worker.Volume, error)
- func (fake *FakeClient) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
- func (fake *FakeClient) CreateVolumeForResourceCacheCallCount() int
- func (fake *FakeClient) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
- func (fake *FakeClient) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeClient) FindContainerByHandle(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error)
- func (fake *FakeClient) FindContainerByHandleArgsForCall(i int) (lager.Logger, int, string)
- func (fake *FakeClient) FindContainerByHandleCallCount() int
- func (fake *FakeClient) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeClient) FindContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeClient) FindInitializedVolumeForResourceCache(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error)
- func (fake *FakeClient) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
- func (fake *FakeClient) FindInitializedVolumeForResourceCacheCallCount() int
- func (fake *FakeClient) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeClient) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeClient) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, ...) (worker.Container, error)
- func (fake *FakeClient) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, ...)
- func (fake *FakeClient) FindOrCreateBuildContainerCallCount() int
- func (fake *FakeClient) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeClient) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeClient) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeClient) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeClient) FindOrCreateResourceCheckContainerCallCount() int
- func (fake *FakeClient) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeClient) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeClient) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)
- func (fake *FakeClient) FindResourceTypeByPathArgsForCall(i int) string
- func (fake *FakeClient) FindResourceTypeByPathCallCount() int
- func (fake *FakeClient) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)
- func (fake *FakeClient) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)
- 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) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error)
- func (fake *FakeClient) Invocations() map[string][][]interface{}
- func (fake *FakeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)
- func (fake *FakeClient) LookupVolumeArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeClient) LookupVolumeCallCount() int
- func (fake *FakeClient) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeClient) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeClient) RunningWorkers() ([]worker.Worker, error)
- func (fake *FakeClient) RunningWorkersCallCount() int
- func (fake *FakeClient) RunningWorkersReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeClient) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
- func (fake *FakeClient) Satisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) (worker.Worker, error)
- func (fake *FakeClient) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
- func (fake *FakeClient) SatisfyingCallCount() int
- func (fake *FakeClient) SatisfyingReturns(result1 worker.Worker, result2 error)
- func (fake *FakeClient) SatisfyingReturnsOnCall(i int, 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) AttachReturnsOnCall(i int, result1 garden.Process, result2 error)
- func (fake *FakeContainer) BulkNetOut(netOutRules []garden.NetOutRule) error
- func (fake *FakeContainer) BulkNetOutArgsForCall(i int) []garden.NetOutRule
- func (fake *FakeContainer) BulkNetOutCallCount() int
- func (fake *FakeContainer) BulkNetOutReturns(result1 error)
- func (fake *FakeContainer) BulkNetOutReturnsOnCall(i int, result1 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) CurrentBandwidthLimitsReturnsOnCall(i int, 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) CurrentCPULimitsReturnsOnCall(i int, 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) CurrentDiskLimitsReturnsOnCall(i int, 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) CurrentMemoryLimitsReturnsOnCall(i int, result1 garden.MemoryLimits, result2 error)
- func (fake *FakeContainer) Destroy() error
- func (fake *FakeContainer) DestroyCallCount() int
- func (fake *FakeContainer) DestroyReturns(result1 error)
- func (fake *FakeContainer) DestroyReturnsOnCall(i int, result1 error)
- func (fake *FakeContainer) Handle() string
- func (fake *FakeContainer) HandleCallCount() int
- func (fake *FakeContainer) HandleReturns(result1 string)
- func (fake *FakeContainer) HandleReturnsOnCall(i int, 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) InfoReturnsOnCall(i int, result1 garden.ContainerInfo, result2 error)
- func (fake *FakeContainer) Invocations() map[string][][]interface{}
- func (fake *FakeContainer) MarkAsHijacked() error
- func (fake *FakeContainer) MarkAsHijackedCallCount() int
- func (fake *FakeContainer) MarkAsHijackedReturns(result1 error)
- func (fake *FakeContainer) MarkAsHijackedReturnsOnCall(i int, 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) MetricsReturnsOnCall(i int, 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) NetInReturnsOnCall(i int, 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) NetOutReturnsOnCall(i int, 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) PropertiesReturnsOnCall(i int, 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) PropertyReturnsOnCall(i int, result1 string, result2 error)
- 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) RemovePropertyReturnsOnCall(i int, 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) RunReturnsOnCall(i int, 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) SetGraceTimeReturnsOnCall(i int, 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) SetPropertyReturnsOnCall(i int, 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) StopReturnsOnCall(i int, 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) StreamInReturnsOnCall(i int, 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) StreamOutReturnsOnCall(i int, 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) VolumeMountsReturnsOnCall(i int, result1 []worker.VolumeMount)
- func (fake *FakeContainer) WorkerName() string
- func (fake *FakeContainer) WorkerNameCallCount() int
- func (fake *FakeContainer) WorkerNameReturns(result1 string)
- func (fake *FakeContainer) WorkerNameReturnsOnCall(i int, result1 string)
- type FakeContainerProvider
- func (fake *FakeContainerProvider) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeContainerProvider) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeContainerProvider) CreateResourceGetContainerCallCount() int
- func (fake *FakeContainerProvider) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) FindCreatedContainerByHandle(logger lager.Logger, handle string, teamID int) (worker.Container, bool, error)
- func (fake *FakeContainerProvider) FindCreatedContainerByHandleArgsForCall(i int) (lager.Logger, string, int)
- func (fake *FakeContainerProvider) FindCreatedContainerByHandleCallCount() int
- func (fake *FakeContainerProvider) FindCreatedContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeContainerProvider) FindCreatedContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeContainerProvider) FindOrCreateBuildContainer(logger lager.Logger, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeContainerProvider) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, ...)
- func (fake *FakeContainerProvider) FindOrCreateBuildContainerCallCount() int
- func (fake *FakeContainerProvider) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerCallCount() int
- func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeContainerProvider) Invocations() map[string][][]interface{}
- type FakeContainerProviderFactory
- func (fake *FakeContainerProviderFactory) ContainerProviderFor(arg1 worker.Worker) worker.ContainerProvider
- func (fake *FakeContainerProviderFactory) ContainerProviderForArgsForCall(i int) worker.Worker
- func (fake *FakeContainerProviderFactory) ContainerProviderForCallCount() int
- func (fake *FakeContainerProviderFactory) ContainerProviderForReturns(result1 worker.ContainerProvider)
- func (fake *FakeContainerProviderFactory) ContainerProviderForReturnsOnCall(i int, result1 worker.ContainerProvider)
- func (fake *FakeContainerProviderFactory) Invocations() map[string][][]interface{}
- type FakeGardenConnectionFactory
- func (fake *FakeGardenConnectionFactory) BuildConnection() gconn.Connection
- func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int
- func (fake *FakeGardenConnectionFactory) BuildConnectionReturns(result1 gconn.Connection)
- func (fake *FakeGardenConnectionFactory) BuildConnectionReturnsOnCall(i int, result1 gconn.Connection)
- func (fake *FakeGardenConnectionFactory) Invocations() map[string][][]interface{}
- type FakeImage
- func (fake *FakeImage) FetchForContainer(logger lager.Logger, container dbng.CreatingContainer) (worker.FetchedImage, error)
- func (fake *FakeImage) FetchForContainerArgsForCall(i int) (lager.Logger, dbng.CreatingContainer)
- func (fake *FakeImage) FetchForContainerCallCount() int
- func (fake *FakeImage) FetchForContainerReturns(result1 worker.FetchedImage, result2 error)
- func (fake *FakeImage) FetchForContainerReturnsOnCall(i int, result1 worker.FetchedImage, result2 error)
- func (fake *FakeImage) Invocations() map[string][][]interface{}
- type FakeImageFactory
- func (fake *FakeImageFactory) GetImage(logger lager.Logger, workerClient worker.Worker, ...) (worker.Image, error)
- func (fake *FakeImageFactory) GetImageArgsForCall(i int) (lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int, ...)
- func (fake *FakeImageFactory) GetImageCallCount() int
- func (fake *FakeImageFactory) GetImageReturns(result1 worker.Image, result2 error)
- func (fake *FakeImageFactory) GetImageReturnsOnCall(i int, result1 worker.Image, result2 error)
- func (fake *FakeImageFactory) Invocations() map[string][][]interface{}
- type FakeImageFetchingDelegate
- func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 worker.ResourceCacheIdentifier) error
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) worker.ResourceCacheIdentifier
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)
- func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall(i int, result1 error)
- func (fake *FakeImageFetchingDelegate) Invocations() map[string][][]interface{}
- func (fake *FakeImageFetchingDelegate) Stderr() io.Writer
- func (fake *FakeImageFetchingDelegate) StderrCallCount() int
- func (fake *FakeImageFetchingDelegate) StderrReturns(result1 io.Writer)
- func (fake *FakeImageFetchingDelegate) StderrReturnsOnCall(i int, result1 io.Writer)
- type FakeInputSource
- func (fake *FakeInputSource) DestinationPath() string
- func (fake *FakeInputSource) DestinationPathCallCount() int
- func (fake *FakeInputSource) DestinationPathReturns(result1 string)
- func (fake *FakeInputSource) DestinationPathReturnsOnCall(i int, result1 string)
- func (fake *FakeInputSource) Invocations() map[string][][]interface{}
- func (fake *FakeInputSource) Name() worker.ArtifactName
- func (fake *FakeInputSource) NameCallCount() int
- func (fake *FakeInputSource) NameReturns(result1 worker.ArtifactName)
- func (fake *FakeInputSource) NameReturnsOnCall(i int, result1 worker.ArtifactName)
- func (fake *FakeInputSource) Source() worker.ArtifactSource
- func (fake *FakeInputSource) SourceCallCount() int
- func (fake *FakeInputSource) SourceReturns(result1 worker.ArtifactSource)
- func (fake *FakeInputSource) SourceReturnsOnCall(i int, result1 worker.ArtifactSource)
- type FakeLockDB
- func (fake *FakeLockDB) AcquireContainerCreatingLock(arg1 lager.Logger, arg2 int) (lock.Lock, bool, error)
- func (fake *FakeLockDB) AcquireContainerCreatingLockArgsForCall(i int) (lager.Logger, int)
- func (fake *FakeLockDB) AcquireContainerCreatingLockCallCount() int
- func (fake *FakeLockDB) AcquireContainerCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) AcquireContainerCreatingLockReturnsOnCall(i int, result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) AcquireVolumeCreatingLock(arg1 lager.Logger, arg2 int) (lock.Lock, bool, error)
- func (fake *FakeLockDB) AcquireVolumeCreatingLockArgsForCall(i int) (lager.Logger, int)
- func (fake *FakeLockDB) AcquireVolumeCreatingLockCallCount() int
- func (fake *FakeLockDB) AcquireVolumeCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) AcquireVolumeCreatingLockReturnsOnCall(i int, result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) Invocations() map[string][][]interface{}
- type FakeSaveWorkerDB
- func (fake *FakeSaveWorkerDB) Invocations() map[string][][]interface{}
- func (fake *FakeSaveWorkerDB) SaveWorker(arg1 atc.Worker, arg2 time.Duration) (dbng.Worker, error)
- func (fake *FakeSaveWorkerDB) SaveWorkerArgsForCall(i int) (atc.Worker, time.Duration)
- func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int
- func (fake *FakeSaveWorkerDB) SaveWorkerReturns(result1 dbng.Worker, result2 error)
- func (fake *FakeSaveWorkerDB) SaveWorkerReturnsOnCall(i int, result1 dbng.Worker, result2 error)
- type FakeSleeper
- type FakeVolume
- func (fake *FakeVolume) COWStrategy() baggageclaim.COWStrategy
- func (fake *FakeVolume) COWStrategyCallCount() int
- func (fake *FakeVolume) COWStrategyReturns(result1 baggageclaim.COWStrategy)
- func (fake *FakeVolume) COWStrategyReturnsOnCall(i int, result1 baggageclaim.COWStrategy)
- func (fake *FakeVolume) CreateChildForContainer(arg1 dbng.CreatingContainer, arg2 string) (dbng.CreatingVolume, error)
- func (fake *FakeVolume) CreateChildForContainerArgsForCall(i int) (dbng.CreatingContainer, string)
- func (fake *FakeVolume) CreateChildForContainerCallCount() int
- func (fake *FakeVolume) CreateChildForContainerReturns(result1 dbng.CreatingVolume, result2 error)
- func (fake *FakeVolume) CreateChildForContainerReturnsOnCall(i int, result1 dbng.CreatingVolume, result2 error)
- func (fake *FakeVolume) Destroy() error
- func (fake *FakeVolume) DestroyCallCount() int
- func (fake *FakeVolume) DestroyReturns(result1 error)
- func (fake *FakeVolume) DestroyReturnsOnCall(i int, result1 error)
- func (fake *FakeVolume) Handle() string
- func (fake *FakeVolume) HandleCallCount() int
- func (fake *FakeVolume) HandleReturns(result1 string)
- func (fake *FakeVolume) HandleReturnsOnCall(i int, result1 string)
- func (fake *FakeVolume) Initialize() error
- func (fake *FakeVolume) InitializeCallCount() int
- func (fake *FakeVolume) InitializeReturns(result1 error)
- func (fake *FakeVolume) InitializeReturnsOnCall(i int, result1 error)
- func (fake *FakeVolume) Invocations() map[string][][]interface{}
- func (fake *FakeVolume) IsInitialized() (bool, error)
- func (fake *FakeVolume) IsInitializedCallCount() int
- func (fake *FakeVolume) IsInitializedReturns(result1 bool, result2 error)
- func (fake *FakeVolume) IsInitializedReturnsOnCall(i int, result1 bool, result2 error)
- func (fake *FakeVolume) Path() string
- func (fake *FakeVolume) PathCallCount() int
- func (fake *FakeVolume) PathReturns(result1 string)
- func (fake *FakeVolume) PathReturnsOnCall(i int, 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) PropertiesReturnsOnCall(i int, result1 baggageclaim.VolumeProperties, result2 error)
- 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) SetPropertyReturnsOnCall(i int, result1 error)
- func (fake *FakeVolume) StreamIn(path string, tarStream io.Reader) error
- func (fake *FakeVolume) StreamInArgsForCall(i int) (string, io.Reader)
- func (fake *FakeVolume) StreamInCallCount() int
- func (fake *FakeVolume) StreamInReturns(result1 error)
- func (fake *FakeVolume) StreamInReturnsOnCall(i int, result1 error)
- func (fake *FakeVolume) StreamOut(path string) (io.ReadCloser, error)
- func (fake *FakeVolume) StreamOutArgsForCall(i int) string
- func (fake *FakeVolume) StreamOutCallCount() int
- func (fake *FakeVolume) StreamOutReturns(result1 io.ReadCloser, result2 error)
- func (fake *FakeVolume) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
- type FakeVolumeClient
- func (fake *FakeVolumeClient) CreateVolumeForResourceCache(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 *dbng.UsedResourceCache) (worker.Volume, error)
- func (fake *FakeVolumeClient) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
- func (fake *FakeVolumeClient) CreateVolumeForResourceCacheCallCount() int
- func (fake *FakeVolumeClient) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCache(arg1 lager.Logger, arg2 *dbng.UsedResourceCache) (worker.Volume, bool, error)
- func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
- func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheCallCount() int
- func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 dbng.CreatingContainer, ...) (worker.Volume, error)
- func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, worker.Volume, int, ...)
- func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount() int
- func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturns(result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceType(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 string) (worker.Volume, error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, string)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount() int
- func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturns(result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 dbng.CreatingContainer, ...) (worker.Volume, error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, int, string)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCallCount() int
- func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturns(result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeVolumeClient) Invocations() map[string][][]interface{}
- func (fake *FakeVolumeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)
- func (fake *FakeVolumeClient) LookupVolumeArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeVolumeClient) LookupVolumeCallCount() int
- func (fake *FakeVolumeClient) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeVolumeClient) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- type FakeWorker
- func (fake *FakeWorker) ActiveContainers() int
- func (fake *FakeWorker) ActiveContainersCallCount() int
- func (fake *FakeWorker) ActiveContainersReturns(result1 int)
- func (fake *FakeWorker) ActiveContainersReturnsOnCall(i int, result1 int)
- func (fake *FakeWorker) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) ([]worker.Worker, error)
- func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
- func (fake *FakeWorker) AllSatisfyingCallCount() int
- func (fake *FakeWorker) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeWorker) AllSatisfyingReturnsOnCall(i int, result1 []worker.Worker, result2 error)
- func (fake *FakeWorker) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeWorker) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeWorker) CreateResourceGetContainerCallCount() int
- func (fake *FakeWorker) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeWorker) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeWorker) CreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, ...) (worker.Volume, error)
- func (fake *FakeWorker) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
- func (fake *FakeWorker) CreateVolumeForResourceCacheCallCount() int
- func (fake *FakeWorker) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
- func (fake *FakeWorker) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeWorker) Description() string
- func (fake *FakeWorker) DescriptionCallCount() int
- func (fake *FakeWorker) DescriptionReturns(result1 string)
- func (fake *FakeWorker) DescriptionReturnsOnCall(i int, result1 string)
- func (fake *FakeWorker) FindContainerByHandle(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error)
- func (fake *FakeWorker) FindContainerByHandleArgsForCall(i int) (lager.Logger, int, string)
- func (fake *FakeWorker) FindContainerByHandleCallCount() int
- func (fake *FakeWorker) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeWorker) FindContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)
- func (fake *FakeWorker) FindInitializedVolumeForResourceCache(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error)
- func (fake *FakeWorker) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
- func (fake *FakeWorker) FindInitializedVolumeForResourceCacheCallCount() int
- func (fake *FakeWorker) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeWorker) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeWorker) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, ...) (worker.Container, error)
- func (fake *FakeWorker) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, ...)
- func (fake *FakeWorker) FindOrCreateBuildContainerCallCount() int
- func (fake *FakeWorker) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeWorker) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeWorker) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, ...) (worker.Container, error)
- func (fake *FakeWorker) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, ...)
- func (fake *FakeWorker) FindOrCreateResourceCheckContainerCallCount() int
- func (fake *FakeWorker) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
- func (fake *FakeWorker) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
- func (fake *FakeWorker) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)
- func (fake *FakeWorker) FindResourceTypeByPathArgsForCall(i int) string
- func (fake *FakeWorker) FindResourceTypeByPathCallCount() int
- func (fake *FakeWorker) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)
- func (fake *FakeWorker) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)
- 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) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error)
- func (fake *FakeWorker) Invocations() map[string][][]interface{}
- func (fake *FakeWorker) IsOwnedByTeam() bool
- func (fake *FakeWorker) IsOwnedByTeamCallCount() int
- func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool)
- func (fake *FakeWorker) IsOwnedByTeamReturnsOnCall(i int, result1 bool)
- func (fake *FakeWorker) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)
- func (fake *FakeWorker) LookupVolumeArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeWorker) LookupVolumeCallCount() int
- func (fake *FakeWorker) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeWorker) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeWorker) Name() string
- func (fake *FakeWorker) NameCallCount() int
- func (fake *FakeWorker) NameReturns(result1 string)
- func (fake *FakeWorker) NameReturnsOnCall(i int, result1 string)
- func (fake *FakeWorker) ResourceTypes() []atc.WorkerResourceType
- func (fake *FakeWorker) ResourceTypesCallCount() int
- func (fake *FakeWorker) ResourceTypesReturns(result1 []atc.WorkerResourceType)
- func (fake *FakeWorker) ResourceTypesReturnsOnCall(i int, result1 []atc.WorkerResourceType)
- func (fake *FakeWorker) RunningWorkers() ([]worker.Worker, error)
- func (fake *FakeWorker) RunningWorkersCallCount() int
- func (fake *FakeWorker) RunningWorkersReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeWorker) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
- func (fake *FakeWorker) Satisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) (worker.Worker, error)
- func (fake *FakeWorker) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
- func (fake *FakeWorker) SatisfyingCallCount() int
- func (fake *FakeWorker) SatisfyingReturns(result1 worker.Worker, result2 error)
- func (fake *FakeWorker) SatisfyingReturnsOnCall(i int, result1 worker.Worker, result2 error)
- func (fake *FakeWorker) Tags() atc.Tags
- func (fake *FakeWorker) TagsCallCount() int
- func (fake *FakeWorker) TagsReturns(result1 atc.Tags)
- func (fake *FakeWorker) TagsReturnsOnCall(i int, result1 atc.Tags)
- func (fake *FakeWorker) Uptime() time.Duration
- func (fake *FakeWorker) UptimeCallCount() int
- func (fake *FakeWorker) UptimeReturns(result1 time.Duration)
- func (fake *FakeWorker) UptimeReturnsOnCall(i int, result1 time.Duration)
- type FakeWorkerProvider
- func (fake *FakeWorkerProvider) FindWorkerForBuildContainer(logger lager.Logger, teamID int, buildID int, planID atc.PlanID) (worker.Worker, bool, error)
- func (fake *FakeWorkerProvider) FindWorkerForBuildContainerArgsForCall(i int) (lager.Logger, int, int, atc.PlanID)
- func (fake *FakeWorkerProvider) FindWorkerForBuildContainerCallCount() int
- func (fake *FakeWorkerProvider) FindWorkerForBuildContainerReturns(result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) FindWorkerForBuildContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) FindWorkerForContainer(logger lager.Logger, teamID int, handle string) (worker.Worker, bool, error)
- func (fake *FakeWorkerProvider) FindWorkerForContainerArgsForCall(i int) (lager.Logger, int, string)
- func (fake *FakeWorkerProvider) FindWorkerForContainerCallCount() int
- func (fake *FakeWorkerProvider) FindWorkerForContainerReturns(result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) FindWorkerForContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainer(logger lager.Logger, teamID int, resourceUser dbng.ResourceUser, ...) (worker.Worker, bool, error)
- func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerArgsForCall(i int) (lager.Logger, int, dbng.ResourceUser, string, atc.Source, ...)
- func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerCallCount() int
- func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerReturns(result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerReturnsOnCall(i int, result1 worker.Worker, 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) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)
- func (fake *FakeWorkerProvider) Invocations() map[string][][]interface{}
- func (fake *FakeWorkerProvider) RunningWorkers() ([]worker.Worker, error)
- func (fake *FakeWorkerProvider) RunningWorkersCallCount() int
- func (fake *FakeWorkerProvider) RunningWorkersReturns(result1 []worker.Worker, result2 error)
- func (fake *FakeWorkerProvider) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeArtifactDestination ¶
type FakeArtifactDestination struct { StreamInStub func(string, io.Reader) error // contains filtered or unexported fields }
func (*FakeArtifactDestination) Invocations ¶
func (fake *FakeArtifactDestination) Invocations() map[string][][]interface{}
func (*FakeArtifactDestination) StreamIn ¶
func (fake *FakeArtifactDestination) StreamIn(arg1 string, arg2 io.Reader) error
func (*FakeArtifactDestination) StreamInArgsForCall ¶
func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (string, io.Reader)
func (*FakeArtifactDestination) StreamInCallCount ¶
func (fake *FakeArtifactDestination) StreamInCallCount() int
func (*FakeArtifactDestination) StreamInReturns ¶
func (fake *FakeArtifactDestination) StreamInReturns(result1 error)
func (*FakeArtifactDestination) StreamInReturnsOnCall ¶
func (fake *FakeArtifactDestination) StreamInReturnsOnCall(i int, result1 error)
type FakeArtifactSource ¶
type FakeArtifactSource struct { StreamToStub func(worker.ArtifactDestination) error StreamFileStub func(path string) (io.ReadCloser, error) VolumeOnStub func(worker.Worker) (worker.Volume, bool, error) // contains filtered or unexported fields }
func (*FakeArtifactSource) Invocations ¶
func (fake *FakeArtifactSource) Invocations() map[string][][]interface{}
func (*FakeArtifactSource) StreamFile ¶
func (fake *FakeArtifactSource) StreamFile(path string) (io.ReadCloser, error)
func (*FakeArtifactSource) StreamFileArgsForCall ¶
func (fake *FakeArtifactSource) StreamFileArgsForCall(i int) string
func (*FakeArtifactSource) StreamFileCallCount ¶
func (fake *FakeArtifactSource) StreamFileCallCount() int
func (*FakeArtifactSource) StreamFileReturns ¶
func (fake *FakeArtifactSource) StreamFileReturns(result1 io.ReadCloser, result2 error)
func (*FakeArtifactSource) StreamFileReturnsOnCall ¶
func (fake *FakeArtifactSource) StreamFileReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
func (*FakeArtifactSource) StreamTo ¶
func (fake *FakeArtifactSource) StreamTo(arg1 worker.ArtifactDestination) error
func (*FakeArtifactSource) StreamToArgsForCall ¶
func (fake *FakeArtifactSource) StreamToArgsForCall(i int) worker.ArtifactDestination
func (*FakeArtifactSource) StreamToCallCount ¶
func (fake *FakeArtifactSource) StreamToCallCount() int
func (*FakeArtifactSource) StreamToReturns ¶
func (fake *FakeArtifactSource) StreamToReturns(result1 error)
func (*FakeArtifactSource) StreamToReturnsOnCall ¶
func (fake *FakeArtifactSource) StreamToReturnsOnCall(i int, result1 error)
func (*FakeArtifactSource) VolumeOnArgsForCall ¶
func (fake *FakeArtifactSource) VolumeOnArgsForCall(i int) worker.Worker
func (*FakeArtifactSource) VolumeOnCallCount ¶
func (fake *FakeArtifactSource) VolumeOnCallCount() int
func (*FakeArtifactSource) VolumeOnReturns ¶
func (fake *FakeArtifactSource) VolumeOnReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeArtifactSource) VolumeOnReturnsOnCall ¶
type FakeClient ¶
type FakeClient struct { FindOrCreateBuildContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes) (worker.Container, error) CreateResourceGetContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error) FindOrCreateResourceCheckContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error) CreateVolumeForResourceCacheStub func(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error) FindInitializedVolumeForResourceCacheStub func(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error) FindContainerByHandleStub func(lager.Logger, int, string) (worker.Container, bool, error) FindResourceTypeByPathStub func(path string) (atc.WorkerResourceType, bool) LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error) SatisfyingStub func(worker.WorkerSpec, atc.VersionedResourceTypes) (worker.Worker, error) AllSatisfyingStub func(worker.WorkerSpec, atc.VersionedResourceTypes) ([]worker.Worker, error) RunningWorkersStub func() ([]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.VersionedResourceTypes) ([]worker.Worker, error)
func (*FakeClient) AllSatisfyingArgsForCall ¶
func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
func (*FakeClient) AllSatisfyingCallCount ¶
func (fake *FakeClient) AllSatisfyingCallCount() int
func (*FakeClient) AllSatisfyingReturns ¶
func (fake *FakeClient) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
func (*FakeClient) AllSatisfyingReturnsOnCall ¶
func (fake *FakeClient) AllSatisfyingReturnsOnCall(i int, result1 []worker.Worker, result2 error)
func (*FakeClient) CreateResourceGetContainer ¶
func (fake *FakeClient) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)
func (*FakeClient) CreateResourceGetContainerArgsForCall ¶
func (fake *FakeClient) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Version, atc.Source, atc.Params)
func (*FakeClient) CreateResourceGetContainerCallCount ¶
func (fake *FakeClient) CreateResourceGetContainerCallCount() int
func (*FakeClient) CreateResourceGetContainerReturns ¶
func (fake *FakeClient) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
func (*FakeClient) CreateResourceGetContainerReturnsOnCall ¶
func (fake *FakeClient) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeClient) CreateVolumeForResourceCache ¶
func (fake *FakeClient) CreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error)
func (*FakeClient) CreateVolumeForResourceCacheArgsForCall ¶
func (fake *FakeClient) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
func (*FakeClient) CreateVolumeForResourceCacheCallCount ¶
func (fake *FakeClient) CreateVolumeForResourceCacheCallCount() int
func (*FakeClient) CreateVolumeForResourceCacheReturns ¶
func (fake *FakeClient) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
func (*FakeClient) CreateVolumeForResourceCacheReturnsOnCall ¶
func (fake *FakeClient) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeClient) FindContainerByHandle ¶
func (*FakeClient) FindContainerByHandleArgsForCall ¶
func (*FakeClient) FindContainerByHandleCallCount ¶
func (fake *FakeClient) FindContainerByHandleCallCount() int
func (*FakeClient) FindContainerByHandleReturns ¶
func (fake *FakeClient) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeClient) FindContainerByHandleReturnsOnCall ¶
func (*FakeClient) FindInitializedVolumeForResourceCache ¶
func (fake *FakeClient) FindInitializedVolumeForResourceCache(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error)
func (*FakeClient) FindInitializedVolumeForResourceCacheArgsForCall ¶
func (fake *FakeClient) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
func (*FakeClient) FindInitializedVolumeForResourceCacheCallCount ¶
func (fake *FakeClient) FindInitializedVolumeForResourceCacheCallCount() int
func (*FakeClient) FindInitializedVolumeForResourceCacheReturns ¶
func (fake *FakeClient) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeClient) FindInitializedVolumeForResourceCacheReturnsOnCall ¶
func (*FakeClient) FindOrCreateBuildContainer ¶
func (fake *FakeClient) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 int, arg5 atc.PlanID, arg6 dbng.ContainerMetadata, arg7 worker.ContainerSpec, arg8 atc.VersionedResourceTypes) (worker.Container, error)
func (*FakeClient) FindOrCreateBuildContainerArgsForCall ¶
func (fake *FakeClient) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes)
func (*FakeClient) FindOrCreateBuildContainerCallCount ¶
func (fake *FakeClient) FindOrCreateBuildContainerCallCount() int
func (*FakeClient) FindOrCreateBuildContainerReturns ¶
func (fake *FakeClient) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
func (*FakeClient) FindOrCreateBuildContainerReturnsOnCall ¶
func (fake *FakeClient) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeClient) FindOrCreateResourceCheckContainer ¶
func (fake *FakeClient) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error)
func (*FakeClient) FindOrCreateResourceCheckContainerArgsForCall ¶
func (fake *FakeClient) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Source)
func (*FakeClient) FindOrCreateResourceCheckContainerCallCount ¶
func (fake *FakeClient) FindOrCreateResourceCheckContainerCallCount() int
func (*FakeClient) FindOrCreateResourceCheckContainerReturns ¶
func (fake *FakeClient) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
func (*FakeClient) FindOrCreateResourceCheckContainerReturnsOnCall ¶
func (fake *FakeClient) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeClient) FindResourceTypeByPath ¶
func (fake *FakeClient) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)
func (*FakeClient) FindResourceTypeByPathArgsForCall ¶
func (fake *FakeClient) FindResourceTypeByPathArgsForCall(i int) string
func (*FakeClient) FindResourceTypeByPathCallCount ¶
func (fake *FakeClient) FindResourceTypeByPathCallCount() int
func (*FakeClient) FindResourceTypeByPathReturns ¶
func (fake *FakeClient) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)
func (*FakeClient) FindResourceTypeByPathReturnsOnCall ¶
func (fake *FakeClient) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)
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) GetWorkerReturnsOnCall ¶
func (fake *FakeClient) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error)
func (*FakeClient) Invocations ¶
func (fake *FakeClient) Invocations() map[string][][]interface{}
func (*FakeClient) LookupVolume ¶
func (*FakeClient) LookupVolumeArgsForCall ¶
func (fake *FakeClient) LookupVolumeArgsForCall(i int) (lager.Logger, string)
func (*FakeClient) LookupVolumeCallCount ¶
func (fake *FakeClient) LookupVolumeCallCount() int
func (*FakeClient) LookupVolumeReturns ¶
func (fake *FakeClient) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeClient) LookupVolumeReturnsOnCall ¶
func (*FakeClient) RunningWorkers ¶
func (fake *FakeClient) RunningWorkers() ([]worker.Worker, error)
func (*FakeClient) RunningWorkersCallCount ¶
func (fake *FakeClient) RunningWorkersCallCount() int
func (*FakeClient) RunningWorkersReturns ¶
func (fake *FakeClient) RunningWorkersReturns(result1 []worker.Worker, result2 error)
func (*FakeClient) RunningWorkersReturnsOnCall ¶
func (fake *FakeClient) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
func (*FakeClient) Satisfying ¶
func (fake *FakeClient) Satisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) (worker.Worker, error)
func (*FakeClient) SatisfyingArgsForCall ¶
func (fake *FakeClient) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
func (*FakeClient) SatisfyingCallCount ¶
func (fake *FakeClient) SatisfyingCallCount() int
func (*FakeClient) SatisfyingReturns ¶
func (fake *FakeClient) SatisfyingReturns(result1 worker.Worker, result2 error)
func (*FakeClient) SatisfyingReturnsOnCall ¶
func (fake *FakeClient) SatisfyingReturnsOnCall(i int, 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) CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error) CurrentCPULimitsStub func() (garden.CPULimits, error) CurrentDiskLimitsStub func() (garden.DiskLimits, error) CurrentMemoryLimitsStub func() (garden.MemoryLimits, error) NetInStub func(hostPort, containerPort uint32) (uint32, uint32, error) NetOutStub func(netOutRule garden.NetOutRule) error BulkNetOutStub func(netOutRules []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 VolumeMountsStub func() []worker.VolumeMount WorkerNameStub func() string MarkAsHijackedStub func() error // 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) AttachReturnsOnCall ¶
func (fake *FakeContainer) AttachReturnsOnCall(i int, result1 garden.Process, result2 error)
func (*FakeContainer) BulkNetOut ¶
func (fake *FakeContainer) BulkNetOut(netOutRules []garden.NetOutRule) error
func (*FakeContainer) BulkNetOutArgsForCall ¶
func (fake *FakeContainer) BulkNetOutArgsForCall(i int) []garden.NetOutRule
func (*FakeContainer) BulkNetOutCallCount ¶
func (fake *FakeContainer) BulkNetOutCallCount() int
func (*FakeContainer) BulkNetOutReturns ¶
func (fake *FakeContainer) BulkNetOutReturns(result1 error)
func (*FakeContainer) BulkNetOutReturnsOnCall ¶
func (fake *FakeContainer) BulkNetOutReturnsOnCall(i int, result1 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) CurrentBandwidthLimitsReturnsOnCall ¶
func (fake *FakeContainer) CurrentBandwidthLimitsReturnsOnCall(i int, 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) CurrentCPULimitsReturnsOnCall ¶
func (fake *FakeContainer) CurrentCPULimitsReturnsOnCall(i int, 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) CurrentDiskLimitsReturnsOnCall ¶
func (fake *FakeContainer) CurrentDiskLimitsReturnsOnCall(i int, 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) CurrentMemoryLimitsReturnsOnCall ¶
func (fake *FakeContainer) CurrentMemoryLimitsReturnsOnCall(i int, 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) DestroyReturnsOnCall ¶
func (fake *FakeContainer) DestroyReturnsOnCall(i int, 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) HandleReturnsOnCall ¶
func (fake *FakeContainer) HandleReturnsOnCall(i int, 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) InfoReturnsOnCall ¶
func (fake *FakeContainer) InfoReturnsOnCall(i int, result1 garden.ContainerInfo, result2 error)
func (*FakeContainer) Invocations ¶
func (fake *FakeContainer) Invocations() map[string][][]interface{}
func (*FakeContainer) MarkAsHijacked ¶
func (fake *FakeContainer) MarkAsHijacked() error
func (*FakeContainer) MarkAsHijackedCallCount ¶
func (fake *FakeContainer) MarkAsHijackedCallCount() int
func (*FakeContainer) MarkAsHijackedReturns ¶
func (fake *FakeContainer) MarkAsHijackedReturns(result1 error)
func (*FakeContainer) MarkAsHijackedReturnsOnCall ¶
func (fake *FakeContainer) MarkAsHijackedReturnsOnCall(i int, result1 error)
func (*FakeContainer) MetricsCallCount ¶
func (fake *FakeContainer) MetricsCallCount() int
func (*FakeContainer) MetricsReturns ¶
func (fake *FakeContainer) MetricsReturns(result1 garden.Metrics, result2 error)
func (*FakeContainer) MetricsReturnsOnCall ¶
func (fake *FakeContainer) MetricsReturnsOnCall(i int, 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) NetInReturnsOnCall ¶
func (fake *FakeContainer) NetInReturnsOnCall(i int, 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) NetOutReturnsOnCall ¶
func (fake *FakeContainer) NetOutReturnsOnCall(i int, 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) PropertiesReturnsOnCall ¶
func (fake *FakeContainer) PropertiesReturnsOnCall(i int, 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) PropertyReturnsOnCall ¶
func (fake *FakeContainer) PropertyReturnsOnCall(i int, result1 string, result2 error)
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) RemovePropertyReturnsOnCall ¶
func (fake *FakeContainer) RemovePropertyReturnsOnCall(i int, 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) RunReturnsOnCall ¶
func (fake *FakeContainer) RunReturnsOnCall(i int, 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) SetGraceTimeReturnsOnCall ¶
func (fake *FakeContainer) SetGraceTimeReturnsOnCall(i int, 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) SetPropertyReturnsOnCall ¶
func (fake *FakeContainer) SetPropertyReturnsOnCall(i int, 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) StopReturnsOnCall ¶
func (fake *FakeContainer) StopReturnsOnCall(i int, 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) StreamInReturnsOnCall ¶
func (fake *FakeContainer) StreamInReturnsOnCall(i int, 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) StreamOutReturnsOnCall ¶
func (fake *FakeContainer) StreamOutReturnsOnCall(i int, 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) VolumeMountsReturnsOnCall ¶
func (fake *FakeContainer) VolumeMountsReturnsOnCall(i int, result1 []worker.VolumeMount)
func (*FakeContainer) WorkerName ¶
func (fake *FakeContainer) WorkerName() string
func (*FakeContainer) WorkerNameCallCount ¶
func (fake *FakeContainer) WorkerNameCallCount() int
func (*FakeContainer) WorkerNameReturns ¶
func (fake *FakeContainer) WorkerNameReturns(result1 string)
func (*FakeContainer) WorkerNameReturnsOnCall ¶
func (fake *FakeContainer) WorkerNameReturnsOnCall(i int, result1 string)
type FakeContainerProvider ¶
type FakeContainerProvider struct { FindCreatedContainerByHandleStub func(logger lager.Logger, handle string, teamID int) (worker.Container, bool, error) FindOrCreateBuildContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, buildID int, planID atc.PlanID, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes) (worker.Container, error) FindOrCreateResourceCheckContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error) CreateResourceGetContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceTypeName string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error) // contains filtered or unexported fields }
func (*FakeContainerProvider) CreateResourceGetContainer ¶
func (fake *FakeContainerProvider) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceTypeName string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)
func (*FakeContainerProvider) CreateResourceGetContainerArgsForCall ¶
func (fake *FakeContainerProvider) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Version, atc.Source, atc.Params)
func (*FakeContainerProvider) CreateResourceGetContainerCallCount ¶
func (fake *FakeContainerProvider) CreateResourceGetContainerCallCount() int
func (*FakeContainerProvider) CreateResourceGetContainerReturns ¶
func (fake *FakeContainerProvider) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
func (*FakeContainerProvider) CreateResourceGetContainerReturnsOnCall ¶
func (fake *FakeContainerProvider) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeContainerProvider) FindCreatedContainerByHandle ¶
func (*FakeContainerProvider) FindCreatedContainerByHandleArgsForCall ¶
func (*FakeContainerProvider) FindCreatedContainerByHandleCallCount ¶
func (fake *FakeContainerProvider) FindCreatedContainerByHandleCallCount() int
func (*FakeContainerProvider) FindCreatedContainerByHandleReturns ¶
func (fake *FakeContainerProvider) FindCreatedContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeContainerProvider) FindCreatedContainerByHandleReturnsOnCall ¶
func (*FakeContainerProvider) FindOrCreateBuildContainer ¶
func (fake *FakeContainerProvider) FindOrCreateBuildContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, buildID int, planID atc.PlanID, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes) (worker.Container, error)
func (*FakeContainerProvider) FindOrCreateBuildContainerArgsForCall ¶
func (fake *FakeContainerProvider) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes)
func (*FakeContainerProvider) FindOrCreateBuildContainerCallCount ¶
func (fake *FakeContainerProvider) FindOrCreateBuildContainerCallCount() int
func (*FakeContainerProvider) FindOrCreateBuildContainerReturns ¶
func (fake *FakeContainerProvider) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
func (*FakeContainerProvider) FindOrCreateBuildContainerReturnsOnCall ¶
func (fake *FakeContainerProvider) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeContainerProvider) FindOrCreateResourceCheckContainer ¶
func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error)
func (*FakeContainerProvider) FindOrCreateResourceCheckContainerArgsForCall ¶
func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Source)
func (*FakeContainerProvider) FindOrCreateResourceCheckContainerCallCount ¶
func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerCallCount() int
func (*FakeContainerProvider) FindOrCreateResourceCheckContainerReturns ¶
func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
func (*FakeContainerProvider) FindOrCreateResourceCheckContainerReturnsOnCall ¶
func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeContainerProvider) Invocations ¶
func (fake *FakeContainerProvider) Invocations() map[string][][]interface{}
type FakeContainerProviderFactory ¶
type FakeContainerProviderFactory struct { ContainerProviderForStub func(worker.Worker) worker.ContainerProvider // contains filtered or unexported fields }
func (*FakeContainerProviderFactory) ContainerProviderFor ¶
func (fake *FakeContainerProviderFactory) ContainerProviderFor(arg1 worker.Worker) worker.ContainerProvider
func (*FakeContainerProviderFactory) ContainerProviderForArgsForCall ¶
func (fake *FakeContainerProviderFactory) ContainerProviderForArgsForCall(i int) worker.Worker
func (*FakeContainerProviderFactory) ContainerProviderForCallCount ¶
func (fake *FakeContainerProviderFactory) ContainerProviderForCallCount() int
func (*FakeContainerProviderFactory) ContainerProviderForReturns ¶
func (fake *FakeContainerProviderFactory) ContainerProviderForReturns(result1 worker.ContainerProvider)
func (*FakeContainerProviderFactory) ContainerProviderForReturnsOnCall ¶
func (fake *FakeContainerProviderFactory) ContainerProviderForReturnsOnCall(i int, result1 worker.ContainerProvider)
func (*FakeContainerProviderFactory) Invocations ¶
func (fake *FakeContainerProviderFactory) Invocations() map[string][][]interface{}
type FakeGardenConnectionFactory ¶
type FakeGardenConnectionFactory struct { BuildConnectionStub func() gconn.Connection // contains filtered or unexported fields }
func (*FakeGardenConnectionFactory) BuildConnection ¶
func (fake *FakeGardenConnectionFactory) BuildConnection() gconn.Connection
func (*FakeGardenConnectionFactory) BuildConnectionCallCount ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int
func (*FakeGardenConnectionFactory) BuildConnectionReturns ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionReturns(result1 gconn.Connection)
func (*FakeGardenConnectionFactory) BuildConnectionReturnsOnCall ¶
func (fake *FakeGardenConnectionFactory) BuildConnectionReturnsOnCall(i int, result1 gconn.Connection)
func (*FakeGardenConnectionFactory) Invocations ¶
func (fake *FakeGardenConnectionFactory) Invocations() map[string][][]interface{}
type FakeImage ¶
type FakeImage struct { FetchForContainerStub func(logger lager.Logger, container dbng.CreatingContainer) (worker.FetchedImage, error) // contains filtered or unexported fields }
func (*FakeImage) FetchForContainer ¶
func (fake *FakeImage) FetchForContainer(logger lager.Logger, container dbng.CreatingContainer) (worker.FetchedImage, error)
func (*FakeImage) FetchForContainerArgsForCall ¶
func (*FakeImage) FetchForContainerCallCount ¶
func (*FakeImage) FetchForContainerReturns ¶
func (fake *FakeImage) FetchForContainerReturns(result1 worker.FetchedImage, result2 error)
func (*FakeImage) FetchForContainerReturnsOnCall ¶
func (fake *FakeImage) FetchForContainerReturnsOnCall(i int, result1 worker.FetchedImage, result2 error)
func (*FakeImage) Invocations ¶
type FakeImageFactory ¶
type FakeImageFactory struct { GetImageStub func(logger lager.Logger, workerClient worker.Worker, volumeClient worker.VolumeClient, imageSpec worker.ImageSpec, teamID int, signals <-chan os.Signal, delegate worker.ImageFetchingDelegate, resourceUser dbng.ResourceUser, resourceTypes atc.VersionedResourceTypes) (worker.Image, error) // contains filtered or unexported fields }
func (*FakeImageFactory) GetImage ¶
func (fake *FakeImageFactory) GetImage(logger lager.Logger, workerClient worker.Worker, volumeClient worker.VolumeClient, imageSpec worker.ImageSpec, teamID int, signals <-chan os.Signal, delegate worker.ImageFetchingDelegate, resourceUser dbng.ResourceUser, resourceTypes atc.VersionedResourceTypes) (worker.Image, error)
func (*FakeImageFactory) GetImageArgsForCall ¶
func (fake *FakeImageFactory) GetImageArgsForCall(i int) (lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ResourceUser, atc.VersionedResourceTypes)
func (*FakeImageFactory) GetImageCallCount ¶
func (fake *FakeImageFactory) GetImageCallCount() int
func (*FakeImageFactory) GetImageReturns ¶
func (fake *FakeImageFactory) GetImageReturns(result1 worker.Image, result2 error)
func (*FakeImageFactory) GetImageReturnsOnCall ¶
func (fake *FakeImageFactory) GetImageReturnsOnCall(i int, result1 worker.Image, result2 error)
func (*FakeImageFactory) Invocations ¶
func (fake *FakeImageFactory) Invocations() map[string][][]interface{}
type FakeImageFetchingDelegate ¶
type FakeImageFetchingDelegate struct { StderrStub func() io.Writer ImageVersionDeterminedStub func(worker.ResourceCacheIdentifier) error // contains filtered or unexported fields }
func (*FakeImageFetchingDelegate) ImageVersionDetermined ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 worker.ResourceCacheIdentifier) error
func (*FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) worker.ResourceCacheIdentifier
func (*FakeImageFetchingDelegate) ImageVersionDeterminedCallCount ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int
func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturns ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)
func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall ¶
func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall(i int, result1 error)
func (*FakeImageFetchingDelegate) Invocations ¶
func (fake *FakeImageFetchingDelegate) Invocations() map[string][][]interface{}
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)
func (*FakeImageFetchingDelegate) StderrReturnsOnCall ¶
func (fake *FakeImageFetchingDelegate) StderrReturnsOnCall(i int, result1 io.Writer)
type FakeInputSource ¶
type FakeInputSource struct { NameStub func() worker.ArtifactName SourceStub func() worker.ArtifactSource DestinationPathStub func() string // contains filtered or unexported fields }
func (*FakeInputSource) DestinationPath ¶
func (fake *FakeInputSource) DestinationPath() string
func (*FakeInputSource) DestinationPathCallCount ¶
func (fake *FakeInputSource) DestinationPathCallCount() int
func (*FakeInputSource) DestinationPathReturns ¶
func (fake *FakeInputSource) DestinationPathReturns(result1 string)
func (*FakeInputSource) DestinationPathReturnsOnCall ¶
func (fake *FakeInputSource) DestinationPathReturnsOnCall(i int, result1 string)
func (*FakeInputSource) Invocations ¶
func (fake *FakeInputSource) Invocations() map[string][][]interface{}
func (*FakeInputSource) Name ¶
func (fake *FakeInputSource) Name() worker.ArtifactName
func (*FakeInputSource) NameCallCount ¶
func (fake *FakeInputSource) NameCallCount() int
func (*FakeInputSource) NameReturns ¶
func (fake *FakeInputSource) NameReturns(result1 worker.ArtifactName)
func (*FakeInputSource) NameReturnsOnCall ¶
func (fake *FakeInputSource) NameReturnsOnCall(i int, result1 worker.ArtifactName)
func (*FakeInputSource) Source ¶
func (fake *FakeInputSource) Source() worker.ArtifactSource
func (*FakeInputSource) SourceCallCount ¶
func (fake *FakeInputSource) SourceCallCount() int
func (*FakeInputSource) SourceReturns ¶
func (fake *FakeInputSource) SourceReturns(result1 worker.ArtifactSource)
func (*FakeInputSource) SourceReturnsOnCall ¶
func (fake *FakeInputSource) SourceReturnsOnCall(i int, result1 worker.ArtifactSource)
type FakeLockDB ¶
type FakeLockDB struct { AcquireVolumeCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error) AcquireContainerCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error) // contains filtered or unexported fields }
func (*FakeLockDB) AcquireContainerCreatingLock ¶
func (*FakeLockDB) AcquireContainerCreatingLockArgsForCall ¶
func (fake *FakeLockDB) AcquireContainerCreatingLockArgsForCall(i int) (lager.Logger, int)
func (*FakeLockDB) AcquireContainerCreatingLockCallCount ¶
func (fake *FakeLockDB) AcquireContainerCreatingLockCallCount() int
func (*FakeLockDB) AcquireContainerCreatingLockReturns ¶
func (fake *FakeLockDB) AcquireContainerCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)
func (*FakeLockDB) AcquireContainerCreatingLockReturnsOnCall ¶
func (*FakeLockDB) AcquireVolumeCreatingLock ¶
func (*FakeLockDB) AcquireVolumeCreatingLockArgsForCall ¶
func (fake *FakeLockDB) AcquireVolumeCreatingLockArgsForCall(i int) (lager.Logger, int)
func (*FakeLockDB) AcquireVolumeCreatingLockCallCount ¶
func (fake *FakeLockDB) AcquireVolumeCreatingLockCallCount() int
func (*FakeLockDB) AcquireVolumeCreatingLockReturns ¶
func (fake *FakeLockDB) AcquireVolumeCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)
func (*FakeLockDB) AcquireVolumeCreatingLockReturnsOnCall ¶
func (*FakeLockDB) Invocations ¶
func (fake *FakeLockDB) Invocations() map[string][][]interface{}
type FakeSaveWorkerDB ¶
type FakeSaveWorkerDB struct { SaveWorkerStub func(atc.Worker, time.Duration) (dbng.Worker, error) // contains filtered or unexported fields }
func (*FakeSaveWorkerDB) Invocations ¶
func (fake *FakeSaveWorkerDB) Invocations() map[string][][]interface{}
func (*FakeSaveWorkerDB) SaveWorker ¶
func (*FakeSaveWorkerDB) SaveWorkerArgsForCall ¶
func (*FakeSaveWorkerDB) SaveWorkerCallCount ¶
func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int
func (*FakeSaveWorkerDB) SaveWorkerReturns ¶
func (fake *FakeSaveWorkerDB) SaveWorkerReturns(result1 dbng.Worker, result2 error)
func (*FakeSaveWorkerDB) SaveWorkerReturnsOnCall ¶
func (fake *FakeSaveWorkerDB) SaveWorkerReturnsOnCall(i int, result1 dbng.Worker, result2 error)
type FakeSleeper ¶
func (*FakeSleeper) Invocations ¶
func (fake *FakeSleeper) Invocations() map[string][][]interface{}
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 SetPropertyStub func(key string, value string) error PropertiesStub func() (baggageclaim.VolumeProperties, error) StreamInStub func(path string, tarStream io.Reader) error StreamOutStub func(path string) (io.ReadCloser, error) COWStrategyStub func() baggageclaim.COWStrategy IsInitializedStub func() (bool, error) InitializeStub func() error CreateChildForContainerStub func(dbng.CreatingContainer, string) (dbng.CreatingVolume, error) DestroyStub func() error // contains filtered or unexported fields }
func (*FakeVolume) COWStrategy ¶
func (fake *FakeVolume) COWStrategy() baggageclaim.COWStrategy
func (*FakeVolume) COWStrategyCallCount ¶
func (fake *FakeVolume) COWStrategyCallCount() int
func (*FakeVolume) COWStrategyReturns ¶
func (fake *FakeVolume) COWStrategyReturns(result1 baggageclaim.COWStrategy)
func (*FakeVolume) COWStrategyReturnsOnCall ¶
func (fake *FakeVolume) COWStrategyReturnsOnCall(i int, result1 baggageclaim.COWStrategy)
func (*FakeVolume) CreateChildForContainer ¶
func (fake *FakeVolume) CreateChildForContainer(arg1 dbng.CreatingContainer, arg2 string) (dbng.CreatingVolume, error)
func (*FakeVolume) CreateChildForContainerArgsForCall ¶
func (fake *FakeVolume) CreateChildForContainerArgsForCall(i int) (dbng.CreatingContainer, string)
func (*FakeVolume) CreateChildForContainerCallCount ¶
func (fake *FakeVolume) CreateChildForContainerCallCount() int
func (*FakeVolume) CreateChildForContainerReturns ¶
func (fake *FakeVolume) CreateChildForContainerReturns(result1 dbng.CreatingVolume, result2 error)
func (*FakeVolume) CreateChildForContainerReturnsOnCall ¶
func (fake *FakeVolume) CreateChildForContainerReturnsOnCall(i int, result1 dbng.CreatingVolume, result2 error)
func (*FakeVolume) Destroy ¶
func (fake *FakeVolume) Destroy() error
func (*FakeVolume) DestroyCallCount ¶
func (fake *FakeVolume) DestroyCallCount() int
func (*FakeVolume) DestroyReturns ¶
func (fake *FakeVolume) DestroyReturns(result1 error)
func (*FakeVolume) DestroyReturnsOnCall ¶
func (fake *FakeVolume) DestroyReturnsOnCall(i int, result1 error)
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) HandleReturnsOnCall ¶
func (fake *FakeVolume) HandleReturnsOnCall(i int, result1 string)
func (*FakeVolume) Initialize ¶
func (fake *FakeVolume) Initialize() error
func (*FakeVolume) InitializeCallCount ¶
func (fake *FakeVolume) InitializeCallCount() int
func (*FakeVolume) InitializeReturns ¶
func (fake *FakeVolume) InitializeReturns(result1 error)
func (*FakeVolume) InitializeReturnsOnCall ¶
func (fake *FakeVolume) InitializeReturnsOnCall(i int, result1 error)
func (*FakeVolume) Invocations ¶
func (fake *FakeVolume) Invocations() map[string][][]interface{}
func (*FakeVolume) IsInitialized ¶
func (fake *FakeVolume) IsInitialized() (bool, error)
func (*FakeVolume) IsInitializedCallCount ¶
func (fake *FakeVolume) IsInitializedCallCount() int
func (*FakeVolume) IsInitializedReturns ¶
func (fake *FakeVolume) IsInitializedReturns(result1 bool, result2 error)
func (*FakeVolume) IsInitializedReturnsOnCall ¶
func (fake *FakeVolume) IsInitializedReturnsOnCall(i int, result1 bool, result2 error)
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) PathReturnsOnCall ¶
func (fake *FakeVolume) PathReturnsOnCall(i int, 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) PropertiesReturnsOnCall ¶
func (fake *FakeVolume) PropertiesReturnsOnCall(i int, result1 baggageclaim.VolumeProperties, result2 error)
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) SetPropertyReturnsOnCall ¶
func (fake *FakeVolume) SetPropertyReturnsOnCall(i int, result1 error)
func (*FakeVolume) StreamIn ¶
func (fake *FakeVolume) StreamIn(path string, tarStream io.Reader) error
func (*FakeVolume) StreamInArgsForCall ¶
func (fake *FakeVolume) StreamInArgsForCall(i int) (string, io.Reader)
func (*FakeVolume) StreamInCallCount ¶
func (fake *FakeVolume) StreamInCallCount() int
func (*FakeVolume) StreamInReturns ¶
func (fake *FakeVolume) StreamInReturns(result1 error)
func (*FakeVolume) StreamInReturnsOnCall ¶
func (fake *FakeVolume) StreamInReturnsOnCall(i int, result1 error)
func (*FakeVolume) StreamOut ¶
func (fake *FakeVolume) StreamOut(path string) (io.ReadCloser, error)
func (*FakeVolume) StreamOutArgsForCall ¶
func (fake *FakeVolume) StreamOutArgsForCall(i int) string
func (*FakeVolume) StreamOutCallCount ¶
func (fake *FakeVolume) StreamOutCallCount() int
func (*FakeVolume) StreamOutReturns ¶
func (fake *FakeVolume) StreamOutReturns(result1 io.ReadCloser, result2 error)
func (*FakeVolume) StreamOutReturnsOnCall ¶
func (fake *FakeVolume) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
type FakeVolumeClient ¶
type FakeVolumeClient struct { CreateVolumeForResourceCacheStub func(lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache) (worker.Volume, error) FindOrCreateVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, int, string) (worker.Volume, error) FindOrCreateCOWVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, worker.Volume, int, string) (worker.Volume, error) FindOrCreateVolumeForBaseResourceTypeStub func(lager.Logger, worker.VolumeSpec, int, string) (worker.Volume, error) FindInitializedVolumeForResourceCacheStub func(lager.Logger, *dbng.UsedResourceCache) (worker.Volume, bool, error) LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error) // contains filtered or unexported fields }
func (*FakeVolumeClient) CreateVolumeForResourceCache ¶
func (fake *FakeVolumeClient) CreateVolumeForResourceCache(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 *dbng.UsedResourceCache) (worker.Volume, error)
func (*FakeVolumeClient) CreateVolumeForResourceCacheArgsForCall ¶
func (fake *FakeVolumeClient) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
func (*FakeVolumeClient) CreateVolumeForResourceCacheCallCount ¶
func (fake *FakeVolumeClient) CreateVolumeForResourceCacheCallCount() int
func (*FakeVolumeClient) CreateVolumeForResourceCacheReturns ¶
func (fake *FakeVolumeClient) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
func (*FakeVolumeClient) CreateVolumeForResourceCacheReturnsOnCall ¶
func (fake *FakeVolumeClient) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindInitializedVolumeForResourceCache ¶
func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCache(arg1 lager.Logger, arg2 *dbng.UsedResourceCache) (worker.Volume, bool, error)
func (*FakeVolumeClient) FindInitializedVolumeForResourceCacheArgsForCall ¶
func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
func (*FakeVolumeClient) FindInitializedVolumeForResourceCacheCallCount ¶
func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheCallCount() int
func (*FakeVolumeClient) FindInitializedVolumeForResourceCacheReturns ¶
func (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeVolumeClient) FindInitializedVolumeForResourceCacheReturnsOnCall ¶
func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainer ¶
func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 dbng.CreatingContainer, arg4 worker.Volume, arg5 int, arg6 string) (worker.Volume, error)
func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall ¶
func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, worker.Volume, int, string)
func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount ¶
func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount() int
func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturns ¶
func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturns(result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturnsOnCall ¶
func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceType ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceType(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 string) (worker.Volume, error)
func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeArgsForCall ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, string)
func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount() int
func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturns ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturns(result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturnsOnCall ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindOrCreateVolumeForContainer ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 dbng.CreatingContainer, arg4 int, arg5 string) (worker.Volume, error)
func (*FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, int, string)
func (*FakeVolumeClient) FindOrCreateVolumeForContainerCallCount ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCallCount() int
func (*FakeVolumeClient) FindOrCreateVolumeForContainerReturns ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturns(result1 worker.Volume, result2 error)
func (*FakeVolumeClient) FindOrCreateVolumeForContainerReturnsOnCall ¶
func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeVolumeClient) Invocations ¶
func (fake *FakeVolumeClient) Invocations() map[string][][]interface{}
func (*FakeVolumeClient) LookupVolume ¶
func (*FakeVolumeClient) LookupVolumeArgsForCall ¶
func (fake *FakeVolumeClient) LookupVolumeArgsForCall(i int) (lager.Logger, string)
func (*FakeVolumeClient) LookupVolumeCallCount ¶
func (fake *FakeVolumeClient) LookupVolumeCallCount() int
func (*FakeVolumeClient) LookupVolumeReturns ¶
func (fake *FakeVolumeClient) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeVolumeClient) LookupVolumeReturnsOnCall ¶
type FakeWorker ¶
type FakeWorker struct { FindOrCreateBuildContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes) (worker.Container, error) CreateResourceGetContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error) FindOrCreateResourceCheckContainerStub func(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error) CreateVolumeForResourceCacheStub func(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error) FindInitializedVolumeForResourceCacheStub func(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error) FindContainerByHandleStub func(lager.Logger, int, string) (worker.Container, bool, error) FindResourceTypeByPathStub func(path string) (atc.WorkerResourceType, bool) LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error) SatisfyingStub func(worker.WorkerSpec, atc.VersionedResourceTypes) (worker.Worker, error) AllSatisfyingStub func(worker.WorkerSpec, atc.VersionedResourceTypes) ([]worker.Worker, error) RunningWorkersStub func() ([]worker.Worker, error) GetWorkerStub func(workerName string) (worker.Worker, error) ActiveContainersStub func() int DescriptionStub func() string NameStub func() string ResourceTypesStub func() []atc.WorkerResourceType TagsStub func() atc.Tags UptimeStub func() time.Duration IsOwnedByTeamStub func() 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) ActiveContainersReturnsOnCall ¶
func (fake *FakeWorker) ActiveContainersReturnsOnCall(i int, result1 int)
func (*FakeWorker) AllSatisfying ¶
func (fake *FakeWorker) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) ([]worker.Worker, error)
func (*FakeWorker) AllSatisfyingArgsForCall ¶
func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
func (*FakeWorker) AllSatisfyingCallCount ¶
func (fake *FakeWorker) AllSatisfyingCallCount() int
func (*FakeWorker) AllSatisfyingReturns ¶
func (fake *FakeWorker) AllSatisfyingReturns(result1 []worker.Worker, result2 error)
func (*FakeWorker) AllSatisfyingReturnsOnCall ¶
func (fake *FakeWorker) AllSatisfyingReturnsOnCall(i int, result1 []worker.Worker, result2 error)
func (*FakeWorker) CreateResourceGetContainer ¶
func (fake *FakeWorker) CreateResourceGetContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)
func (*FakeWorker) CreateResourceGetContainerArgsForCall ¶
func (fake *FakeWorker) CreateResourceGetContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Version, atc.Source, atc.Params)
func (*FakeWorker) CreateResourceGetContainerCallCount ¶
func (fake *FakeWorker) CreateResourceGetContainerCallCount() int
func (*FakeWorker) CreateResourceGetContainerReturns ¶
func (fake *FakeWorker) CreateResourceGetContainerReturns(result1 worker.Container, result2 error)
func (*FakeWorker) CreateResourceGetContainerReturnsOnCall ¶
func (fake *FakeWorker) CreateResourceGetContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeWorker) CreateVolumeForResourceCache ¶
func (fake *FakeWorker) CreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error)
func (*FakeWorker) CreateVolumeForResourceCacheArgsForCall ¶
func (fake *FakeWorker) CreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)
func (*FakeWorker) CreateVolumeForResourceCacheCallCount ¶
func (fake *FakeWorker) CreateVolumeForResourceCacheCallCount() int
func (*FakeWorker) CreateVolumeForResourceCacheReturns ¶
func (fake *FakeWorker) CreateVolumeForResourceCacheReturns(result1 worker.Volume, result2 error)
func (*FakeWorker) CreateVolumeForResourceCacheReturnsOnCall ¶
func (fake *FakeWorker) CreateVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, 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) DescriptionReturnsOnCall ¶
func (fake *FakeWorker) DescriptionReturnsOnCall(i int, result1 string)
func (*FakeWorker) FindContainerByHandle ¶
func (*FakeWorker) FindContainerByHandleArgsForCall ¶
func (*FakeWorker) FindContainerByHandleCallCount ¶
func (fake *FakeWorker) FindContainerByHandleCallCount() int
func (*FakeWorker) FindContainerByHandleReturns ¶
func (fake *FakeWorker) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)
func (*FakeWorker) FindContainerByHandleReturnsOnCall ¶
func (*FakeWorker) FindInitializedVolumeForResourceCache ¶
func (fake *FakeWorker) FindInitializedVolumeForResourceCache(logger lager.Logger, resourceCache *dbng.UsedResourceCache) (worker.Volume, bool, error)
func (*FakeWorker) FindInitializedVolumeForResourceCacheArgsForCall ¶
func (fake *FakeWorker) FindInitializedVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *dbng.UsedResourceCache)
func (*FakeWorker) FindInitializedVolumeForResourceCacheCallCount ¶
func (fake *FakeWorker) FindInitializedVolumeForResourceCacheCallCount() int
func (*FakeWorker) FindInitializedVolumeForResourceCacheReturns ¶
func (fake *FakeWorker) FindInitializedVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeWorker) FindInitializedVolumeForResourceCacheReturnsOnCall ¶
func (*FakeWorker) FindOrCreateBuildContainer ¶
func (fake *FakeWorker) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 int, arg5 atc.PlanID, arg6 dbng.ContainerMetadata, arg7 worker.ContainerSpec, arg8 atc.VersionedResourceTypes) (worker.Container, error)
func (*FakeWorker) FindOrCreateBuildContainerArgsForCall ¶
func (fake *FakeWorker) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes)
func (*FakeWorker) FindOrCreateBuildContainerCallCount ¶
func (fake *FakeWorker) FindOrCreateBuildContainerCallCount() int
func (*FakeWorker) FindOrCreateBuildContainerReturns ¶
func (fake *FakeWorker) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)
func (*FakeWorker) FindOrCreateBuildContainerReturnsOnCall ¶
func (fake *FakeWorker) FindOrCreateBuildContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeWorker) FindOrCreateResourceCheckContainer ¶
func (fake *FakeWorker) FindOrCreateResourceCheckContainer(logger lager.Logger, resourceUser dbng.ResourceUser, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, metadata dbng.ContainerMetadata, spec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, resourceType string, source atc.Source) (worker.Container, error)
func (*FakeWorker) FindOrCreateResourceCheckContainerArgsForCall ¶
func (fake *FakeWorker) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, dbng.ResourceUser, <-chan os.Signal, worker.ImageFetchingDelegate, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, string, atc.Source)
func (*FakeWorker) FindOrCreateResourceCheckContainerCallCount ¶
func (fake *FakeWorker) FindOrCreateResourceCheckContainerCallCount() int
func (*FakeWorker) FindOrCreateResourceCheckContainerReturns ¶
func (fake *FakeWorker) FindOrCreateResourceCheckContainerReturns(result1 worker.Container, result2 error)
func (*FakeWorker) FindOrCreateResourceCheckContainerReturnsOnCall ¶
func (fake *FakeWorker) FindOrCreateResourceCheckContainerReturnsOnCall(i int, result1 worker.Container, result2 error)
func (*FakeWorker) FindResourceTypeByPath ¶
func (fake *FakeWorker) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)
func (*FakeWorker) FindResourceTypeByPathArgsForCall ¶
func (fake *FakeWorker) FindResourceTypeByPathArgsForCall(i int) string
func (*FakeWorker) FindResourceTypeByPathCallCount ¶
func (fake *FakeWorker) FindResourceTypeByPathCallCount() int
func (*FakeWorker) FindResourceTypeByPathReturns ¶
func (fake *FakeWorker) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)
func (*FakeWorker) FindResourceTypeByPathReturnsOnCall ¶
func (fake *FakeWorker) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)
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) GetWorkerReturnsOnCall ¶
func (fake *FakeWorker) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error)
func (*FakeWorker) Invocations ¶
func (fake *FakeWorker) Invocations() map[string][][]interface{}
func (*FakeWorker) IsOwnedByTeam ¶
func (fake *FakeWorker) IsOwnedByTeam() bool
func (*FakeWorker) IsOwnedByTeamCallCount ¶
func (fake *FakeWorker) IsOwnedByTeamCallCount() int
func (*FakeWorker) IsOwnedByTeamReturns ¶
func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool)
func (*FakeWorker) IsOwnedByTeamReturnsOnCall ¶
func (fake *FakeWorker) IsOwnedByTeamReturnsOnCall(i int, result1 bool)
func (*FakeWorker) LookupVolume ¶
func (*FakeWorker) LookupVolumeArgsForCall ¶
func (fake *FakeWorker) LookupVolumeArgsForCall(i int) (lager.Logger, string)
func (*FakeWorker) LookupVolumeCallCount ¶
func (fake *FakeWorker) LookupVolumeCallCount() int
func (*FakeWorker) LookupVolumeReturns ¶
func (fake *FakeWorker) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeWorker) LookupVolumeReturnsOnCall ¶
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) NameReturnsOnCall ¶
func (fake *FakeWorker) NameReturnsOnCall(i int, result1 string)
func (*FakeWorker) ResourceTypes ¶
func (fake *FakeWorker) ResourceTypes() []atc.WorkerResourceType
func (*FakeWorker) ResourceTypesCallCount ¶
func (fake *FakeWorker) ResourceTypesCallCount() int
func (*FakeWorker) ResourceTypesReturns ¶
func (fake *FakeWorker) ResourceTypesReturns(result1 []atc.WorkerResourceType)
func (*FakeWorker) ResourceTypesReturnsOnCall ¶
func (fake *FakeWorker) ResourceTypesReturnsOnCall(i int, result1 []atc.WorkerResourceType)
func (*FakeWorker) RunningWorkers ¶
func (fake *FakeWorker) RunningWorkers() ([]worker.Worker, error)
func (*FakeWorker) RunningWorkersCallCount ¶
func (fake *FakeWorker) RunningWorkersCallCount() int
func (*FakeWorker) RunningWorkersReturns ¶
func (fake *FakeWorker) RunningWorkersReturns(result1 []worker.Worker, result2 error)
func (*FakeWorker) RunningWorkersReturnsOnCall ¶
func (fake *FakeWorker) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
func (*FakeWorker) Satisfying ¶
func (fake *FakeWorker) Satisfying(arg1 worker.WorkerSpec, arg2 atc.VersionedResourceTypes) (worker.Worker, error)
func (*FakeWorker) SatisfyingArgsForCall ¶
func (fake *FakeWorker) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.VersionedResourceTypes)
func (*FakeWorker) SatisfyingCallCount ¶
func (fake *FakeWorker) SatisfyingCallCount() int
func (*FakeWorker) SatisfyingReturns ¶
func (fake *FakeWorker) SatisfyingReturns(result1 worker.Worker, result2 error)
func (*FakeWorker) SatisfyingReturnsOnCall ¶
func (fake *FakeWorker) SatisfyingReturnsOnCall(i int, result1 worker.Worker, result2 error)
func (*FakeWorker) Tags ¶
func (fake *FakeWorker) Tags() atc.Tags
func (*FakeWorker) TagsCallCount ¶
func (fake *FakeWorker) TagsCallCount() int
func (*FakeWorker) TagsReturns ¶
func (fake *FakeWorker) TagsReturns(result1 atc.Tags)
func (*FakeWorker) TagsReturnsOnCall ¶
func (fake *FakeWorker) TagsReturnsOnCall(i int, result1 atc.Tags)
func (*FakeWorker) Uptime ¶
func (fake *FakeWorker) Uptime() time.Duration
func (*FakeWorker) UptimeCallCount ¶
func (fake *FakeWorker) UptimeCallCount() int
func (*FakeWorker) UptimeReturns ¶
func (fake *FakeWorker) UptimeReturns(result1 time.Duration)
func (*FakeWorker) UptimeReturnsOnCall ¶
func (fake *FakeWorker) UptimeReturnsOnCall(i int, result1 time.Duration)
type FakeWorkerProvider ¶
type FakeWorkerProvider struct { RunningWorkersStub func() ([]worker.Worker, error) GetWorkerStub func(string) (worker.Worker, bool, error) FindWorkerForContainerStub func(logger lager.Logger, teamID int, handle string) (worker.Worker, bool, error) FindWorkerForResourceCheckContainerStub func(logger lager.Logger, teamID int, resourceUser dbng.ResourceUser, resourceType string, resourceSource atc.Source, types atc.VersionedResourceTypes) (worker.Worker, bool, error) FindWorkerForBuildContainerStub func(logger lager.Logger, teamID int, buildID int, planID atc.PlanID) (worker.Worker, bool, error) // contains filtered or unexported fields }
func (*FakeWorkerProvider) FindWorkerForBuildContainer ¶
func (*FakeWorkerProvider) FindWorkerForBuildContainerArgsForCall ¶
func (*FakeWorkerProvider) FindWorkerForBuildContainerCallCount ¶
func (fake *FakeWorkerProvider) FindWorkerForBuildContainerCallCount() int
func (*FakeWorkerProvider) FindWorkerForBuildContainerReturns ¶
func (fake *FakeWorkerProvider) FindWorkerForBuildContainerReturns(result1 worker.Worker, result2 bool, result3 error)
func (*FakeWorkerProvider) FindWorkerForBuildContainerReturnsOnCall ¶
func (*FakeWorkerProvider) FindWorkerForContainer ¶
func (*FakeWorkerProvider) FindWorkerForContainerArgsForCall ¶
func (*FakeWorkerProvider) FindWorkerForContainerCallCount ¶
func (fake *FakeWorkerProvider) FindWorkerForContainerCallCount() int
func (*FakeWorkerProvider) FindWorkerForContainerReturns ¶
func (fake *FakeWorkerProvider) FindWorkerForContainerReturns(result1 worker.Worker, result2 bool, result3 error)
func (*FakeWorkerProvider) FindWorkerForContainerReturnsOnCall ¶
func (*FakeWorkerProvider) FindWorkerForResourceCheckContainer ¶
func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainer(logger lager.Logger, teamID int, resourceUser dbng.ResourceUser, resourceType string, resourceSource atc.Source, types atc.VersionedResourceTypes) (worker.Worker, bool, error)
func (*FakeWorkerProvider) FindWorkerForResourceCheckContainerArgsForCall ¶
func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerArgsForCall(i int) (lager.Logger, int, dbng.ResourceUser, string, atc.Source, atc.VersionedResourceTypes)
func (*FakeWorkerProvider) FindWorkerForResourceCheckContainerCallCount ¶
func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerCallCount() int
func (*FakeWorkerProvider) FindWorkerForResourceCheckContainerReturns ¶
func (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerReturns(result1 worker.Worker, result2 bool, result3 error)
func (*FakeWorkerProvider) FindWorkerForResourceCheckContainerReturnsOnCall ¶
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) GetWorkerReturnsOnCall ¶
func (*FakeWorkerProvider) Invocations ¶
func (fake *FakeWorkerProvider) Invocations() map[string][][]interface{}
func (*FakeWorkerProvider) RunningWorkers ¶
func (fake *FakeWorkerProvider) RunningWorkers() ([]worker.Worker, error)
func (*FakeWorkerProvider) RunningWorkersCallCount ¶
func (fake *FakeWorkerProvider) RunningWorkersCallCount() int
func (*FakeWorkerProvider) RunningWorkersReturns ¶
func (fake *FakeWorkerProvider) RunningWorkersReturns(result1 []worker.Worker, result2 error)
func (*FakeWorkerProvider) RunningWorkersReturnsOnCall ¶
func (fake *FakeWorkerProvider) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)
Source Files
¶
- fake_artifact_destination.go
- fake_artifact_source.go
- fake_client.go
- fake_container.go
- fake_container_provider.go
- fake_container_provider_factory.go
- fake_garden_connection_factory.go
- fake_image.go
- fake_image_factory.go
- fake_image_fetching_delegate.go
- fake_input_source.go
- fake_lock_db.go
- fake_save_worker_db.go
- fake_sleeper.go
- fake_volume.go
- fake_volume_client.go
- fake_worker.go
- fake_worker_provider.go
Click to show internal directories.
Click to hide internal directories.