workerfakes

package
v0.0.0-...-9d0dc56 Latest Latest
Warning

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

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

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

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(lager.Logger, worker.WorkerSpec, atc.VersionedResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(lager.Logger, worker.WorkerSpec, atc.VersionedResourceTypes) ([]worker.Worker, error)

	RunningWorkersStub func(lager.Logger) ([]worker.Worker, error)
	// contains filtered or unexported fields
}

func (*FakeClient) AllSatisfying 

func (fake *FakeClient) AllSatisfying(arg1 lager.Logger, arg2 worker.WorkerSpec, arg3 atc.VersionedResourceTypes) ([]worker.Worker, error)

func (*FakeClient) AllSatisfyingArgsForCall 

func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (lager.Logger, 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 (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) 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) 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(arg1 lager.Logger) ([]worker.Worker, error)

func (*FakeClient) RunningWorkersArgsForCall 

func (fake *FakeClient) RunningWorkersArgsForCall(i int) lager.Logger

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 lager.Logger, arg2 worker.WorkerSpec, arg3 atc.VersionedResourceTypes) (worker.Worker, error)

func (*FakeClient) SatisfyingArgsForCall 

func (fake *FakeClient) SatisfyingArgsForCall(i int) (lager.Logger, 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 (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 (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) 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 (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) 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 (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)

	SetPrivilegedStub func(bool) 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) SetPrivileged 

func (fake *FakeVolume) SetPrivileged(arg1 bool) error

func (*FakeVolume) SetPrivilegedArgsForCall 

func (fake *FakeVolume) SetPrivilegedArgsForCall(i int) bool

func (*FakeVolume) SetPrivilegedCallCount 

func (fake *FakeVolume) SetPrivilegedCallCount() int

func (*FakeVolume) SetPrivilegedReturns 

func (fake *FakeVolume) SetPrivilegedReturns(result1 error)

func (*FakeVolume) SetPrivilegedReturnsOnCall 

func (fake *FakeVolume) SetPrivilegedReturnsOnCall(i int, result1 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(lager.Logger, worker.WorkerSpec, atc.VersionedResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(lager.Logger, worker.WorkerSpec, atc.VersionedResourceTypes) ([]worker.Worker, error)

	RunningWorkersStub func(lager.Logger) ([]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

	IsVersionCompatibleStub func(lager.Logger, *version.Version) 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 lager.Logger, arg2 worker.WorkerSpec, arg3 atc.VersionedResourceTypes) ([]worker.Worker, error)

func (*FakeWorker) AllSatisfyingArgsForCall 

func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (lager.Logger, 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 (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) 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) 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) IsVersionCompatible 

func (fake *FakeWorker) IsVersionCompatible(arg1 lager.Logger, arg2 *version.Version) bool

func (*FakeWorker) IsVersionCompatibleArgsForCall 

func (fake *FakeWorker) IsVersionCompatibleArgsForCall(i int) (lager.Logger, *version.Version)

func (*FakeWorker) IsVersionCompatibleCallCount 

func (fake *FakeWorker) IsVersionCompatibleCallCount() int

func (*FakeWorker) IsVersionCompatibleReturns 

func (fake *FakeWorker) IsVersionCompatibleReturns(result1 bool)

func (*FakeWorker) IsVersionCompatibleReturnsOnCall 

func (fake *FakeWorker) IsVersionCompatibleReturnsOnCall(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(arg1 lager.Logger) ([]worker.Worker, error)

func (*FakeWorker) RunningWorkersArgsForCall 

func (fake *FakeWorker) RunningWorkersArgsForCall(i int) lager.Logger

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 lager.Logger, arg2 worker.WorkerSpec, arg3 atc.VersionedResourceTypes) (worker.Worker, error)

func (*FakeWorker) SatisfyingArgsForCall 

func (fake *FakeWorker) SatisfyingArgsForCall(i int) (lager.Logger, 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(lager.Logger) ([]worker.Worker, 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) Invocations 

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

func (*FakeWorkerProvider) RunningWorkers 

func (fake *FakeWorkerProvider) RunningWorkers(arg1 lager.Logger) ([]worker.Worker, error)

func (*FakeWorkerProvider) RunningWorkersArgsForCall 

func (fake *FakeWorkerProvider) RunningWorkersArgsForCall(i int) lager.Logger

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.