workerfakes

package
v3.3.4+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 31, 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.

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 {
	FindOrCreateContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, db.ResourceUser, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes) (worker.Container, 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, creds.VersionedResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(lager.Logger, worker.WorkerSpec, creds.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 creds.VersionedResourceTypes) ([]worker.Worker, error)

func (*FakeClient) AllSatisfyingArgsForCall

func (fake *FakeClient) AllSatisfyingArgsForCall(i int) (lager.Logger, worker.WorkerSpec, creds.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) 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) FindOrCreateContainer

func (fake *FakeClient) FindOrCreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 db.ResourceUser, arg5 db.ContainerOwner, arg6 db.ContainerMetadata, arg7 worker.ContainerSpec, arg8 creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeClient) FindOrCreateContainerCallCount

func (fake *FakeClient) FindOrCreateContainerCallCount() int

func (*FakeClient) FindOrCreateContainerReturns

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

func (*FakeClient) FindOrCreateContainerReturnsOnCall

func (fake *FakeClient) FindOrCreateContainerReturnsOnCall(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 creds.VersionedResourceTypes) (worker.Worker, error)

func (*FakeClient) SatisfyingArgsForCall

func (fake *FakeClient) SatisfyingArgsForCall(i int) (lager.Logger, worker.WorkerSpec, creds.VersionedResourceTypes)

func (*FakeClient) SatisfyingCallCount

func (fake *FakeClient) SatisfyingCallCount() int

func (*FakeClient) SatisfyingReturns

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

func (*FakeClient) SatisfyingReturnsOnCall

func (fake *FakeClient) SatisfyingReturnsOnCall(i int, result1 worker.Worker, result2 error)

type FakeContainer

type FakeContainer struct {
	HandleStub func() string

	StopStub func(kill bool) error

	InfoStub func() (garden.ContainerInfo, error)

	StreamInStub func(spec garden.StreamInSpec) error

	StreamOutStub func(spec garden.StreamOutSpec) (io.ReadCloser, error)

	CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error)

	CurrentCPULimitsStub func() (garden.CPULimits, error)

	CurrentDiskLimitsStub func() (garden.DiskLimits, error)

	CurrentMemoryLimitsStub func() (garden.MemoryLimits, error)

	NetInStub func(hostPort, containerPort uint32) (uint32, uint32, error)

	NetOutStub func(netOutRule garden.NetOutRule) error

	BulkNetOutStub func(netOutRules []garden.NetOutRule) error

	RunStub func(garden.ProcessSpec, garden.ProcessIO) (garden.Process, error)

	AttachStub func(processID string, io garden.ProcessIO) (garden.Process, error)

	MetricsStub func() (garden.Metrics, error)

	SetGraceTimeStub func(graceTime time.Duration) error

	PropertiesStub func() (garden.Properties, error)

	PropertyStub func(name string) (string, error)

	SetPropertyStub func(name string, value string) error

	RemovePropertyStub func(name string) error

	DestroyStub func() error

	VolumeMountsStub func() []worker.VolumeMount

	WorkerNameStub func() string

	MarkAsHijackedStub func() error
	// contains filtered or unexported fields
}

func (*FakeContainer) Attach

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

func (*FakeContainer) AttachArgsForCall

func (fake *FakeContainer) AttachArgsForCall(i int) (string, garden.ProcessIO)

func (*FakeContainer) AttachCallCount

func (fake *FakeContainer) AttachCallCount() int

func (*FakeContainer) AttachReturns

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

func (*FakeContainer) AttachReturnsOnCall

func (fake *FakeContainer) AttachReturnsOnCall(i int, result1 garden.Process, result2 error)

func (*FakeContainer) BulkNetOut

func (fake *FakeContainer) BulkNetOut(netOutRules []garden.NetOutRule) error

func (*FakeContainer) BulkNetOutArgsForCall

func (fake *FakeContainer) BulkNetOutArgsForCall(i int) []garden.NetOutRule

func (*FakeContainer) BulkNetOutCallCount

func (fake *FakeContainer) BulkNetOutCallCount() int

func (*FakeContainer) BulkNetOutReturns

func (fake *FakeContainer) BulkNetOutReturns(result1 error)

func (*FakeContainer) BulkNetOutReturnsOnCall

func (fake *FakeContainer) BulkNetOutReturnsOnCall(i int, result1 error)

func (*FakeContainer) CurrentBandwidthLimits

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

func (*FakeContainer) CurrentBandwidthLimitsCallCount

func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int

func (*FakeContainer) CurrentBandwidthLimitsReturns

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

func (*FakeContainer) CurrentBandwidthLimitsReturnsOnCall

func (fake *FakeContainer) CurrentBandwidthLimitsReturnsOnCall(i int, result1 garden.BandwidthLimits, result2 error)

func (*FakeContainer) CurrentCPULimits

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

func (*FakeContainer) CurrentCPULimitsCallCount

func (fake *FakeContainer) CurrentCPULimitsCallCount() int

func (*FakeContainer) CurrentCPULimitsReturns

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

func (*FakeContainer) CurrentCPULimitsReturnsOnCall

func (fake *FakeContainer) CurrentCPULimitsReturnsOnCall(i int, result1 garden.CPULimits, result2 error)

func (*FakeContainer) CurrentDiskLimits

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

func (*FakeContainer) CurrentDiskLimitsCallCount

func (fake *FakeContainer) CurrentDiskLimitsCallCount() int

func (*FakeContainer) CurrentDiskLimitsReturns

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

func (*FakeContainer) CurrentDiskLimitsReturnsOnCall

func (fake *FakeContainer) CurrentDiskLimitsReturnsOnCall(i int, result1 garden.DiskLimits, result2 error)

func (*FakeContainer) CurrentMemoryLimits

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

func (*FakeContainer) CurrentMemoryLimitsCallCount

func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int

func (*FakeContainer) CurrentMemoryLimitsReturns

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

func (*FakeContainer) CurrentMemoryLimitsReturnsOnCall

func (fake *FakeContainer) CurrentMemoryLimitsReturnsOnCall(i int, result1 garden.MemoryLimits, result2 error)

func (*FakeContainer) Destroy

func (fake *FakeContainer) Destroy() error

func (*FakeContainer) DestroyCallCount

func (fake *FakeContainer) DestroyCallCount() int

func (*FakeContainer) DestroyReturns

func (fake *FakeContainer) DestroyReturns(result1 error)

func (*FakeContainer) DestroyReturnsOnCall

func (fake *FakeContainer) DestroyReturnsOnCall(i int, result1 error)

func (*FakeContainer) Handle

func (fake *FakeContainer) Handle() string

func (*FakeContainer) HandleCallCount

func (fake *FakeContainer) HandleCallCount() int

func (*FakeContainer) HandleReturns

func (fake *FakeContainer) HandleReturns(result1 string)

func (*FakeContainer) HandleReturnsOnCall

func (fake *FakeContainer) HandleReturnsOnCall(i int, result1 string)

func (*FakeContainer) Info

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

func (*FakeContainer) InfoCallCount

func (fake *FakeContainer) InfoCallCount() int

func (*FakeContainer) InfoReturns

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

func (*FakeContainer) InfoReturnsOnCall

func (fake *FakeContainer) InfoReturnsOnCall(i int, result1 garden.ContainerInfo, result2 error)

func (*FakeContainer) Invocations

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

func (*FakeContainer) MarkAsHijacked

func (fake *FakeContainer) MarkAsHijacked() error

func (*FakeContainer) MarkAsHijackedCallCount

func (fake *FakeContainer) MarkAsHijackedCallCount() int

func (*FakeContainer) MarkAsHijackedReturns

func (fake *FakeContainer) MarkAsHijackedReturns(result1 error)

func (*FakeContainer) MarkAsHijackedReturnsOnCall

func (fake *FakeContainer) MarkAsHijackedReturnsOnCall(i int, result1 error)

func (*FakeContainer) Metrics

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

func (*FakeContainer) MetricsCallCount

func (fake *FakeContainer) MetricsCallCount() int

func (*FakeContainer) MetricsReturns

func (fake *FakeContainer) MetricsReturns(result1 garden.Metrics, result2 error)

func (*FakeContainer) MetricsReturnsOnCall

func (fake *FakeContainer) MetricsReturnsOnCall(i int, result1 garden.Metrics, result2 error)

func (*FakeContainer) NetIn

func (fake *FakeContainer) NetIn(hostPort uint32, containerPort uint32) (uint32, uint32, error)

func (*FakeContainer) NetInArgsForCall

func (fake *FakeContainer) NetInArgsForCall(i int) (uint32, uint32)

func (*FakeContainer) NetInCallCount

func (fake *FakeContainer) NetInCallCount() int

func (*FakeContainer) NetInReturns

func (fake *FakeContainer) NetInReturns(result1 uint32, result2 uint32, result3 error)

func (*FakeContainer) NetInReturnsOnCall

func (fake *FakeContainer) NetInReturnsOnCall(i int, result1 uint32, result2 uint32, result3 error)

func (*FakeContainer) NetOut

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

func (*FakeContainer) NetOutArgsForCall

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

func (*FakeContainer) NetOutCallCount

func (fake *FakeContainer) NetOutCallCount() int

func (*FakeContainer) NetOutReturns

func (fake *FakeContainer) NetOutReturns(result1 error)

func (*FakeContainer) NetOutReturnsOnCall

func (fake *FakeContainer) NetOutReturnsOnCall(i int, result1 error)

func (*FakeContainer) Properties

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

func (*FakeContainer) PropertiesCallCount

func (fake *FakeContainer) PropertiesCallCount() int

func (*FakeContainer) PropertiesReturns

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

func (*FakeContainer) PropertiesReturnsOnCall

func (fake *FakeContainer) PropertiesReturnsOnCall(i int, result1 garden.Properties, result2 error)

func (*FakeContainer) Property

func (fake *FakeContainer) Property(name string) (string, error)

func (*FakeContainer) PropertyArgsForCall

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

func (*FakeContainer) PropertyCallCount

func (fake *FakeContainer) PropertyCallCount() int

func (*FakeContainer) PropertyReturns

func (fake *FakeContainer) PropertyReturns(result1 string, result2 error)

func (*FakeContainer) PropertyReturnsOnCall

func (fake *FakeContainer) PropertyReturnsOnCall(i int, result1 string, result2 error)

func (*FakeContainer) RemoveProperty

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

func (*FakeContainer) RemovePropertyArgsForCall

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

func (*FakeContainer) RemovePropertyCallCount

func (fake *FakeContainer) RemovePropertyCallCount() int

func (*FakeContainer) RemovePropertyReturns

func (fake *FakeContainer) RemovePropertyReturns(result1 error)

func (*FakeContainer) RemovePropertyReturnsOnCall

func (fake *FakeContainer) RemovePropertyReturnsOnCall(i int, result1 error)

func (*FakeContainer) Run

func (*FakeContainer) RunArgsForCall

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

func (*FakeContainer) RunCallCount

func (fake *FakeContainer) RunCallCount() int

func (*FakeContainer) RunReturns

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

func (*FakeContainer) RunReturnsOnCall

func (fake *FakeContainer) RunReturnsOnCall(i int, result1 garden.Process, result2 error)

func (*FakeContainer) SetGraceTime

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

func (*FakeContainer) SetGraceTimeArgsForCall

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

func (*FakeContainer) SetGraceTimeCallCount

func (fake *FakeContainer) SetGraceTimeCallCount() int

func (*FakeContainer) SetGraceTimeReturns

func (fake *FakeContainer) SetGraceTimeReturns(result1 error)

func (*FakeContainer) SetGraceTimeReturnsOnCall

func (fake *FakeContainer) SetGraceTimeReturnsOnCall(i int, result1 error)

func (*FakeContainer) SetProperty

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

func (*FakeContainer) SetPropertyArgsForCall

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

func (*FakeContainer) SetPropertyCallCount

func (fake *FakeContainer) SetPropertyCallCount() int

func (*FakeContainer) SetPropertyReturns

func (fake *FakeContainer) SetPropertyReturns(result1 error)

func (*FakeContainer) SetPropertyReturnsOnCall

func (fake *FakeContainer) SetPropertyReturnsOnCall(i int, result1 error)

func (*FakeContainer) Stop

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

func (*FakeContainer) StopArgsForCall

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

func (*FakeContainer) StopCallCount

func (fake *FakeContainer) StopCallCount() int

func (*FakeContainer) StopReturns

func (fake *FakeContainer) StopReturns(result1 error)

func (*FakeContainer) StopReturnsOnCall

func (fake *FakeContainer) StopReturnsOnCall(i int, result1 error)

func (*FakeContainer) StreamIn

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

func (*FakeContainer) StreamInArgsForCall

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

func (*FakeContainer) StreamInCallCount

func (fake *FakeContainer) StreamInCallCount() int

func (*FakeContainer) StreamInReturns

func (fake *FakeContainer) StreamInReturns(result1 error)

func (*FakeContainer) StreamInReturnsOnCall

func (fake *FakeContainer) StreamInReturnsOnCall(i int, result1 error)

func (*FakeContainer) StreamOut

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

func (*FakeContainer) StreamOutArgsForCall

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

func (*FakeContainer) StreamOutCallCount

func (fake *FakeContainer) StreamOutCallCount() int

func (*FakeContainer) StreamOutReturns

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

func (*FakeContainer) StreamOutReturnsOnCall

func (fake *FakeContainer) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error)

func (*FakeContainer) VolumeMounts

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

func (*FakeContainer) VolumeMountsCallCount

func (fake *FakeContainer) VolumeMountsCallCount() int

func (*FakeContainer) VolumeMountsReturns

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

func (*FakeContainer) VolumeMountsReturnsOnCall

func (fake *FakeContainer) VolumeMountsReturnsOnCall(i int, result1 []worker.VolumeMount)

func (*FakeContainer) WorkerName

func (fake *FakeContainer) WorkerName() string

func (*FakeContainer) WorkerNameCallCount

func (fake *FakeContainer) WorkerNameCallCount() int

func (*FakeContainer) WorkerNameReturns

func (fake *FakeContainer) WorkerNameReturns(result1 string)

func (*FakeContainer) WorkerNameReturnsOnCall

func (fake *FakeContainer) WorkerNameReturnsOnCall(i int, result1 string)

type FakeContainerProvider

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

	FindOrCreateContainerStub func(logger lager.Logger, cancel <-chan os.Signal, resourceUser db.ResourceUser, owner db.ContainerOwner, delegate worker.ImageFetchingDelegate, metadata db.ContainerMetadata, spec worker.ContainerSpec, resourceTypes creds.VersionedResourceTypes) (worker.Container, error)
	// contains filtered or unexported fields
}

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

func (fake *FakeContainerProvider) FindOrCreateContainer(logger lager.Logger, cancel <-chan os.Signal, resourceUser db.ResourceUser, owner db.ContainerOwner, delegate worker.ImageFetchingDelegate, metadata db.ContainerMetadata, spec worker.ContainerSpec, resourceTypes creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateContainerCallCount

func (fake *FakeContainerProvider) FindOrCreateContainerCallCount() int

func (*FakeContainerProvider) FindOrCreateContainerReturns

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

func (*FakeContainerProvider) FindOrCreateContainerReturnsOnCall

func (fake *FakeContainerProvider) FindOrCreateContainerReturnsOnCall(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, cancel <-chan os.Signal, container db.CreatingContainer) (worker.FetchedImage, error)
	// contains filtered or unexported fields
}

func (*FakeImage) FetchForContainer

func (fake *FakeImage) FetchForContainer(logger lager.Logger, cancel <-chan os.Signal, container db.CreatingContainer) (worker.FetchedImage, error)

func (*FakeImage) FetchForContainerArgsForCall

func (fake *FakeImage) FetchForContainerArgsForCall(i int) (lager.Logger, <-chan os.Signal, db.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, delegate worker.ImageFetchingDelegate, resourceUser db.ResourceUser, resourceTypes creds.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, delegate worker.ImageFetchingDelegate, resourceUser db.ResourceUser, resourceTypes creds.VersionedResourceTypes) (worker.Image, error)

func (*FakeImageFactory) GetImageCallCount

func (fake *FakeImageFactory) GetImageCallCount() int

func (*FakeImageFactory) GetImageReturns

func (fake *FakeImageFactory) GetImageReturns(result1 worker.Image, result2 error)

func (*FakeImageFactory) GetImageReturnsOnCall

func (fake *FakeImageFactory) GetImageReturnsOnCall(i int, result1 worker.Image, result2 error)

func (*FakeImageFactory) Invocations

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

type FakeImageFetchingDelegate

type FakeImageFetchingDelegate struct {
	StdoutStub func() io.Writer

	StderrStub func() io.Writer

	ImageVersionDeterminedStub func(*db.UsedResourceCache) error
	// contains filtered or unexported fields
}

func (*FakeImageFetchingDelegate) ImageVersionDetermined

func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 *db.UsedResourceCache) error

func (*FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) *db.UsedResourceCache

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)

func (*FakeImageFetchingDelegate) Stdout

func (fake *FakeImageFetchingDelegate) Stdout() io.Writer

func (*FakeImageFetchingDelegate) StdoutCallCount

func (fake *FakeImageFetchingDelegate) StdoutCallCount() int

func (*FakeImageFetchingDelegate) StdoutReturns

func (fake *FakeImageFetchingDelegate) StdoutReturns(result1 io.Writer)

func (*FakeImageFetchingDelegate) StdoutReturnsOnCall

func (fake *FakeImageFetchingDelegate) StdoutReturnsOnCall(i int, result1 io.Writer)

type FakeInputSource

type FakeInputSource struct {
	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) 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 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

	InitializeResourceCacheStub func(*db.UsedResourceCache) error

	InitializeTaskCacheStub func(lager.Logger, int, string, string, bool) error

	CreateChildForContainerStub func(db.CreatingContainer, string) (db.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 db.CreatingContainer, arg2 string) (db.CreatingVolume, error)

func (*FakeVolume) CreateChildForContainerArgsForCall

func (fake *FakeVolume) CreateChildForContainerArgsForCall(i int) (db.CreatingContainer, string)

func (*FakeVolume) CreateChildForContainerCallCount

func (fake *FakeVolume) CreateChildForContainerCallCount() int

func (*FakeVolume) CreateChildForContainerReturns

func (fake *FakeVolume) CreateChildForContainerReturns(result1 db.CreatingVolume, result2 error)

func (*FakeVolume) CreateChildForContainerReturnsOnCall

func (fake *FakeVolume) CreateChildForContainerReturnsOnCall(i int, result1 db.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) InitializeResourceCache

func (fake *FakeVolume) InitializeResourceCache(arg1 *db.UsedResourceCache) error

func (*FakeVolume) InitializeResourceCacheArgsForCall

func (fake *FakeVolume) InitializeResourceCacheArgsForCall(i int) *db.UsedResourceCache

func (*FakeVolume) InitializeResourceCacheCallCount

func (fake *FakeVolume) InitializeResourceCacheCallCount() int

func (*FakeVolume) InitializeResourceCacheReturns

func (fake *FakeVolume) InitializeResourceCacheReturns(result1 error)

func (*FakeVolume) InitializeResourceCacheReturnsOnCall

func (fake *FakeVolume) InitializeResourceCacheReturnsOnCall(i int, result1 error)

func (*FakeVolume) InitializeTaskCache

func (fake *FakeVolume) InitializeTaskCache(arg1 lager.Logger, arg2 int, arg3 string, arg4 string, arg5 bool) error

func (*FakeVolume) InitializeTaskCacheArgsForCall

func (fake *FakeVolume) InitializeTaskCacheArgsForCall(i int) (lager.Logger, int, string, string, bool)

func (*FakeVolume) InitializeTaskCacheCallCount

func (fake *FakeVolume) InitializeTaskCacheCallCount() int

func (*FakeVolume) InitializeTaskCacheReturns

func (fake *FakeVolume) InitializeTaskCacheReturns(result1 error)

func (*FakeVolume) InitializeTaskCacheReturnsOnCall

func (fake *FakeVolume) InitializeTaskCacheReturnsOnCall(i int, result1 error)

func (*FakeVolume) Invocations

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

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 {
	FindOrCreateVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, int, string) (worker.Volume, error)

	FindOrCreateCOWVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, worker.Volume, int, string) (worker.Volume, error)

	FindOrCreateVolumeForBaseResourceTypeStub func(lager.Logger, worker.VolumeSpec, int, string) (worker.Volume, error)

	FindVolumeForResourceCacheStub func(lager.Logger, *db.UsedResourceCache) (worker.Volume, bool, error)

	FindVolumeForTaskCacheStub func(logger lager.Logger, teamID int, jobID int, stepName string, path string) (worker.Volume, bool, error)

	CreateVolumeForTaskCacheStub func(logger lager.Logger, volumeSpec worker.VolumeSpec, teamID int, jobID int, stepName string, path string) (worker.Volume, error)

	LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error)
	// contains filtered or unexported fields
}

func (*FakeVolumeClient) CreateVolumeForTaskCache

func (fake *FakeVolumeClient) CreateVolumeForTaskCache(logger lager.Logger, volumeSpec worker.VolumeSpec, teamID int, jobID int, stepName string, path string) (worker.Volume, error)

func (*FakeVolumeClient) CreateVolumeForTaskCacheArgsForCall

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, int, string, string)

func (*FakeVolumeClient) CreateVolumeForTaskCacheCallCount

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheCallCount() int

func (*FakeVolumeClient) CreateVolumeForTaskCacheReturns

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheReturns(result1 worker.Volume, result2 error)

func (*FakeVolumeClient) CreateVolumeForTaskCacheReturnsOnCall

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheReturnsOnCall(i int, result1 worker.Volume, result2 error)

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainer

func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 db.CreatingContainer, arg4 worker.Volume, arg5 int, arg6 string) (worker.Volume, error)

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall

func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, db.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 db.CreatingContainer, arg4 int, arg5 string) (worker.Volume, error)

func (*FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall

func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, db.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) FindVolumeForResourceCache

func (fake *FakeVolumeClient) FindVolumeForResourceCache(arg1 lager.Logger, arg2 *db.UsedResourceCache) (worker.Volume, bool, error)

func (*FakeVolumeClient) FindVolumeForResourceCacheArgsForCall

func (fake *FakeVolumeClient) FindVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *db.UsedResourceCache)

func (*FakeVolumeClient) FindVolumeForResourceCacheCallCount

func (fake *FakeVolumeClient) FindVolumeForResourceCacheCallCount() int

func (*FakeVolumeClient) FindVolumeForResourceCacheReturns

func (fake *FakeVolumeClient) FindVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeVolumeClient) FindVolumeForResourceCacheReturnsOnCall

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

func (*FakeVolumeClient) FindVolumeForTaskCache

func (fake *FakeVolumeClient) FindVolumeForTaskCache(logger lager.Logger, teamID int, jobID int, stepName string, path string) (worker.Volume, bool, error)

func (*FakeVolumeClient) FindVolumeForTaskCacheArgsForCall

func (fake *FakeVolumeClient) FindVolumeForTaskCacheArgsForCall(i int) (lager.Logger, int, int, string, string)

func (*FakeVolumeClient) FindVolumeForTaskCacheCallCount

func (fake *FakeVolumeClient) FindVolumeForTaskCacheCallCount() int

func (*FakeVolumeClient) FindVolumeForTaskCacheReturns

func (fake *FakeVolumeClient) FindVolumeForTaskCacheReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeVolumeClient) FindVolumeForTaskCacheReturnsOnCall

