workerfakes

package
v0.0.0-...-e99be67 Latest Latest
Warning

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

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

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

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

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) VolumeOn

func (fake *FakeArtifactSource) VolumeOn(arg1 worker.Worker) (worker.Volume, bool, 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

func (fake *FakeArtifactSource) VolumeOnReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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) 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 (fake *FakeClient) FindContainerByHandle(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error)

func (*FakeClient) FindContainerByHandleArgsForCall

func (fake *FakeClient) FindContainerByHandleArgsForCall(i int) (lager.Logger, int, string)

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 (fake *FakeClient) FindContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)

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 (fake *FakeClient) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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) 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) 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 (fake *FakeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)

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 (fake *FakeClient) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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) Attach

func (fake *FakeContainer) Attach(processID string, io garden.ProcessIO) (garden.Process, error)

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) Metrics

func (fake *FakeContainer) Metrics() (garden.Metrics, 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) NetIn

func (fake *FakeContainer) NetIn(hostPort uint32, containerPort uint32) (uint32, uint32, 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) Property

func (fake *FakeContainer) Property(name string) (string, 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 (*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) 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 (fake *FakeContainerProvider) FindCreatedContainerByHandle(logger lager.Logger, handle string, teamID int) (worker.Container, bool, error)

func (*FakeContainerProvider) FindCreatedContainerByHandleArgsForCall

func (fake *FakeContainerProvider) FindCreatedContainerByHandleArgsForCall(i int) (lager.Logger, string, int)

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 (fake *FakeContainerProvider) FindCreatedContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)

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) 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) 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 (fake *FakeImage) FetchForContainerArgsForCall(i int) (lager.Logger, dbng.CreatingContainer)

func (*FakeImage) FetchForContainerCallCount

func (fake *FakeImage) FetchForContainerCallCount() int

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

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

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) 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 (fake *FakeLockDB) AcquireContainerCreatingLock(arg1 lager.Logger, arg2 int) (lock.Lock, bool, error)

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 (fake *FakeLockDB) AcquireContainerCreatingLockReturnsOnCall(i int, result1 lock.Lock, result2 bool, result3 error)

func (*FakeLockDB) AcquireVolumeCreatingLock

func (fake *FakeLockDB) AcquireVolumeCreatingLock(arg1 lager.Logger, arg2 int) (lock.Lock, bool, error)

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 (fake *FakeLockDB) AcquireVolumeCreatingLockReturnsOnCall(i int, result1 lock.Lock, result2 bool, result3 error)

func (*FakeLockDB) Invocations

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

type FakeSleeper

type FakeSleeper struct {
	SleepStub func(time.Duration)
	// contains filtered or unexported fields
}

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 (fake *FakeVolumeClient) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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 (fake *FakeVolumeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)

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

func (fake *FakeVolumeClient) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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) 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 (fake *FakeWorker) FindContainerByHandle(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error)

func (*FakeWorker) FindContainerByHandleArgsForCall

func (fake *FakeWorker) FindContainerByHandleArgsForCall(i int) (lager.Logger, int, string)

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 (fake *FakeWorker) FindContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)

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 (fake *FakeWorker) FindInitializedVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

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) 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) 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 (fake *FakeWorker) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)

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 (fake *FakeWorker) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)

func (*FakeWorker) Name

func (fake *FakeWorker) Name() string

func (*FakeWorker) NameCallCount

func (fake *FakeWorker) NameCallCount() int

func (*FakeWorker) NameReturns

func (fake *FakeWorker) NameReturns(result1 string)

func (*FakeWorker) 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 (fake *FakeWorkerProvider) FindWorkerForBuildContainer(logger lager.Logger, teamID int, buildID int, planID atc.PlanID) (worker.Worker, bool, error)

func (*FakeWorkerProvider) FindWorkerForBuildContainerArgsForCall

func (fake *FakeWorkerProvider) FindWorkerForBuildContainerArgsForCall(i int) (lager.Logger, int, int, atc.PlanID)

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 (fake *FakeWorkerProvider) FindWorkerForBuildContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)

func (*FakeWorkerProvider) FindWorkerForContainer

func (fake *FakeWorkerProvider) FindWorkerForContainer(logger lager.Logger, teamID int, handle string) (worker.Worker, bool, error)

func (*FakeWorkerProvider) FindWorkerForContainerArgsForCall

func (fake *FakeWorkerProvider) FindWorkerForContainerArgsForCall(i int) (lager.Logger, int, string)

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 (fake *FakeWorkerProvider) FindWorkerForContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)

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 (fake *FakeWorkerProvider) FindWorkerForResourceCheckContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)

func (*FakeWorkerProvider) GetWorker

func (fake *FakeWorkerProvider) GetWorker(arg1 string) (worker.Worker, bool, error)

func (*FakeWorkerProvider) GetWorkerArgsForCall

func (fake *FakeWorkerProvider) GetWorkerArgsForCall(i int) string

func (*FakeWorkerProvider) GetWorkerCallCount

func (fake *FakeWorkerProvider) GetWorkerCallCount() int

func (*FakeWorkerProvider) GetWorkerReturns

func (fake *FakeWorkerProvider) GetWorkerReturns(result1 worker.Worker, result2 bool, result3 error)

func (*FakeWorkerProvider) GetWorkerReturnsOnCall

func (fake *FakeWorkerProvider) GetWorkerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error)

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL