workerfakes

package
v0.0.0-...-2c9ee18 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2017 License: Apache-2.0 Imports: 13 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

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)

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

type FakeClient 

type FakeClient struct {
	FindOrCreateBuildContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string) (worker.Container, error)

	FindOrCreateResourceGetContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)

	FindOrCreateResourceCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

	FindOrCreateResourceTypeCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

	FindOrCreateContainerForIdentifierStub func(logger lager.Logger, id worker.Identifier, metadata worker.Metadata, containerSpec worker.ContainerSpec, resourceTypes atc.ResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceSources map[string]worker.ArtifactSource) (worker.Container, []string, error)

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

	FindContainerForIdentifierStub func(lager.Logger, worker.Identifier) (worker.Container, bool, error)

	FindContainerByHandleStub func(lager.Logger, string, int) (worker.Container, bool, error)

	ValidateResourceCheckVersionStub func(container db.SavedContainer) (bool, error)

	FindResourceTypeByPathStub func(path string) (atc.WorkerResourceType, bool)

	LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error)

	SatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) ([]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.ResourceTypes) ([]worker.Worker, error)

func (*FakeClient) AllSatisfyingArgsForCall 

func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)

func (*FakeClient) AllSatisfyingCallCount 

func (fake *FakeClient) AllSatisfyingCallCount() int

func (*FakeClient) AllSatisfyingReturns 

func (fake *FakeClient) AllSatisfyingReturns(result1 []worker.Worker, result2 error)

func (*FakeClient) FindContainerByHandle 

func (fake *FakeClient) FindContainerByHandle(arg1 lager.Logger, arg2 string, arg3 int) (worker.Container, bool, error)

func (*FakeClient) FindContainerByHandleArgsForCall 

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

func (*FakeClient) FindContainerByHandleCallCount 

func (fake *FakeClient) FindContainerByHandleCallCount() int

func (*FakeClient) FindContainerByHandleReturns 

func (fake *FakeClient) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)

func (*FakeClient) FindContainerForIdentifier 

func (fake *FakeClient) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)

func (*FakeClient) FindContainerForIdentifierArgsForCall 

func (fake *FakeClient) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)

func (*FakeClient) FindContainerForIdentifierCallCount 

func (fake *FakeClient) FindContainerForIdentifierCallCount() int

func (*FakeClient) FindContainerForIdentifierReturns 

func (fake *FakeClient) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)

func (*FakeClient) 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) FindOrCreateBuildContainer 

func (fake *FakeClient) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 worker.Identifier, arg5 worker.Metadata, arg6 worker.ContainerSpec, arg7 atc.ResourceTypes, arg8 map[string]string) (worker.Container, error)

func (*FakeClient) FindOrCreateBuildContainerArgsForCall 

func (fake *FakeClient) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string)

func (*FakeClient) FindOrCreateBuildContainerCallCount 

func (fake *FakeClient) FindOrCreateBuildContainerCallCount() int

func (*FakeClient) FindOrCreateBuildContainerReturns 

func (fake *FakeClient) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)

func (*FakeClient) FindOrCreateContainerForIdentifier 

func (fake *FakeClient) FindOrCreateContainerForIdentifier(logger lager.Logger, id worker.Identifier, metadata worker.Metadata, containerSpec worker.ContainerSpec, resourceTypes atc.ResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceSources map[string]worker.ArtifactSource) (worker.Container, []string, error)

func (*FakeClient) FindOrCreateContainerForIdentifierArgsForCall 

func (fake *FakeClient) FindOrCreateContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, worker.ImageFetchingDelegate, map[string]worker.ArtifactSource)

func (*FakeClient) FindOrCreateContainerForIdentifierCallCount 

func (fake *FakeClient) FindOrCreateContainerForIdentifierCallCount() int

func (*FakeClient) FindOrCreateContainerForIdentifierReturns 

func (fake *FakeClient) FindOrCreateContainerForIdentifierReturns(result1 worker.Container, result2 []string, result3 error)

func (*FakeClient) FindOrCreateResourceCheckContainer 

func (fake *FakeClient) FindOrCreateResourceCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

func (*FakeClient) FindOrCreateResourceCheckContainerArgsForCall 

func (fake *FakeClient) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, 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) FindOrCreateResourceGetContainer 

func (fake *FakeClient) FindOrCreateResourceGetContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)

func (*FakeClient) FindOrCreateResourceGetContainerArgsForCall 

func (fake *FakeClient) FindOrCreateResourceGetContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string, string, atc.Version, atc.Source, atc.Params)

func (*FakeClient) FindOrCreateResourceGetContainerCallCount 

func (fake *FakeClient) FindOrCreateResourceGetContainerCallCount() int

func (*FakeClient) FindOrCreateResourceGetContainerReturns 

func (fake *FakeClient) FindOrCreateResourceGetContainerReturns(result1 worker.Container, result2 error)

func (*FakeClient) FindOrCreateResourceTypeCheckContainer 

func (fake *FakeClient) FindOrCreateResourceTypeCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

func (*FakeClient) FindOrCreateResourceTypeCheckContainerArgsForCall 

func (fake *FakeClient) FindOrCreateResourceTypeCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, string, atc.Source)

func (*FakeClient) FindOrCreateResourceTypeCheckContainerCallCount 

func (fake *FakeClient) FindOrCreateResourceTypeCheckContainerCallCount() int

func (*FakeClient) FindOrCreateResourceTypeCheckContainerReturns 

func (fake *FakeClient) FindOrCreateResourceTypeCheckContainerReturns(result1 worker.Container, result2 error)

func (*FakeClient) FindOrCreateVolumeForResourceCache 

func (fake *FakeClient) FindOrCreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error)

func (*FakeClient) FindOrCreateVolumeForResourceCacheArgsForCall 

func (fake *FakeClient) FindOrCreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)

func (*FakeClient) FindOrCreateVolumeForResourceCacheCallCount 

func (fake *FakeClient) FindOrCreateVolumeForResourceCacheCallCount() int

func (*FakeClient) FindOrCreateVolumeForResourceCacheReturns 

func (fake *FakeClient) FindOrCreateVolumeForResourceCacheReturns(result1 worker.Volume, 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) 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) 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) 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) Satisfying 

func (fake *FakeClient) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)

func (*FakeClient) SatisfyingArgsForCall 

func (fake *FakeClient) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)

func (*FakeClient) SatisfyingCallCount 

func (fake *FakeClient) SatisfyingCallCount() int

func (*FakeClient) SatisfyingReturns 

func (fake *FakeClient) SatisfyingReturns(result1 worker.Worker, result2 error)

func (*FakeClient) ValidateResourceCheckVersion 

func (fake *FakeClient) ValidateResourceCheckVersion(container db.SavedContainer) (bool, error)

func (*FakeClient) ValidateResourceCheckVersionArgsForCall 

func (fake *FakeClient) ValidateResourceCheckVersionArgsForCall(i int) db.SavedContainer

func (*FakeClient) ValidateResourceCheckVersionCallCount 

func (fake *FakeClient) ValidateResourceCheckVersionCallCount() int

func (*FakeClient) ValidateResourceCheckVersionReturns 

func (fake *FakeClient) ValidateResourceCheckVersionReturns(result1 bool, 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) 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) CurrentBandwidthLimits 

func (fake *FakeContainer) CurrentBandwidthLimits() (garden.BandwidthLimits, error)

func (*FakeContainer) CurrentBandwidthLimitsCallCount 

func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int

func (*FakeContainer) CurrentBandwidthLimitsReturns 

func (fake *FakeContainer) CurrentBandwidthLimitsReturns(result1 garden.BandwidthLimits, result2 error)

func (*FakeContainer) CurrentCPULimits 

func (fake *FakeContainer) CurrentCPULimits() (garden.CPULimits, error)

func (*FakeContainer) CurrentCPULimitsCallCount 

func (fake *FakeContainer) CurrentCPULimitsCallCount() int

func (*FakeContainer) CurrentCPULimitsReturns 

func (fake *FakeContainer) CurrentCPULimitsReturns(result1 garden.CPULimits, result2 error)

func (*FakeContainer) CurrentDiskLimits 

func (fake *FakeContainer) CurrentDiskLimits() (garden.DiskLimits, error)

func (*FakeContainer) CurrentDiskLimitsCallCount 

func (fake *FakeContainer) CurrentDiskLimitsCallCount() int

func (*FakeContainer) CurrentDiskLimitsReturns 

func (fake *FakeContainer) CurrentDiskLimitsReturns(result1 garden.DiskLimits, result2 error)

func (*FakeContainer) CurrentMemoryLimits 

func (fake *FakeContainer) CurrentMemoryLimits() (garden.MemoryLimits, error)

func (*FakeContainer) CurrentMemoryLimitsCallCount 

func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int

func (*FakeContainer) CurrentMemoryLimitsReturns 

func (fake *FakeContainer) CurrentMemoryLimitsReturns(result1 garden.MemoryLimits, result2 error)

func (*FakeContainer) Destroy 

func (fake *FakeContainer) Destroy() error

func (*FakeContainer) DestroyCallCount 

func (fake *FakeContainer) DestroyCallCount() int

func (*FakeContainer) DestroyReturns 

func (fake *FakeContainer) DestroyReturns(result1 error)

func (*FakeContainer) Handle 

func (fake *FakeContainer) Handle() string

func (*FakeContainer) HandleCallCount 

func (fake *FakeContainer) HandleCallCount() int

func (*FakeContainer) HandleReturns 

func (fake *FakeContainer) HandleReturns(result1 string)

func (*FakeContainer) Info 

func (fake *FakeContainer) Info() (garden.ContainerInfo, error)

func (*FakeContainer) InfoCallCount 

func (fake *FakeContainer) InfoCallCount() int

func (*FakeContainer) InfoReturns 

func (fake *FakeContainer) InfoReturns(result1 garden.ContainerInfo, result2 error)

func (*FakeContainer) 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) 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) 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) NetOut 

func (fake *FakeContainer) NetOut(netOutRule garden.NetOutRule) error

func (*FakeContainer) NetOutArgsForCall 

func (fake *FakeContainer) NetOutArgsForCall(i int) garden.NetOutRule

func (*FakeContainer) NetOutCallCount 

func (fake *FakeContainer) NetOutCallCount() int

func (*FakeContainer) NetOutReturns 

func (fake *FakeContainer) NetOutReturns(result1 error)

func (*FakeContainer) Properties 

func (fake *FakeContainer) Properties() (garden.Properties, error)

func (*FakeContainer) PropertiesCallCount 

func (fake *FakeContainer) PropertiesCallCount() int

func (*FakeContainer) PropertiesReturns 

func (fake *FakeContainer) PropertiesReturns(result1 garden.Properties, result2 error)

func (*FakeContainer) 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) RemoveProperty 

func (fake *FakeContainer) RemoveProperty(name string) error

func (*FakeContainer) RemovePropertyArgsForCall 

func (fake *FakeContainer) RemovePropertyArgsForCall(i int) string

func (*FakeContainer) RemovePropertyCallCount 

func (fake *FakeContainer) RemovePropertyCallCount() int

func (*FakeContainer) RemovePropertyReturns 

func (fake *FakeContainer) RemovePropertyReturns(result1 error)

func (*FakeContainer) Run 

func (fake *FakeContainer) Run(arg1 garden.ProcessSpec, arg2 garden.ProcessIO) (garden.Process, error)

func (*FakeContainer) RunArgsForCall 

func (fake *FakeContainer) RunArgsForCall(i int) (garden.ProcessSpec, garden.ProcessIO)

func (*FakeContainer) RunCallCount 

func (fake *FakeContainer) RunCallCount() int

func (*FakeContainer) RunReturns 

func (fake *FakeContainer) RunReturns(result1 garden.Process, result2 error)

func (*FakeContainer) SetGraceTime 

func (fake *FakeContainer) SetGraceTime(graceTime time.Duration) error

func (*FakeContainer) SetGraceTimeArgsForCall 

func (fake *FakeContainer) SetGraceTimeArgsForCall(i int) time.Duration

func (*FakeContainer) SetGraceTimeCallCount 

func (fake *FakeContainer) SetGraceTimeCallCount() int

func (*FakeContainer) SetGraceTimeReturns 

func (fake *FakeContainer) SetGraceTimeReturns(result1 error)

func (*FakeContainer) SetProperty 

func (fake *FakeContainer) SetProperty(name string, value string) error

func (*FakeContainer) SetPropertyArgsForCall 

func (fake *FakeContainer) SetPropertyArgsForCall(i int) (string, string)

func (*FakeContainer) SetPropertyCallCount 

func (fake *FakeContainer) SetPropertyCallCount() int

func (*FakeContainer) SetPropertyReturns 

func (fake *FakeContainer) SetPropertyReturns(result1 error)

func (*FakeContainer) Stop 

func (fake *FakeContainer) Stop(kill bool) error

func (*FakeContainer) StopArgsForCall 

func (fake *FakeContainer) StopArgsForCall(i int) bool

func (*FakeContainer) StopCallCount 

func (fake *FakeContainer) StopCallCount() int

func (*FakeContainer) StopReturns 

func (fake *FakeContainer) StopReturns(result1 error)

func (*FakeContainer) StreamIn 

func (fake *FakeContainer) StreamIn(spec garden.StreamInSpec) error

func (*FakeContainer) StreamInArgsForCall 

func (fake *FakeContainer) StreamInArgsForCall(i int) garden.StreamInSpec

func (*FakeContainer) StreamInCallCount 

func (fake *FakeContainer) StreamInCallCount() int

func (*FakeContainer) StreamInReturns 

func (fake *FakeContainer) StreamInReturns(result1 error)

func (*FakeContainer) StreamOut 

func (fake *FakeContainer) StreamOut(spec garden.StreamOutSpec) (io.ReadCloser, error)

func (*FakeContainer) StreamOutArgsForCall 

func (fake *FakeContainer) StreamOutArgsForCall(i int) garden.StreamOutSpec

func (*FakeContainer) StreamOutCallCount 

func (fake *FakeContainer) StreamOutCallCount() int

func (*FakeContainer) StreamOutReturns 

func (fake *FakeContainer) StreamOutReturns(result1 io.ReadCloser, result2 error)

func (*FakeContainer) VolumeMounts 

func (fake *FakeContainer) VolumeMounts() []worker.VolumeMount

func (*FakeContainer) VolumeMountsCallCount 

func (fake *FakeContainer) VolumeMountsCallCount() int

func (*FakeContainer) VolumeMountsReturns 

func (fake *FakeContainer) VolumeMountsReturns(result1 []worker.VolumeMount)

func (*FakeContainer) WorkerName 

func (fake *FakeContainer) WorkerName() string

func (*FakeContainer) WorkerNameCallCount 

func (fake *FakeContainer) WorkerNameCallCount() int

func (*FakeContainer) WorkerNameReturns 

func (fake *FakeContainer) WorkerNameReturns(result1 string)

type FakeContainerProvider 

type FakeContainerProvider struct {
	FindContainerByHandleStub func(logger lager.Logger, handle string, teamID int) (worker.Container, bool, error)

	FindOrCreateBuildContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string) (worker.Container, error)

	FindOrCreateResourceCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

	FindOrCreateResourceTypeCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceTypeName string, source atc.Source) (worker.Container, error)

	FindOrCreateResourceGetContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceTypeName string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)
	// contains filtered or unexported fields
}

func (*FakeContainerProvider) FindContainerByHandle 

func (fake *FakeContainerProvider) FindContainerByHandle(logger lager.Logger, handle string, teamID int) (worker.Container, bool, error)

func (*FakeContainerProvider) FindContainerByHandleArgsForCall 

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

func (*FakeContainerProvider) FindContainerByHandleCallCount 

func (fake *FakeContainerProvider) FindContainerByHandleCallCount() int

func (*FakeContainerProvider) FindContainerByHandleReturns 

func (fake *FakeContainerProvider) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)

func (*FakeContainerProvider) FindOrCreateBuildContainer 

func (fake *FakeContainerProvider) FindOrCreateBuildContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateBuildContainerArgsForCall 

func (fake *FakeContainerProvider) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string)

func (*FakeContainerProvider) FindOrCreateBuildContainerCallCount 

func (fake *FakeContainerProvider) FindOrCreateBuildContainerCallCount() int

func (*FakeContainerProvider) FindOrCreateBuildContainerReturns 

func (fake *FakeContainerProvider) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)

func (*FakeContainerProvider) FindOrCreateResourceCheckContainer 

func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateResourceCheckContainerArgsForCall 

func (fake *FakeContainerProvider) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, 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) FindOrCreateResourceGetContainer 

func (fake *FakeContainerProvider) FindOrCreateResourceGetContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceTypeName string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateResourceGetContainerArgsForCall 

func (fake *FakeContainerProvider) FindOrCreateResourceGetContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string, string, atc.Version, atc.Source, atc.Params)

func (*FakeContainerProvider) FindOrCreateResourceGetContainerCallCount 

func (fake *FakeContainerProvider) FindOrCreateResourceGetContainerCallCount() int

func (*FakeContainerProvider) FindOrCreateResourceGetContainerReturns 

func (fake *FakeContainerProvider) FindOrCreateResourceGetContainerReturns(result1 worker.Container, result2 error)

func (*FakeContainerProvider) FindOrCreateResourceTypeCheckContainer 

func (fake *FakeContainerProvider) FindOrCreateResourceTypeCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceTypeName string, source atc.Source) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateResourceTypeCheckContainerArgsForCall 

func (fake *FakeContainerProvider) FindOrCreateResourceTypeCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, string, atc.Source)

func (*FakeContainerProvider) FindOrCreateResourceTypeCheckContainerCallCount 

func (fake *FakeContainerProvider) FindOrCreateResourceTypeCheckContainerCallCount() int

func (*FakeContainerProvider) FindOrCreateResourceTypeCheckContainerReturns 

func (fake *FakeContainerProvider) FindOrCreateResourceTypeCheckContainerReturns(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) Invocations 

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

type FakeGardenConnectionFactory 

type FakeGardenConnectionFactory struct {
	BuildConnectionStub func() connection.Connection
	// contains filtered or unexported fields
}

func (*FakeGardenConnectionFactory) BuildConnection 

func (fake *FakeGardenConnectionFactory) BuildConnection() connection.Connection

func (*FakeGardenConnectionFactory) BuildConnectionCallCount 

func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int

func (*FakeGardenConnectionFactory) BuildConnectionReturns 

func (fake *FakeGardenConnectionFactory) BuildConnectionReturns(result1 connection.Connection)

func (*FakeGardenConnectionFactory) Invocations 

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

type FakeGardenWorkerDB 

type FakeGardenWorkerDB struct {
	CreateContainerToBeRemovedStub func(container db.Container, maxLifetime time.Duration, volumeHandles []string) (db.SavedContainer, error)

	UpdateContainerTTLToBeRemovedStub func(container db.Container, maxLifetime time.Duration) (db.SavedContainer, error)

	GetContainerStub func(handle string) (db.SavedContainer, bool, error)

	ReapContainerStub func(string) error

	GetPipelineByIDStub func(pipelineID int) (db.SavedPipeline, error)

	AcquireVolumeCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error)

	AcquireContainerCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error)
	// contains filtered or unexported fields
}

func (*FakeGardenWorkerDB) AcquireContainerCreatingLock 

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

func (*FakeGardenWorkerDB) AcquireContainerCreatingLockArgsForCall 

func (fake *FakeGardenWorkerDB) AcquireContainerCreatingLockArgsForCall(i int) (lager.Logger, int)

func (*FakeGardenWorkerDB) AcquireContainerCreatingLockCallCount 

func (fake *FakeGardenWorkerDB) AcquireContainerCreatingLockCallCount() int

func (*FakeGardenWorkerDB) AcquireContainerCreatingLockReturns 

func (fake *FakeGardenWorkerDB) AcquireContainerCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)

func (*FakeGardenWorkerDB) AcquireVolumeCreatingLock 

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

func (*FakeGardenWorkerDB) AcquireVolumeCreatingLockArgsForCall 

func (fake *FakeGardenWorkerDB) AcquireVolumeCreatingLockArgsForCall(i int) (lager.Logger, int)

func (*FakeGardenWorkerDB) AcquireVolumeCreatingLockCallCount 

func (fake *FakeGardenWorkerDB) AcquireVolumeCreatingLockCallCount() int

func (*FakeGardenWorkerDB) AcquireVolumeCreatingLockReturns 

func (fake *FakeGardenWorkerDB) AcquireVolumeCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)

func (*FakeGardenWorkerDB) CreateContainerToBeRemoved 

func (fake *FakeGardenWorkerDB) CreateContainerToBeRemoved(container db.Container, maxLifetime time.Duration, volumeHandles []string) (db.SavedContainer, error)

func (*FakeGardenWorkerDB) CreateContainerToBeRemovedArgsForCall 

func (fake *FakeGardenWorkerDB) CreateContainerToBeRemovedArgsForCall(i int) (db.Container, time.Duration, []string)

func (*FakeGardenWorkerDB) CreateContainerToBeRemovedCallCount 

func (fake *FakeGardenWorkerDB) CreateContainerToBeRemovedCallCount() int

func (*FakeGardenWorkerDB) CreateContainerToBeRemovedReturns 

func (fake *FakeGardenWorkerDB) CreateContainerToBeRemovedReturns(result1 db.SavedContainer, result2 error)

func (*FakeGardenWorkerDB) GetContainer 

func (fake *FakeGardenWorkerDB) GetContainer(handle string) (db.SavedContainer, bool, error)

func (*FakeGardenWorkerDB) GetContainerArgsForCall 

func (fake *FakeGardenWorkerDB) GetContainerArgsForCall(i int) string

func (*FakeGardenWorkerDB) GetContainerCallCount 

func (fake *FakeGardenWorkerDB) GetContainerCallCount() int

func (*FakeGardenWorkerDB) GetContainerReturns 

func (fake *FakeGardenWorkerDB) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)

func (*FakeGardenWorkerDB) GetPipelineByID 

func (fake *FakeGardenWorkerDB) GetPipelineByID(pipelineID int) (db.SavedPipeline, error)

func (*FakeGardenWorkerDB) GetPipelineByIDArgsForCall 

func (fake *FakeGardenWorkerDB) GetPipelineByIDArgsForCall(i int) int

func (*FakeGardenWorkerDB) GetPipelineByIDCallCount 

func (fake *FakeGardenWorkerDB) GetPipelineByIDCallCount() int

func (*FakeGardenWorkerDB) GetPipelineByIDReturns 

func (fake *FakeGardenWorkerDB) GetPipelineByIDReturns(result1 db.SavedPipeline, result2 error)

func (*FakeGardenWorkerDB) Invocations 

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

func (*FakeGardenWorkerDB) ReapContainer 

func (fake *FakeGardenWorkerDB) ReapContainer(arg1 string) error

func (*FakeGardenWorkerDB) ReapContainerArgsForCall 

func (fake *FakeGardenWorkerDB) ReapContainerArgsForCall(i int) string

func (*FakeGardenWorkerDB) ReapContainerCallCount 

func (fake *FakeGardenWorkerDB) ReapContainerCallCount() int

func (*FakeGardenWorkerDB) ReapContainerReturns 

func (fake *FakeGardenWorkerDB) ReapContainerReturns(result1 error)

func (*FakeGardenWorkerDB) UpdateContainerTTLToBeRemoved 

func (fake *FakeGardenWorkerDB) UpdateContainerTTLToBeRemoved(container db.Container, maxLifetime time.Duration) (db.SavedContainer, error)

func (*FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedArgsForCall 

func (fake *FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedArgsForCall(i int) (db.Container, time.Duration)

func (*FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedCallCount 

func (fake *FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedCallCount() int

func (*FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedReturns 

func (fake *FakeGardenWorkerDB) UpdateContainerTTLToBeRemovedReturns(result1 db.SavedContainer, result2 error)

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

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

type FakeImageFactory 

type FakeImageFactory struct {
	GetImageStub func(lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, atc.ResourceTypes) (worker.Image, error)
	// contains filtered or unexported fields
}

func (*FakeImageFactory) GetImage 

func (fake *FakeImageFactory) GetImage(arg1 lager.Logger, arg2 worker.Worker, arg3 worker.VolumeClient, arg4 worker.ImageSpec, arg5 int, arg6 <-chan os.Signal, arg7 worker.ImageFetchingDelegate, arg8 worker.Identifier, arg9 worker.Metadata, arg10 atc.ResourceTypes) (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, worker.Identifier, worker.Metadata, atc.ResourceTypes)

func (*FakeImageFactory) GetImageCallCount 

func (fake *FakeImageFactory) GetImageCallCount() int

func (*FakeImageFactory) GetImageReturns 

func (fake *FakeImageFactory) GetImageReturns(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) 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)

type FakeSaveWorkerDB 

type FakeSaveWorkerDB struct {
	SaveWorkerStub func(db.WorkerInfo, time.Duration) (db.SavedWorker, error)
	// contains filtered or unexported fields
}

func (*FakeSaveWorkerDB) Invocations 

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

func (*FakeSaveWorkerDB) SaveWorker 

func (fake *FakeSaveWorkerDB) SaveWorker(arg1 db.WorkerInfo, arg2 time.Duration) (db.SavedWorker, error)

func (*FakeSaveWorkerDB) SaveWorkerArgsForCall 

func (fake *FakeSaveWorkerDB) SaveWorkerArgsForCall(i int) (db.WorkerInfo, time.Duration)

func (*FakeSaveWorkerDB) SaveWorkerCallCount 

func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int

func (*FakeSaveWorkerDB) SaveWorkerReturns 

func (fake *FakeSaveWorkerDB) SaveWorkerReturns(result1 db.SavedWorker, result2 error)

type FakeSleeper 

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

func (fake *FakeVolume) Path() string

func (*FakeVolume) PathCallCount 

func (fake *FakeVolume) PathCallCount() int

func (*FakeVolume) PathReturns 

func (fake *FakeVolume) PathReturns(result1 string)

func (*FakeVolume) Properties 

func (fake *FakeVolume) Properties() (baggageclaim.VolumeProperties, error)

func (*FakeVolume) PropertiesCallCount 

func (fake *FakeVolume) PropertiesCallCount() int

func (*FakeVolume) PropertiesReturns 

func (fake *FakeVolume) PropertiesReturns(result1 baggageclaim.VolumeProperties, result2 error)

func (*FakeVolume) 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) 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) 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)

type FakeVolumeClient 

type FakeVolumeClient struct {
	FindOrCreateVolumeForResourceCacheStub func(lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache) (worker.Volume, error)

	FindOrCreateVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, dbng.CreatingContainer, 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) 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) 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) 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) FindOrCreateVolumeForResourceCache 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCache(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 *dbng.UsedResourceCache) (worker.Volume, error)

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCacheArgsForCall 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCacheCallCount 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCacheCallCount() int

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCacheReturns 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCacheReturns(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)

type FakeVolumeFactoryDB 

type FakeVolumeFactoryDB struct {
	ReapVolumeStub func(handle string) error
	// contains filtered or unexported fields
}

func (*FakeVolumeFactoryDB) Invocations 

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

func (*FakeVolumeFactoryDB) ReapVolume 

func (fake *FakeVolumeFactoryDB) ReapVolume(handle string) error

func (*FakeVolumeFactoryDB) ReapVolumeArgsForCall 

func (fake *FakeVolumeFactoryDB) ReapVolumeArgsForCall(i int) string

func (*FakeVolumeFactoryDB) ReapVolumeCallCount 

func (fake *FakeVolumeFactoryDB) ReapVolumeCallCount() int

func (*FakeVolumeFactoryDB) ReapVolumeReturns 

func (fake *FakeVolumeFactoryDB) ReapVolumeReturns(result1 error)

type FakeWorker 

type FakeWorker struct {
	FindOrCreateBuildContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string) (worker.Container, error)

	FindOrCreateResourceGetContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)

	FindOrCreateResourceCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

	FindOrCreateResourceTypeCheckContainerStub func(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

	FindOrCreateContainerForIdentifierStub func(logger lager.Logger, id worker.Identifier, metadata worker.Metadata, containerSpec worker.ContainerSpec, resourceTypes atc.ResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceSources map[string]worker.ArtifactSource) (worker.Container, []string, error)

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

	FindContainerForIdentifierStub func(lager.Logger, worker.Identifier) (worker.Container, bool, error)

	FindContainerByHandleStub func(lager.Logger, string, int) (worker.Container, bool, error)

	ValidateResourceCheckVersionStub func(container db.SavedContainer) (bool, error)

	FindResourceTypeByPathStub func(path string) (atc.WorkerResourceType, bool)

	LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error)

	SatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(worker.WorkerSpec, atc.ResourceTypes) ([]worker.Worker, error)

	RunningWorkersStub func() ([]worker.Worker, error)

	GetWorkerStub func(workerName string) (worker.Worker, error)

	ActiveContainersStub func() int

	DescriptionStub func() string

	NameStub func() string

	AddressStub 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) Address 

func (fake *FakeWorker) Address() *string

func (*FakeWorker) AddressCallCount 

func (fake *FakeWorker) AddressCallCount() int

func (*FakeWorker) AddressReturns 

func (fake *FakeWorker) AddressReturns(result1 *string)

func (*FakeWorker) AllSatisfying 

func (fake *FakeWorker) AllSatisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) ([]worker.Worker, error)

func (*FakeWorker) AllSatisfyingArgsForCall 

func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)

func (*FakeWorker) AllSatisfyingCallCount 

func (fake *FakeWorker) AllSatisfyingCallCount() int

func (*FakeWorker) AllSatisfyingReturns 

func (fake *FakeWorker) AllSatisfyingReturns(result1 []worker.Worker, result2 error)

func (*FakeWorker) 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) FindContainerByHandle 

func (fake *FakeWorker) FindContainerByHandle(arg1 lager.Logger, arg2 string, arg3 int) (worker.Container, bool, error)

func (*FakeWorker) FindContainerByHandleArgsForCall 

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

func (*FakeWorker) FindContainerByHandleCallCount 

func (fake *FakeWorker) FindContainerByHandleCallCount() int

func (*FakeWorker) FindContainerByHandleReturns 

func (fake *FakeWorker) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error)

func (*FakeWorker) FindContainerForIdentifier 

func (fake *FakeWorker) FindContainerForIdentifier(arg1 lager.Logger, arg2 worker.Identifier) (worker.Container, bool, error)

func (*FakeWorker) FindContainerForIdentifierArgsForCall 

func (fake *FakeWorker) FindContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier)

func (*FakeWorker) FindContainerForIdentifierCallCount 

func (fake *FakeWorker) FindContainerForIdentifierCallCount() int

func (*FakeWorker) FindContainerForIdentifierReturns 

func (fake *FakeWorker) FindContainerForIdentifierReturns(result1 worker.Container, result2 bool, result3 error)

func (*FakeWorker) 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) FindOrCreateBuildContainer 

func (fake *FakeWorker) FindOrCreateBuildContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 worker.Identifier, arg5 worker.Metadata, arg6 worker.ContainerSpec, arg7 atc.ResourceTypes, arg8 map[string]string) (worker.Container, error)

func (*FakeWorker) FindOrCreateBuildContainerArgsForCall 

func (fake *FakeWorker) FindOrCreateBuildContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string)

func (*FakeWorker) FindOrCreateBuildContainerCallCount 

func (fake *FakeWorker) FindOrCreateBuildContainerCallCount() int

func (*FakeWorker) FindOrCreateBuildContainerReturns 

func (fake *FakeWorker) FindOrCreateBuildContainerReturns(result1 worker.Container, result2 error)

func (*FakeWorker) FindOrCreateContainerForIdentifier 

func (fake *FakeWorker) FindOrCreateContainerForIdentifier(logger lager.Logger, id worker.Identifier, metadata worker.Metadata, containerSpec worker.ContainerSpec, resourceTypes atc.ResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceSources map[string]worker.ArtifactSource) (worker.Container, []string, error)

func (*FakeWorker) FindOrCreateContainerForIdentifierArgsForCall 

func (fake *FakeWorker) FindOrCreateContainerForIdentifierArgsForCall(i int) (lager.Logger, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, worker.ImageFetchingDelegate, map[string]worker.ArtifactSource)

func (*FakeWorker) FindOrCreateContainerForIdentifierCallCount 

func (fake *FakeWorker) FindOrCreateContainerForIdentifierCallCount() int

func (*FakeWorker) FindOrCreateContainerForIdentifierReturns 

func (fake *FakeWorker) FindOrCreateContainerForIdentifierReturns(result1 worker.Container, result2 []string, result3 error)

func (*FakeWorker) FindOrCreateResourceCheckContainer 

func (fake *FakeWorker) FindOrCreateResourceCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

func (*FakeWorker) FindOrCreateResourceCheckContainerArgsForCall 

func (fake *FakeWorker) FindOrCreateResourceCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, 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) FindOrCreateResourceGetContainer 

func (fake *FakeWorker) FindOrCreateResourceGetContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, outputPaths map[string]string, resourceType string, version atc.Version, source atc.Source, params atc.Params) (worker.Container, error)

func (*FakeWorker) FindOrCreateResourceGetContainerArgsForCall 

func (fake *FakeWorker) FindOrCreateResourceGetContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, map[string]string, string, atc.Version, atc.Source, atc.Params)

func (*FakeWorker) FindOrCreateResourceGetContainerCallCount 

func (fake *FakeWorker) FindOrCreateResourceGetContainerCallCount() int

func (*FakeWorker) FindOrCreateResourceGetContainerReturns 

func (fake *FakeWorker) FindOrCreateResourceGetContainerReturns(result1 worker.Container, result2 error)

func (*FakeWorker) FindOrCreateResourceTypeCheckContainer 

func (fake *FakeWorker) FindOrCreateResourceTypeCheckContainer(logger lager.Logger, cancel <-chan os.Signal, delegate worker.ImageFetchingDelegate, id worker.Identifier, metadata worker.Metadata, spec worker.ContainerSpec, resourceTypes atc.ResourceTypes, resourceType string, source atc.Source) (worker.Container, error)

func (*FakeWorker) FindOrCreateResourceTypeCheckContainerArgsForCall 

func (fake *FakeWorker) FindOrCreateResourceTypeCheckContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, worker.Identifier, worker.Metadata, worker.ContainerSpec, atc.ResourceTypes, string, atc.Source)

func (*FakeWorker) FindOrCreateResourceTypeCheckContainerCallCount 

func (fake *FakeWorker) FindOrCreateResourceTypeCheckContainerCallCount() int

func (*FakeWorker) FindOrCreateResourceTypeCheckContainerReturns 

func (fake *FakeWorker) FindOrCreateResourceTypeCheckContainerReturns(result1 worker.Container, result2 error)

func (*FakeWorker) FindOrCreateVolumeForResourceCache 

func (fake *FakeWorker) FindOrCreateVolumeForResourceCache(logger lager.Logger, vs worker.VolumeSpec, resourceCache *dbng.UsedResourceCache) (worker.Volume, error)

func (*FakeWorker) FindOrCreateVolumeForResourceCacheArgsForCall 

func (fake *FakeWorker) FindOrCreateVolumeForResourceCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, *dbng.UsedResourceCache)

func (*FakeWorker) FindOrCreateVolumeForResourceCacheCallCount 

func (fake *FakeWorker) FindOrCreateVolumeForResourceCacheCallCount() int

func (*FakeWorker) FindOrCreateVolumeForResourceCacheReturns 

func (fake *FakeWorker) FindOrCreateVolumeForResourceCacheReturns(result1 worker.Volume, 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) 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) 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) 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) 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) 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) 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) Satisfying 

func (fake *FakeWorker) Satisfying(arg1 worker.WorkerSpec, arg2 atc.ResourceTypes) (worker.Worker, error)

func (*FakeWorker) SatisfyingArgsForCall 

func (fake *FakeWorker) SatisfyingArgsForCall(i int) (worker.WorkerSpec, atc.ResourceTypes)

func (*FakeWorker) SatisfyingCallCount 

func (fake *FakeWorker) SatisfyingCallCount() int

func (*FakeWorker) SatisfyingReturns 

func (fake *FakeWorker) SatisfyingReturns(result1 worker.Worker, result2 error)

func (*FakeWorker) 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) 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) ValidateResourceCheckVersion 

func (fake *FakeWorker) ValidateResourceCheckVersion(container db.SavedContainer) (bool, error)

func (*FakeWorker) ValidateResourceCheckVersionArgsForCall 

func (fake *FakeWorker) ValidateResourceCheckVersionArgsForCall(i int) db.SavedContainer

func (*FakeWorker) ValidateResourceCheckVersionCallCount 

func (fake *FakeWorker) ValidateResourceCheckVersionCallCount() int

func (*FakeWorker) ValidateResourceCheckVersionReturns 

func (fake *FakeWorker) ValidateResourceCheckVersionReturns(result1 bool, result2 error)

type FakeWorkerDB 

type FakeWorkerDB struct {
	WorkersStub func() ([]db.SavedWorker, error)

	GetWorkerStub func(string) (db.SavedWorker, bool, error)

	CreateContainerToBeRemovedStub func(container db.Container, maxLifetime time.Duration, volumeHandles []string) (db.SavedContainer, error)

	UpdateContainerTTLToBeRemovedStub func(container db.Container, maxLifetime time.Duration) (db.SavedContainer, error)

	GetContainerStub func(string) (db.SavedContainer, bool, error)

	FindContainerByIdentifierStub func(db.ContainerIdentifier) (db.SavedContainer, bool, error)

	ReapContainerStub func(handle string) error

	GetPipelineByIDStub func(pipelineID int) (db.SavedPipeline, error)

	ReapVolumeStub func(handle string) error

	AcquireVolumeCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error)

	AcquireContainerCreatingLockStub func(lager.Logger, int) (lock.Lock, bool, error)
	// contains filtered or unexported fields
}

func (*FakeWorkerDB) AcquireContainerCreatingLock 

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

func (*FakeWorkerDB) AcquireContainerCreatingLockArgsForCall 

func (fake *FakeWorkerDB) AcquireContainerCreatingLockArgsForCall(i int) (lager.Logger, int)

func (*FakeWorkerDB) AcquireContainerCreatingLockCallCount 

func (fake *FakeWorkerDB) AcquireContainerCreatingLockCallCount() int

func (*FakeWorkerDB) AcquireContainerCreatingLockReturns 

func (fake *FakeWorkerDB) AcquireContainerCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)

func (*FakeWorkerDB) AcquireVolumeCreatingLock 

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

func (*FakeWorkerDB) AcquireVolumeCreatingLockArgsForCall 

func (fake *FakeWorkerDB) AcquireVolumeCreatingLockArgsForCall(i int) (lager.Logger, int)

func (*FakeWorkerDB) AcquireVolumeCreatingLockCallCount 

func (fake *FakeWorkerDB) AcquireVolumeCreatingLockCallCount() int

func (*FakeWorkerDB) AcquireVolumeCreatingLockReturns 

func (fake *FakeWorkerDB) AcquireVolumeCreatingLockReturns(result1 lock.Lock, result2 bool, result3 error)

func (*FakeWorkerDB) CreateContainerToBeRemoved 

func (fake *FakeWorkerDB) CreateContainerToBeRemoved(container db.Container, maxLifetime time.Duration, volumeHandles []string) (db.SavedContainer, error)

func (*FakeWorkerDB) CreateContainerToBeRemovedArgsForCall 

func (fake *FakeWorkerDB) CreateContainerToBeRemovedArgsForCall(i int) (db.Container, time.Duration, []string)

func (*FakeWorkerDB) CreateContainerToBeRemovedCallCount 

func (fake *FakeWorkerDB) CreateContainerToBeRemovedCallCount() int

func (*FakeWorkerDB) CreateContainerToBeRemovedReturns 

func (fake *FakeWorkerDB) CreateContainerToBeRemovedReturns(result1 db.SavedContainer, result2 error)

func (*FakeWorkerDB) FindContainerByIdentifier 

func (fake *FakeWorkerDB) FindContainerByIdentifier(arg1 db.ContainerIdentifier) (db.SavedContainer, bool, error)

func (*FakeWorkerDB) FindContainerByIdentifierArgsForCall 

func (fake *FakeWorkerDB) FindContainerByIdentifierArgsForCall(i int) db.ContainerIdentifier

func (*FakeWorkerDB) FindContainerByIdentifierCallCount 

func (fake *FakeWorkerDB) FindContainerByIdentifierCallCount() int

func (*FakeWorkerDB) FindContainerByIdentifierReturns 

func (fake *FakeWorkerDB) FindContainerByIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)

func (*FakeWorkerDB) GetContainer 

func (fake *FakeWorkerDB) GetContainer(arg1 string) (db.SavedContainer, bool, error)

func (*FakeWorkerDB) GetContainerArgsForCall 

func (fake *FakeWorkerDB) GetContainerArgsForCall(i int) string

func (*FakeWorkerDB) GetContainerCallCount 

func (fake *FakeWorkerDB) GetContainerCallCount() int

func (*FakeWorkerDB) GetContainerReturns 

func (fake *FakeWorkerDB) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)

func (*FakeWorkerDB) GetPipelineByID 

func (fake *FakeWorkerDB) GetPipelineByID(pipelineID int) (db.SavedPipeline, error)

func (*FakeWorkerDB) GetPipelineByIDArgsForCall 

func (fake *FakeWorkerDB) GetPipelineByIDArgsForCall(i int) int

func (*FakeWorkerDB) GetPipelineByIDCallCount 

func (fake *FakeWorkerDB) GetPipelineByIDCallCount() int

func (*FakeWorkerDB) GetPipelineByIDReturns 

func (fake *FakeWorkerDB) GetPipelineByIDReturns(result1 db.SavedPipeline, result2 error)

func (*FakeWorkerDB) GetWorker 

func (fake *FakeWorkerDB) GetWorker(arg1 string) (db.SavedWorker, bool, error)

func (*FakeWorkerDB) GetWorkerArgsForCall 

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

func (*FakeWorkerDB) GetWorkerCallCount 

func (fake *FakeWorkerDB) GetWorkerCallCount() int

func (*FakeWorkerDB) GetWorkerReturns 

func (fake *FakeWorkerDB) GetWorkerReturns(result1 db.SavedWorker, result2 bool, result3 error)

func (*FakeWorkerDB) Invocations 

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

func (*FakeWorkerDB) ReapContainer 

func (fake *FakeWorkerDB) ReapContainer(handle string) error

func (*FakeWorkerDB) ReapContainerArgsForCall 

func (fake *FakeWorkerDB) ReapContainerArgsForCall(i int) string

func (*FakeWorkerDB) ReapContainerCallCount 

func (fake *FakeWorkerDB) ReapContainerCallCount() int

func (*FakeWorkerDB) ReapContainerReturns 

func (fake *FakeWorkerDB) ReapContainerReturns(result1 error)

func (*FakeWorkerDB) ReapVolume 

func (fake *FakeWorkerDB) ReapVolume(handle string) error

func (*FakeWorkerDB) ReapVolumeArgsForCall 

func (fake *FakeWorkerDB) ReapVolumeArgsForCall(i int) string

func (*FakeWorkerDB) ReapVolumeCallCount 

func (fake *FakeWorkerDB) ReapVolumeCallCount() int

func (*FakeWorkerDB) ReapVolumeReturns 

func (fake *FakeWorkerDB) ReapVolumeReturns(result1 error)

func (*FakeWorkerDB) UpdateContainerTTLToBeRemoved 

func (fake *FakeWorkerDB) UpdateContainerTTLToBeRemoved(container db.Container, maxLifetime time.Duration) (db.SavedContainer, error)

func (*FakeWorkerDB) UpdateContainerTTLToBeRemovedArgsForCall 

func (fake *FakeWorkerDB) UpdateContainerTTLToBeRemovedArgsForCall(i int) (db.Container, time.Duration)

func (*FakeWorkerDB) UpdateContainerTTLToBeRemovedCallCount 

func (fake *FakeWorkerDB) UpdateContainerTTLToBeRemovedCallCount() int

func (*FakeWorkerDB) UpdateContainerTTLToBeRemovedReturns 

func (fake *FakeWorkerDB) UpdateContainerTTLToBeRemovedReturns(result1 db.SavedContainer, result2 error)

func (*FakeWorkerDB) Workers 

func (fake *FakeWorkerDB) Workers() ([]db.SavedWorker, error)

func (*FakeWorkerDB) WorkersCallCount 

func (fake *FakeWorkerDB) WorkersCallCount() int

func (*FakeWorkerDB) WorkersReturns 

func (fake *FakeWorkerDB) WorkersReturns(result1 []db.SavedWorker, result2 error)

type FakeWorkerProvider 

type FakeWorkerProvider struct {
	RunningWorkersStub func() ([]worker.Worker, error)

	GetWorkerStub func(string) (worker.Worker, bool, error)

	FindContainerForIdentifierStub func(worker.Identifier) (db.SavedContainer, bool, error)

	GetContainerStub func(string) (db.SavedContainer, bool, error)

	ReapContainerStub func(string) error
	// contains filtered or unexported fields
}

func (*FakeWorkerProvider) FindContainerForIdentifier 

func (fake *FakeWorkerProvider) FindContainerForIdentifier(arg1 worker.Identifier) (db.SavedContainer, bool, error)

func (*FakeWorkerProvider) FindContainerForIdentifierArgsForCall 

func (fake *FakeWorkerProvider) FindContainerForIdentifierArgsForCall(i int) worker.Identifier

func (*FakeWorkerProvider) FindContainerForIdentifierCallCount 

func (fake *FakeWorkerProvider) FindContainerForIdentifierCallCount() int

func (*FakeWorkerProvider) FindContainerForIdentifierReturns 

func (fake *FakeWorkerProvider) FindContainerForIdentifierReturns(result1 db.SavedContainer, result2 bool, result3 error)

func (*FakeWorkerProvider) GetContainer 

func (fake *FakeWorkerProvider) GetContainer(arg1 string) (db.SavedContainer, bool, error)

func (*FakeWorkerProvider) GetContainerArgsForCall 

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

func (*FakeWorkerProvider) GetContainerCallCount 

func (fake *FakeWorkerProvider) GetContainerCallCount() int

func (*FakeWorkerProvider) GetContainerReturns 

func (fake *FakeWorkerProvider) GetContainerReturns(result1 db.SavedContainer, result2 bool, result3 error)

func (*FakeWorkerProvider) 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) Invocations 

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

func (*FakeWorkerProvider) ReapContainer 

func (fake *FakeWorkerProvider) ReapContainer(arg1 string) error

func (*FakeWorkerProvider) ReapContainerArgsForCall 

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

func (*FakeWorkerProvider) ReapContainerCallCount 

func (fake *FakeWorkerProvider) ReapContainerCallCount() int

func (*FakeWorkerProvider) ReapContainerReturns 

func (fake *FakeWorkerProvider) ReapContainerReturns(result1 error)

func (*FakeWorkerProvider) 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)

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.