func (fake *FakeVolumeClient) FindVolumeForTaskCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 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 {
	FindOrCreateContainerStub func(lager.Logger, <-chan os.Signal, worker.ImageFetchingDelegate, db.ResourceUser, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes) (worker.Container, 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, creds.VersionedResourceTypes) (worker.Worker, error)

	AllSatisfyingStub func(lager.Logger, worker.WorkerSpec, creds.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

	FindVolumeForResourceCacheStub func(logger lager.Logger, resourceCache *db.UsedResourceCache) (worker.Volume, bool, error)

	FindVolumeForTaskCacheStub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error)
	// 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 creds.VersionedResourceTypes) ([]worker.Worker, error)

func (*FakeWorker) AllSatisfyingArgsForCall

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

func (fake *FakeWorker) FindOrCreateContainer(arg1 lager.Logger, arg2 <-chan os.Signal, arg3 worker.ImageFetchingDelegate, arg4 db.ResourceUser, arg5 db.ContainerOwner, arg6 db.ContainerMetadata, arg7 worker.ContainerSpec, arg8 creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeWorker) FindOrCreateContainerCallCount

func (fake *FakeWorker) FindOrCreateContainerCallCount() int

func (*FakeWorker) FindOrCreateContainerReturns

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

func (*FakeWorker) FindOrCreateContainerReturnsOnCall

func (fake *FakeWorker) FindOrCreateContainerReturnsOnCall(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) FindVolumeForResourceCache

func (fake *FakeWorker) FindVolumeForResourceCache(logger lager.Logger, resourceCache *db.UsedResourceCache) (worker.Volume, bool, error)

func (*FakeWorker) FindVolumeForResourceCacheArgsForCall

func (fake *FakeWorker) FindVolumeForResourceCacheArgsForCall(i int) (lager.Logger, *db.UsedResourceCache)

func (*FakeWorker) FindVolumeForResourceCacheCallCount

func (fake *FakeWorker) FindVolumeForResourceCacheCallCount() int

func (*FakeWorker) FindVolumeForResourceCacheReturns

func (fake *FakeWorker) FindVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeWorker) FindVolumeForResourceCacheReturnsOnCall

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

func (*FakeWorker) FindVolumeForTaskCache

func (fake *FakeWorker) FindVolumeForTaskCache(arg1 lager.Logger, arg2 int, arg3 int, arg4 string, arg5 string) (worker.Volume, bool, error)

func (*FakeWorker) FindVolumeForTaskCacheArgsForCall

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

func (*FakeWorker) FindVolumeForTaskCacheCallCount

func (fake *FakeWorker) FindVolumeForTaskCacheCallCount() int

func (*FakeWorker) FindVolumeForTaskCacheReturns

func (fake *FakeWorker) FindVolumeForTaskCacheReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeWorker) FindVolumeForTaskCacheReturnsOnCall

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

func (*FakeWorker) Invocations

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

func (*FakeWorker) IsOwnedByTeam

func (fake *FakeWorker) IsOwnedByTeam() bool

func (*FakeWorker) IsOwnedByTeamCallCount

func (fake *FakeWorker) IsOwnedByTeamCallCount() int

func (*FakeWorker) IsOwnedByTeamReturns

func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool)

func (*FakeWorker) IsOwnedByTeamReturnsOnCall

func (fake *FakeWorker) IsOwnedByTeamReturnsOnCall(i int, result1 bool)

func (*FakeWorker) 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 creds.VersionedResourceTypes) (worker.Worker, error)

func (*FakeWorker) SatisfyingArgsForCall

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

	FindWorkerForContainerByOwnerStub func(logger lager.Logger, teamID int, owner db.ContainerOwner) (worker.Worker, bool, error)
	// contains filtered or unexported fields
}

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

func (fake *FakeWorkerProvider) FindWorkerForContainerByOwner(logger lager.Logger, teamID int, owner db.ContainerOwner) (worker.Worker, bool, error)

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerArgsForCall

func (fake *FakeWorkerProvider) FindWorkerForContainerByOwnerArgsForCall(i int) (lager.Logger, int, db.ContainerOwner)

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerCallCount

func (fake *FakeWorkerProvider) FindWorkerForContainerByOwnerCallCount() int

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerReturns

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

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerReturnsOnCall

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

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

Jump to

Keyboard shortcuts

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