workerfakes

package
v6.7.3-0...-1f455d7 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

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 {
	GetStreamInP2pUrlStub func(context.Context, string) (string, error)

	StreamInStub func(context.Context, string, baggageclaim.Encoding, io.Reader) error
	// contains filtered or unexported fields
}

func (*FakeArtifactDestination) GetStreamInP2pUrl 

func (fake *FakeArtifactDestination) GetStreamInP2pUrl(arg1 context.Context, arg2 string) (string, error)

func (*FakeArtifactDestination) GetStreamInP2pUrlArgsForCall 

func (fake *FakeArtifactDestination) GetStreamInP2pUrlArgsForCall(i int) (context.Context, string)

func (*FakeArtifactDestination) GetStreamInP2pUrlCallCount 

func (fake *FakeArtifactDestination) GetStreamInP2pUrlCallCount() int

func (*FakeArtifactDestination) GetStreamInP2pUrlCalls 

func (fake *FakeArtifactDestination) GetStreamInP2pUrlCalls(stub func(context.Context, string) (string, error))

func (*FakeArtifactDestination) GetStreamInP2pUrlReturns 

func (fake *FakeArtifactDestination) GetStreamInP2pUrlReturns(result1 string, result2 error)

func (*FakeArtifactDestination) GetStreamInP2pUrlReturnsOnCall 

func (fake *FakeArtifactDestination) GetStreamInP2pUrlReturnsOnCall(i int, result1 string, result2 error)

func (*FakeArtifactDestination) Invocations 

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

func (*FakeArtifactDestination) StreamIn 

func (fake *FakeArtifactDestination) StreamIn(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding, arg4 io.Reader) error

func (*FakeArtifactDestination) StreamInArgsForCall 

func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (context.Context, string, baggageclaim.Encoding, io.Reader)

func (*FakeArtifactDestination) StreamInCallCount 

func (fake *FakeArtifactDestination) StreamInCallCount() int

func (*FakeArtifactDestination) StreamInCalls 

func (fake *FakeArtifactDestination) StreamInCalls(stub func(context.Context, string, baggageclaim.Encoding, io.Reader) error)

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 {
	ExistsOnStub func(lager.Logger, worker.Worker) (worker.Volume, bool, error)
	// contains filtered or unexported fields
}

func (*FakeArtifactSource) ExistsOn 

func (fake *FakeArtifactSource) ExistsOn(arg1 lager.Logger, arg2 worker.Worker) (worker.Volume, bool, error)

func (*FakeArtifactSource) ExistsOnArgsForCall 

func (fake *FakeArtifactSource) ExistsOnArgsForCall(i int) (lager.Logger, worker.Worker)

func (*FakeArtifactSource) ExistsOnCallCount 

func (fake *FakeArtifactSource) ExistsOnCallCount() int

func (*FakeArtifactSource) ExistsOnCalls 

func (fake *FakeArtifactSource) ExistsOnCalls(stub func(lager.Logger, worker.Worker) (worker.Volume, bool, error))

func (*FakeArtifactSource) ExistsOnReturns 

func (fake *FakeArtifactSource) ExistsOnReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeArtifactSource) ExistsOnReturnsOnCall 

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

func (*FakeArtifactSource) Invocations 

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

type FakeBindMountSource 

type FakeBindMountSource struct {
	VolumeOnStub func(worker.Worker) (garden.BindMount, bool, error)
	// contains filtered or unexported fields
}

func (*FakeBindMountSource) Invocations 

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

func (*FakeBindMountSource) VolumeOn 

func (fake *FakeBindMountSource) VolumeOn(arg1 worker.Worker) (garden.BindMount, bool, error)

func (*FakeBindMountSource) VolumeOnArgsForCall 

func (fake *FakeBindMountSource) VolumeOnArgsForCall(i int) worker.Worker

func (*FakeBindMountSource) VolumeOnCallCount 

func (fake *FakeBindMountSource) VolumeOnCallCount() int

func (*FakeBindMountSource) VolumeOnCalls 

func (fake *FakeBindMountSource) VolumeOnCalls(stub func(worker.Worker) (garden.BindMount, bool, error))

func (*FakeBindMountSource) VolumeOnReturns 

func (fake *FakeBindMountSource) VolumeOnReturns(result1 garden.BindMount, result2 bool, result3 error)

func (*FakeBindMountSource) VolumeOnReturnsOnCall 

func (fake *FakeBindMountSource) VolumeOnReturnsOnCall(i int, result1 garden.BindMount, result2 bool, result3 error)

type FakeClient 

type FakeClient struct {
	CreateVolumeStub func(lager.Logger, worker.VolumeSpec, worker.WorkerSpec, db.VolumeType) (worker.Volume, error)

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

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

	RunCheckStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource, time.Duration) (worker.CheckResult, error)

	RunGetStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, db.UsedResourceCache, resource.Resource) (worker.GetResult, error)

	RunPutStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource) (worker.PutResult, error)

	RunTaskStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, lock.LockFactory) (worker.TaskResult, error)

	StreamFileFromArtifactStub func(context.Context, lager.Logger, runtime.Artifact, string) (io.ReadCloser, error)
	// contains filtered or unexported fields
}

func (*FakeClient) CreateVolume 

func (fake *FakeClient) CreateVolume(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 worker.WorkerSpec, arg4 db.VolumeType) (worker.Volume, error)

func (*FakeClient) CreateVolumeArgsForCall 

func (fake *FakeClient) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, worker.WorkerSpec, db.VolumeType)

func (*FakeClient) CreateVolumeCallCount 

func (fake *FakeClient) CreateVolumeCallCount() int

func (*FakeClient) CreateVolumeCalls 

func (fake *FakeClient) CreateVolumeCalls(stub func(lager.Logger, worker.VolumeSpec, worker.WorkerSpec, db.VolumeType) (worker.Volume, error))

func (*FakeClient) CreateVolumeReturns 

func (fake *FakeClient) CreateVolumeReturns(result1 worker.Volume, result2 error)

func (*FakeClient) CreateVolumeReturnsOnCall 

func (fake *FakeClient) CreateVolumeReturnsOnCall(i int, result1 worker.Volume, result2 error)

func (*FakeClient) FindContainer 

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

func (*FakeClient) FindContainerArgsForCall 

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

func (*FakeClient) FindContainerCallCount 

func (fake *FakeClient) FindContainerCallCount() int

func (*FakeClient) FindContainerCalls 

func (fake *FakeClient) FindContainerCalls(stub func(lager.Logger, int, string) (worker.Container, bool, error))

func (*FakeClient) FindContainerReturns 

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

func (*FakeClient) FindContainerReturnsOnCall 

func (fake *FakeClient) FindContainerReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error)

func (*FakeClient) FindVolume 

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

func (*FakeClient) FindVolumeArgsForCall 

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

func (*FakeClient) FindVolumeCallCount 

func (fake *FakeClient) FindVolumeCallCount() int

func (*FakeClient) FindVolumeCalls 

func (fake *FakeClient) FindVolumeCalls(stub func(lager.Logger, int, string) (worker.Volume, bool, error))

func (*FakeClient) FindVolumeReturns 

func (fake *FakeClient) FindVolumeReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeClient) FindVolumeReturnsOnCall 

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

func (*FakeClient) Invocations 

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

func (*FakeClient) RunCheckStep 

func (fake *FakeClient) RunCheckStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 worker.ContainerSpec, arg5 worker.WorkerSpec, arg6 worker.ContainerPlacementStrategy, arg7 db.ContainerMetadata, arg8 runtime.ProcessSpec, arg9 runtime.StartingEventDelegate, arg10 resource.Resource, arg11 time.Duration) (worker.CheckResult, error)

func (*FakeClient) RunCheckStepArgsForCall 

func (fake *FakeClient) RunCheckStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource, time.Duration)

func (*FakeClient) RunCheckStepCallCount 

func (fake *FakeClient) RunCheckStepCallCount() int

func (*FakeClient) RunCheckStepCalls 

func (fake *FakeClient) RunCheckStepCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource, time.Duration) (worker.CheckResult, error))

func (*FakeClient) RunCheckStepReturns 

func (fake *FakeClient) RunCheckStepReturns(result1 worker.CheckResult, result2 error)

func (*FakeClient) RunCheckStepReturnsOnCall 

func (fake *FakeClient) RunCheckStepReturnsOnCall(i int, result1 worker.CheckResult, result2 error)

func (*FakeClient) RunGetStep 

func (fake *FakeClient) RunGetStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 worker.ContainerSpec, arg5 worker.WorkerSpec, arg6 worker.ContainerPlacementStrategy, arg7 db.ContainerMetadata, arg8 runtime.ProcessSpec, arg9 runtime.StartingEventDelegate, arg10 db.UsedResourceCache, arg11 resource.Resource) (worker.GetResult, error)

func (*FakeClient) RunGetStepArgsForCall 

func (fake *FakeClient) RunGetStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, db.UsedResourceCache, resource.Resource)

func (*FakeClient) RunGetStepCallCount 

func (fake *FakeClient) RunGetStepCallCount() int

func (*FakeClient) RunGetStepCalls 

func (fake *FakeClient) RunGetStepCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, db.UsedResourceCache, resource.Resource) (worker.GetResult, error))

func (*FakeClient) RunGetStepReturns 

func (fake *FakeClient) RunGetStepReturns(result1 worker.GetResult, result2 error)

func (*FakeClient) RunGetStepReturnsOnCall 

func (fake *FakeClient) RunGetStepReturnsOnCall(i int, result1 worker.GetResult, result2 error)

func (*FakeClient) RunPutStep 

func (fake *FakeClient) RunPutStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 worker.ContainerSpec, arg5 worker.WorkerSpec, arg6 worker.ContainerPlacementStrategy, arg7 db.ContainerMetadata, arg8 runtime.ProcessSpec, arg9 runtime.StartingEventDelegate, arg10 resource.Resource) (worker.PutResult, error)

func (*FakeClient) RunPutStepArgsForCall 

func (fake *FakeClient) RunPutStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource)

func (*FakeClient) RunPutStepCallCount 

func (fake *FakeClient) RunPutStepCallCount() int

func (*FakeClient) RunPutStepCalls 

func (fake *FakeClient) RunPutStepCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, resource.Resource) (worker.PutResult, error))

func (*FakeClient) RunPutStepReturns 

func (fake *FakeClient) RunPutStepReturns(result1 worker.PutResult, result2 error)

func (*FakeClient) RunPutStepReturnsOnCall 

func (fake *FakeClient) RunPutStepReturnsOnCall(i int, result1 worker.PutResult, result2 error)

func (*FakeClient) RunTaskStep 

func (fake *FakeClient) RunTaskStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 worker.ContainerSpec, arg5 worker.WorkerSpec, arg6 worker.ContainerPlacementStrategy, arg7 db.ContainerMetadata, arg8 runtime.ProcessSpec, arg9 runtime.StartingEventDelegate, arg10 lock.LockFactory) (worker.TaskResult, error)

func (*FakeClient) RunTaskStepArgsForCall 

func (fake *FakeClient) RunTaskStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, lock.LockFactory)

func (*FakeClient) RunTaskStepCallCount 

func (fake *FakeClient) RunTaskStepCallCount() int

func (*FakeClient) RunTaskStepCalls 

func (fake *FakeClient) RunTaskStepCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy, db.ContainerMetadata, runtime.ProcessSpec, runtime.StartingEventDelegate, lock.LockFactory) (worker.TaskResult, error))

func (*FakeClient) RunTaskStepReturns 

func (fake *FakeClient) RunTaskStepReturns(result1 worker.TaskResult, result2 error)

func (*FakeClient) RunTaskStepReturnsOnCall 

func (fake *FakeClient) RunTaskStepReturnsOnCall(i int, result1 worker.TaskResult, result2 error)

func (*FakeClient) StreamFileFromArtifact 

func (fake *FakeClient) StreamFileFromArtifact(arg1 context.Context, arg2 lager.Logger, arg3 runtime.Artifact, arg4 string) (io.ReadCloser, error)

func (*FakeClient) StreamFileFromArtifactArgsForCall 

func (fake *FakeClient) StreamFileFromArtifactArgsForCall(i int) (context.Context, lager.Logger, runtime.Artifact, string)

func (*FakeClient) StreamFileFromArtifactCallCount 

func (fake *FakeClient) StreamFileFromArtifactCallCount() int

func (*FakeClient) StreamFileFromArtifactCalls 

func (fake *FakeClient) StreamFileFromArtifactCalls(stub func(context.Context, lager.Logger, runtime.Artifact, string) (io.ReadCloser, error))

func (*FakeClient) StreamFileFromArtifactReturns 

func (fake *FakeClient) StreamFileFromArtifactReturns(result1 io.ReadCloser, result2 error)

func (*FakeClient) StreamFileFromArtifactReturnsOnCall 

func (fake *FakeClient) StreamFileFromArtifactReturnsOnCall(i int, result1 io.ReadCloser, result2 error)

type FakeContainer 

type FakeContainer struct {
	AttachStub func(context.Context, string, garden.ProcessIO) (garden.Process, error)

	BulkNetOutStub func([]garden.NetOutRule) error

	CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error)

	CurrentCPULimitsStub func() (garden.CPULimits, error)

	CurrentDiskLimitsStub func() (garden.DiskLimits, error)

	CurrentMemoryLimitsStub func() (garden.MemoryLimits, error)

	DestroyStub func() error

	HandleStub func() string

	InfoStub func() (garden.ContainerInfo, error)

	MetricsStub func() (garden.Metrics, error)

	NetInStub func(uint32, uint32) (uint32, uint32, error)

	NetOutStub func(garden.NetOutRule) error

	PropertiesStub func() (garden.Properties, error)

	PropertyStub func(string) (string, error)

	RemovePropertyStub func(string) error

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

	RunScriptStub func(context.Context, string, []string, []byte, interface{}, io.Writer, bool) error

	SetGraceTimeStub func(time.Duration) error

	SetPropertyStub func(string, string) error

	StopStub func(bool) error

	StreamInStub func(garden.StreamInSpec) error

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

	UpdateLastHijackStub func() error

	VolumeMountsStub func() []worker.VolumeMount

	WorkerNameStub func() string
	// contains filtered or unexported fields
}

func (*FakeContainer) Attach 

func (fake *FakeContainer) Attach(arg1 context.Context, arg2 string, arg3 garden.ProcessIO) (garden.Process, error)

func (*FakeContainer) AttachArgsForCall 

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

func (*FakeContainer) AttachCallCount 

func (fake *FakeContainer) AttachCallCount() int

func (*FakeContainer) AttachCalls 

func (fake *FakeContainer) AttachCalls(stub func(context.Context, string, garden.ProcessIO) (garden.Process, error))

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(arg1 []garden.NetOutRule) error

func (*FakeContainer) BulkNetOutArgsForCall 

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

func (*FakeContainer) BulkNetOutCallCount 

func (fake *FakeContainer) BulkNetOutCallCount() int

func (*FakeContainer) BulkNetOutCalls 

func (fake *FakeContainer) BulkNetOutCalls(stub func([]garden.NetOutRule) error)

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

func (fake *FakeContainer) CurrentBandwidthLimitsCalls(stub func() (garden.BandwidthLimits, error))

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

func (fake *FakeContainer) CurrentCPULimitsCalls(stub func() (garden.CPULimits, error))

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

func (fake *FakeContainer) CurrentDiskLimitsCalls(stub func() (garden.DiskLimits, error))

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

func (fake *FakeContainer) CurrentMemoryLimitsCalls(stub func() (garden.MemoryLimits, error))

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

func (fake *FakeContainer) DestroyCalls(stub func() error)

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

func (fake *FakeContainer) HandleCalls(stub func() string)

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

func (fake *FakeContainer) InfoCalls(stub func() (garden.ContainerInfo, error))

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

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

func (*FakeContainer) MetricsCallCount 

func (fake *FakeContainer) MetricsCallCount() int

func (*FakeContainer) MetricsCalls 

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

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(arg1 uint32, arg2 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) NetInCalls 

func (fake *FakeContainer) NetInCalls(stub func(uint32, uint32) (uint32, uint32, error))

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(arg1 garden.NetOutRule) error

func (*FakeContainer) NetOutArgsForCall 

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

func (*FakeContainer) NetOutCallCount 

func (fake *FakeContainer) NetOutCallCount() int

func (*FakeContainer) NetOutCalls 

func (fake *FakeContainer) NetOutCalls(stub func(garden.NetOutRule) error)

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

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

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(arg1 string) (string, error)

func (*FakeContainer) PropertyArgsForCall 

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

func (*FakeContainer) PropertyCallCount 

func (fake *FakeContainer) PropertyCallCount() int

func (*FakeContainer) PropertyCalls 

func (fake *FakeContainer) PropertyCalls(stub func(string) (string, error))

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(arg1 string) error

func (*FakeContainer) RemovePropertyArgsForCall 

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

func (*FakeContainer) RemovePropertyCallCount 

func (fake *FakeContainer) RemovePropertyCallCount() int

func (*FakeContainer) RemovePropertyCalls 

func (fake *FakeContainer) RemovePropertyCalls(stub func(string) error)

func (*FakeContainer) RemovePropertyReturns 

func (fake *FakeContainer) RemovePropertyReturns(result1 error)

func (*FakeContainer) RemovePropertyReturnsOnCall 

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

func (*FakeContainer) Run 

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

func (*FakeContainer) RunArgsForCall 

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

func (*FakeContainer) RunCallCount 

func (fake *FakeContainer) RunCallCount() int

func (*FakeContainer) RunCalls 

func (fake *FakeContainer) RunCalls(stub func(context.Context, garden.ProcessSpec, garden.ProcessIO) (garden.Process, error))

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

func (fake *FakeContainer) RunScript(arg1 context.Context, arg2 string, arg3 []string, arg4 []byte, arg5 interface{}, arg6 io.Writer, arg7 bool) error

func (*FakeContainer) RunScriptArgsForCall 

func (fake *FakeContainer) RunScriptArgsForCall(i int) (context.Context, string, []string, []byte, interface{}, io.Writer, bool)

func (*FakeContainer) RunScriptCallCount 

func (fake *FakeContainer) RunScriptCallCount() int

func (*FakeContainer) RunScriptCalls 

func (fake *FakeContainer) RunScriptCalls(stub func(context.Context, string, []string, []byte, interface{}, io.Writer, bool) error)

func (*FakeContainer) RunScriptReturns 

func (fake *FakeContainer) RunScriptReturns(result1 error)

func (*FakeContainer) RunScriptReturnsOnCall 

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

func (*FakeContainer) SetGraceTime 

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

func (*FakeContainer) SetGraceTimeArgsForCall 

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

func (*FakeContainer) SetGraceTimeCallCount 

func (fake *FakeContainer) SetGraceTimeCallCount() int

func (*FakeContainer) SetGraceTimeCalls 

func (fake *FakeContainer) SetGraceTimeCalls(stub func(time.Duration) error)

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(arg1 string, arg2 string) error

func (*FakeContainer) SetPropertyArgsForCall 

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

func (*FakeContainer) SetPropertyCallCount 

func (fake *FakeContainer) SetPropertyCallCount() int

func (*FakeContainer) SetPropertyCalls 

func (fake *FakeContainer) SetPropertyCalls(stub func(string, string) error)

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(arg1 bool) error

func (*FakeContainer) StopArgsForCall 

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

func (*FakeContainer) StopCallCount 

func (fake *FakeContainer) StopCallCount() int

func (*FakeContainer) StopCalls 

func (fake *FakeContainer) StopCalls(stub func(bool) error)

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(arg1 garden.StreamInSpec) error

func (*FakeContainer) StreamInArgsForCall 

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

func (*FakeContainer) StreamInCallCount 

func (fake *FakeContainer) StreamInCallCount() int

func (*FakeContainer) StreamInCalls 

func (fake *FakeContainer) StreamInCalls(stub func(garden.StreamInSpec) error)

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(arg1 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) StreamOutCalls 

func (fake *FakeContainer) StreamOutCalls(stub func(garden.StreamOutSpec) (io.ReadCloser, error))

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

func (fake *FakeContainer) UpdateLastHijack() error

func (*FakeContainer) UpdateLastHijackCallCount 

func (fake *FakeContainer) UpdateLastHijackCallCount() int

func (*FakeContainer) UpdateLastHijackCalls 

func (fake *FakeContainer) UpdateLastHijackCalls(stub func() error)

func (*FakeContainer) UpdateLastHijackReturns 

func (fake *FakeContainer) UpdateLastHijackReturns(result1 error)

func (*FakeContainer) UpdateLastHijackReturnsOnCall 

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

func (*FakeContainer) VolumeMounts 

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

func (*FakeContainer) VolumeMountsCallCount 

func (fake *FakeContainer) VolumeMountsCallCount() int

func (*FakeContainer) VolumeMountsCalls 

func (fake *FakeContainer) VolumeMountsCalls(stub func() []worker.VolumeMount)

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

func (fake *FakeContainer) WorkerNameCalls(stub func() string)

func (*FakeContainer) WorkerNameReturns 

func (fake *FakeContainer) WorkerNameReturns(result1 string)

func (*FakeContainer) WorkerNameReturnsOnCall 

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

type FakeContainerPlacementStrategy 

type FakeContainerPlacementStrategy struct {
	ChooseStub func(lager.Logger, []worker.Worker, worker.ContainerSpec) (worker.Worker, error)

	ModifiesActiveTasksStub func() bool
	// contains filtered or unexported fields
}

func (*FakeContainerPlacementStrategy) Choose 

func (fake *FakeContainerPlacementStrategy) Choose(arg1 lager.Logger, arg2 []worker.Worker, arg3 worker.ContainerSpec) (worker.Worker, error)

func (*FakeContainerPlacementStrategy) ChooseArgsForCall 

func (fake *FakeContainerPlacementStrategy) ChooseArgsForCall(i int) (lager.Logger, []worker.Worker, worker.ContainerSpec)

func (*FakeContainerPlacementStrategy) ChooseCallCount 

func (fake *FakeContainerPlacementStrategy) ChooseCallCount() int

func (*FakeContainerPlacementStrategy) ChooseCalls 

func (fake *FakeContainerPlacementStrategy) ChooseCalls(stub func(lager.Logger, []worker.Worker, worker.ContainerSpec) (worker.Worker, error))

func (*FakeContainerPlacementStrategy) ChooseReturns 

func (fake *FakeContainerPlacementStrategy) ChooseReturns(result1 worker.Worker, result2 error)

func (*FakeContainerPlacementStrategy) ChooseReturnsOnCall 

func (fake *FakeContainerPlacementStrategy) ChooseReturnsOnCall(i int, result1 worker.Worker, result2 error)

func (*FakeContainerPlacementStrategy) Invocations 

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

func (*FakeContainerPlacementStrategy) ModifiesActiveTasks 

func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasks() bool

func (*FakeContainerPlacementStrategy) ModifiesActiveTasksCallCount 

func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksCallCount() int

func (*FakeContainerPlacementStrategy) ModifiesActiveTasksCalls 

func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksCalls(stub func() bool)

func (*FakeContainerPlacementStrategy) ModifiesActiveTasksReturns 

func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksReturns(result1 bool)

func (*FakeContainerPlacementStrategy) ModifiesActiveTasksReturnsOnCall 

func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksReturnsOnCall(i int, result1 bool)

type FakeFetchSource 

type FakeFetchSource struct {
	CreateStub func(context.Context) (worker.GetResult, worker.Volume, error)

	FindStub func() (worker.GetResult, worker.Volume, bool, error)
	// contains filtered or unexported fields
}

func (*FakeFetchSource) Create 

func (fake *FakeFetchSource) Create(arg1 context.Context) (worker.GetResult, worker.Volume, error)

func (*FakeFetchSource) CreateArgsForCall 

func (fake *FakeFetchSource) CreateArgsForCall(i int) context.Context

func (*FakeFetchSource) CreateCallCount 

func (fake *FakeFetchSource) CreateCallCount() int

func (*FakeFetchSource) CreateCalls 

func (fake *FakeFetchSource) CreateCalls(stub func(context.Context) (worker.GetResult, worker.Volume, error))

func (*FakeFetchSource) CreateReturns 

func (fake *FakeFetchSource) CreateReturns(result1 worker.GetResult, result2 worker.Volume, result3 error)

func (*FakeFetchSource) CreateReturnsOnCall 

func (fake *FakeFetchSource) CreateReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 error)

func (*FakeFetchSource) Find 

func (fake *FakeFetchSource) Find() (worker.GetResult, worker.Volume, bool, error)

func (*FakeFetchSource) FindCallCount 

func (fake *FakeFetchSource) FindCallCount() int

func (*FakeFetchSource) FindCalls 

func (fake *FakeFetchSource) FindCalls(stub func() (worker.GetResult, worker.Volume, bool, error))

func (*FakeFetchSource) FindReturns 

func (fake *FakeFetchSource) FindReturns(result1 worker.GetResult, result2 worker.Volume, result3 bool, result4 error)

func (*FakeFetchSource) FindReturnsOnCall 

func (fake *FakeFetchSource) FindReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 bool, result4 error)

func (*FakeFetchSource) Invocations 

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

type FakeFetchSourceFactory 

type FakeFetchSourceFactory struct {
	NewFetchSourceStub func(lager.Logger, worker.Worker, db.ContainerOwner, db.UsedResourceCache, resource.Resource, worker.ContainerSpec, runtime.ProcessSpec, db.ContainerMetadata) worker.FetchSource
	// contains filtered or unexported fields
}

func (*FakeFetchSourceFactory) Invocations 

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

func (*FakeFetchSourceFactory) NewFetchSource 

func (fake *FakeFetchSourceFactory) NewFetchSource(arg1 lager.Logger, arg2 worker.Worker, arg3 db.ContainerOwner, arg4 db.UsedResourceCache, arg5 resource.Resource, arg6 worker.ContainerSpec, arg7 runtime.ProcessSpec, arg8 db.ContainerMetadata) worker.FetchSource

func (*FakeFetchSourceFactory) NewFetchSourceArgsForCall 

func (fake *FakeFetchSourceFactory) NewFetchSourceArgsForCall(i int) (lager.Logger, worker.Worker, db.ContainerOwner, db.UsedResourceCache, resource.Resource, worker.ContainerSpec, runtime.ProcessSpec, db.ContainerMetadata)

func (*FakeFetchSourceFactory) NewFetchSourceCallCount 

func (fake *FakeFetchSourceFactory) NewFetchSourceCallCount() int

func (*FakeFetchSourceFactory) NewFetchSourceCalls 

func (fake *FakeFetchSourceFactory) NewFetchSourceCalls(stub func(lager.Logger, worker.Worker, db.ContainerOwner, db.UsedResourceCache, resource.Resource, worker.ContainerSpec, runtime.ProcessSpec, db.ContainerMetadata) worker.FetchSource)

func (*FakeFetchSourceFactory) NewFetchSourceReturns 

func (fake *FakeFetchSourceFactory) NewFetchSourceReturns(result1 worker.FetchSource)

func (*FakeFetchSourceFactory) NewFetchSourceReturnsOnCall 

func (fake *FakeFetchSourceFactory) NewFetchSourceReturnsOnCall(i int, result1 worker.FetchSource)

type FakeFetcher 

type FakeFetcher struct {
	FetchStub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string) (worker.GetResult, worker.Volume, error)
	// contains filtered or unexported fields
}

func (*FakeFetcher) Fetch 

func (fake *FakeFetcher) Fetch(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerMetadata, arg4 worker.Worker, arg5 worker.ContainerSpec, arg6 runtime.ProcessSpec, arg7 resource.Resource, arg8 db.ContainerOwner, arg9 db.UsedResourceCache, arg10 string) (worker.GetResult, worker.Volume, error)

func (*FakeFetcher) FetchArgsForCall 

func (fake *FakeFetcher) FetchArgsForCall(i int) (context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string)

func (*FakeFetcher) FetchCallCount 

func (fake *FakeFetcher) FetchCallCount() int

func (*FakeFetcher) FetchCalls 

func (fake *FakeFetcher) FetchCalls(stub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string) (worker.GetResult, worker.Volume, error))

func (*FakeFetcher) FetchReturns 

func (fake *FakeFetcher) FetchReturns(result1 worker.GetResult, result2 worker.Volume, result3 error)

func (*FakeFetcher) FetchReturnsOnCall 

func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 error)

func (*FakeFetcher) Invocations 

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

type FakeImage 

type FakeImage struct {
	FetchForContainerStub func(context.Context, lager.Logger, db.CreatingContainer) (worker.FetchedImage, error)
	// contains filtered or unexported fields
}

func (*FakeImage) FetchForContainer 

func (fake *FakeImage) FetchForContainer(arg1 context.Context, arg2 lager.Logger, arg3 db.CreatingContainer) (worker.FetchedImage, error)

func (*FakeImage) FetchForContainerArgsForCall 

func (fake *FakeImage) FetchForContainerArgsForCall(i int) (context.Context, lager.Logger, db.CreatingContainer)

func (*FakeImage) FetchForContainerCallCount 

func (fake *FakeImage) FetchForContainerCallCount() int

func (*FakeImage) FetchForContainerCalls 

func (fake *FakeImage) FetchForContainerCalls(stub func(context.Context, lager.Logger, db.CreatingContainer) (worker.FetchedImage, error))

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(lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int) (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) (worker.Image, error)

func (*FakeImageFactory) GetImageArgsForCall 

func (fake *FakeImageFactory) GetImageArgsForCall(i int) (lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int)

func (*FakeImageFactory) GetImageCallCount 

func (fake *FakeImageFactory) GetImageCallCount() int

func (*FakeImageFactory) GetImageCalls 

func (fake *FakeImageFactory) GetImageCalls(stub func(lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int) (worker.Image, error))

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 FakeInputSource 

type FakeInputSource struct {
	DestinationPathStub func() string

	SourceStub func() worker.ArtifactSource
	// contains filtered or unexported fields
}

func (*FakeInputSource) DestinationPath 

func (fake *FakeInputSource) DestinationPath() string

func (*FakeInputSource) DestinationPathCallCount 

func (fake *FakeInputSource) DestinationPathCallCount() int

func (*FakeInputSource) DestinationPathCalls 

func (fake *FakeInputSource) DestinationPathCalls(stub func() string)

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

func (fake *FakeInputSource) SourceCalls(stub func() worker.ArtifactSource)

func (*FakeInputSource) SourceReturns 

func (fake *FakeInputSource) SourceReturns(result1 worker.ArtifactSource)

func (*FakeInputSource) SourceReturnsOnCall 

func (fake *FakeInputSource) SourceReturnsOnCall(i int, result1 worker.ArtifactSource)

type FakePool 

type FakePool struct {
	ContainerInWorkerStub func(lager.Logger, db.ContainerOwner, worker.WorkerSpec) (bool, error)

	FindOrChooseWorkerStub func(lager.Logger, worker.WorkerSpec) (worker.Worker, error)

	FindOrChooseWorkerForContainerStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy) (worker.Worker, error)
	// contains filtered or unexported fields
}

func (*FakePool) ContainerInWorker 

func (fake *FakePool) ContainerInWorker(arg1 lager.Logger, arg2 db.ContainerOwner, arg3 worker.WorkerSpec) (bool, error)

func (*FakePool) ContainerInWorkerArgsForCall 

func (fake *FakePool) ContainerInWorkerArgsForCall(i int) (lager.Logger, db.ContainerOwner, worker.WorkerSpec)

func (*FakePool) ContainerInWorkerCallCount 

func (fake *FakePool) ContainerInWorkerCallCount() int

func (*FakePool) ContainerInWorkerCalls 

func (fake *FakePool) ContainerInWorkerCalls(stub func(lager.Logger, db.ContainerOwner, worker.WorkerSpec) (bool, error))

func (*FakePool) ContainerInWorkerReturns 

func (fake *FakePool) ContainerInWorkerReturns(result1 bool, result2 error)

func (*FakePool) ContainerInWorkerReturnsOnCall 

func (fake *FakePool) ContainerInWorkerReturnsOnCall(i int, result1 bool, result2 error)

func (*FakePool) FindOrChooseWorker 

func (fake *FakePool) FindOrChooseWorker(arg1 lager.Logger, arg2 worker.WorkerSpec) (worker.Worker, error)

func (*FakePool) FindOrChooseWorkerArgsForCall 

func (fake *FakePool) FindOrChooseWorkerArgsForCall(i int) (lager.Logger, worker.WorkerSpec)

func (*FakePool) FindOrChooseWorkerCallCount 

func (fake *FakePool) FindOrChooseWorkerCallCount() int

func (*FakePool) FindOrChooseWorkerCalls 

func (fake *FakePool) FindOrChooseWorkerCalls(stub func(lager.Logger, worker.WorkerSpec) (worker.Worker, error))

func (*FakePool) FindOrChooseWorkerForContainer 

func (fake *FakePool) FindOrChooseWorkerForContainer(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 worker.ContainerSpec, arg5 worker.WorkerSpec, arg6 worker.ContainerPlacementStrategy) (worker.Worker, error)

func (*FakePool) FindOrChooseWorkerForContainerArgsForCall 

func (fake *FakePool) FindOrChooseWorkerForContainerArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy)

func (*FakePool) FindOrChooseWorkerForContainerCallCount 

func (fake *FakePool) FindOrChooseWorkerForContainerCallCount() int

func (*FakePool) FindOrChooseWorkerForContainerCalls 

func (fake *FakePool) FindOrChooseWorkerForContainerCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, worker.WorkerSpec, worker.ContainerPlacementStrategy) (worker.Worker, error))

func (*FakePool) FindOrChooseWorkerForContainerReturns 

func (fake *FakePool) FindOrChooseWorkerForContainerReturns(result1 worker.Worker, result2 error)

func (*FakePool) FindOrChooseWorkerForContainerReturnsOnCall 

func (fake *FakePool) FindOrChooseWorkerForContainerReturnsOnCall(i int, result1 worker.Worker, result2 error)

func (*FakePool) FindOrChooseWorkerReturns 

func (fake *FakePool) FindOrChooseWorkerReturns(result1 worker.Worker, result2 error)

func (*FakePool) FindOrChooseWorkerReturnsOnCall 

func (fake *FakePool) FindOrChooseWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error)

func (*FakePool) Invocations 

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

type FakeStreamableArtifactSource 

type FakeStreamableArtifactSource struct {
	ExistsOnStub func(lager.Logger, worker.Worker) (worker.Volume, bool, error)

	StreamFileStub func(context.Context, string) (io.ReadCloser, error)

	StreamToStub func(context.Context, worker.ArtifactDestination) error
	// contains filtered or unexported fields
}

func (*FakeStreamableArtifactSource) ExistsOn 

func (fake *FakeStreamableArtifactSource) ExistsOn(arg1 lager.Logger, arg2 worker.Worker) (worker.Volume, bool, error)

func (*FakeStreamableArtifactSource) ExistsOnArgsForCall 

func (fake *FakeStreamableArtifactSource) ExistsOnArgsForCall(i int) (lager.Logger, worker.Worker)

func (*FakeStreamableArtifactSource) ExistsOnCallCount 

func (fake *FakeStreamableArtifactSource) ExistsOnCallCount() int

func (*FakeStreamableArtifactSource) ExistsOnCalls 

func (fake *FakeStreamableArtifactSource) ExistsOnCalls(stub func(lager.Logger, worker.Worker) (worker.Volume, bool, error))

func (*FakeStreamableArtifactSource) ExistsOnReturns 

func (fake *FakeStreamableArtifactSource) ExistsOnReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeStreamableArtifactSource) ExistsOnReturnsOnCall 

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

func (*FakeStreamableArtifactSource) Invocations 

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

func (*FakeStreamableArtifactSource) StreamFile 

func (fake *FakeStreamableArtifactSource) StreamFile(arg1 context.Context, arg2 string) (io.ReadCloser, error)

func (*FakeStreamableArtifactSource) StreamFileArgsForCall 

func (fake *FakeStreamableArtifactSource) StreamFileArgsForCall(i int) (context.Context, string)

func (*FakeStreamableArtifactSource) StreamFileCallCount 

func (fake *FakeStreamableArtifactSource) StreamFileCallCount() int

func (*FakeStreamableArtifactSource) StreamFileCalls 

func (fake *FakeStreamableArtifactSource) StreamFileCalls(stub func(context.Context, string) (io.ReadCloser, error))

func (*FakeStreamableArtifactSource) StreamFileReturns 

func (fake *FakeStreamableArtifactSource) StreamFileReturns(result1 io.ReadCloser, result2 error)

func (*FakeStreamableArtifactSource) StreamFileReturnsOnCall 

func (fake *FakeStreamableArtifactSource) StreamFileReturnsOnCall(i int, result1 io.ReadCloser, result2 error)

func (*FakeStreamableArtifactSource) StreamTo 

func (fake *FakeStreamableArtifactSource) StreamTo(arg1 context.Context, arg2 worker.ArtifactDestination) error

func (*FakeStreamableArtifactSource) StreamToArgsForCall 

func (fake *FakeStreamableArtifactSource) StreamToArgsForCall(i int) (context.Context, worker.ArtifactDestination)

func (*FakeStreamableArtifactSource) StreamToCallCount 

func (fake *FakeStreamableArtifactSource) StreamToCallCount() int

func (*FakeStreamableArtifactSource) StreamToCalls 

func (fake *FakeStreamableArtifactSource) StreamToCalls(stub func(context.Context, worker.ArtifactDestination) error)

func (*FakeStreamableArtifactSource) StreamToReturns 

func (fake *FakeStreamableArtifactSource) StreamToReturns(result1 error)

func (*FakeStreamableArtifactSource) StreamToReturnsOnCall 

func (fake *FakeStreamableArtifactSource) StreamToReturnsOnCall(i int, result1 error)

type FakeVolume 

type FakeVolume struct {
	COWStrategyStub func() baggageclaim.COWStrategy

	CreateChildForContainerStub func(db.CreatingContainer, string) (db.CreatingVolume, error)

	DestroyStub func() error

	GetResourceCacheIDStub func() int

	GetStreamInP2pUrlStub func(context.Context, string) (string, error)

	HandleStub func() string

	InitializeArtifactStub func(string, int) (db.WorkerArtifact, error)

	InitializeResourceCacheStub func(db.UsedResourceCache) error

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

	PathStub func() string

	PropertiesStub func() (baggageclaim.VolumeProperties, error)

	SetPrivilegedStub func(bool) error

	SetPropertyStub func(string, string) error

	StreamInStub func(context.Context, string, baggageclaim.Encoding, io.Reader) error

	StreamOutStub func(context.Context, string, baggageclaim.Encoding) (io.ReadCloser, error)

	StreamP2pOutStub func(context.Context, string, string, baggageclaim.Encoding) error

	WorkerNameStub func() string
	// contains filtered or unexported fields
}

func (*FakeVolume) COWStrategy 

func (fake *FakeVolume) COWStrategy() baggageclaim.COWStrategy

func (*FakeVolume) COWStrategyCallCount 

func (fake *FakeVolume) COWStrategyCallCount() int

func (*FakeVolume) COWStrategyCalls 

func (fake *FakeVolume) COWStrategyCalls(stub func() baggageclaim.COWStrategy)

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

func (fake *FakeVolume) CreateChildForContainerCalls(stub func(db.CreatingContainer, string) (db.CreatingVolume, error))

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

func (fake *FakeVolume) DestroyCalls(stub func() error)

func (*FakeVolume) DestroyReturns 

func (fake *FakeVolume) DestroyReturns(result1 error)

func (*FakeVolume) DestroyReturnsOnCall 

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

func (*FakeVolume) GetResourceCacheID 

func (fake *FakeVolume) GetResourceCacheID() int

func (*FakeVolume) GetResourceCacheIDCallCount 

func (fake *FakeVolume) GetResourceCacheIDCallCount() int

func (*FakeVolume) GetResourceCacheIDCalls 

func (fake *FakeVolume) GetResourceCacheIDCalls(stub func() int)

func (*FakeVolume) GetResourceCacheIDReturns 

func (fake *FakeVolume) GetResourceCacheIDReturns(result1 int)

func (*FakeVolume) GetResourceCacheIDReturnsOnCall 

func (fake *FakeVolume) GetResourceCacheIDReturnsOnCall(i int, result1 int)

func (*FakeVolume) GetStreamInP2pUrl 

func (fake *FakeVolume) GetStreamInP2pUrl(arg1 context.Context, arg2 string) (string, error)

func (*FakeVolume) GetStreamInP2pUrlArgsForCall 

func (fake *FakeVolume) GetStreamInP2pUrlArgsForCall(i int) (context.Context, string)

func (*FakeVolume) GetStreamInP2pUrlCallCount 

func (fake *FakeVolume) GetStreamInP2pUrlCallCount() int

func (*FakeVolume) GetStreamInP2pUrlCalls 

func (fake *FakeVolume) GetStreamInP2pUrlCalls(stub func(context.Context, string) (string, error))

func (*FakeVolume) GetStreamInP2pUrlReturns 

func (fake *FakeVolume) GetStreamInP2pUrlReturns(result1 string, result2 error)

func (*FakeVolume) GetStreamInP2pUrlReturnsOnCall 

func (fake *FakeVolume) GetStreamInP2pUrlReturnsOnCall(i int, result1 string, result2 error)

func (*FakeVolume) Handle 

func (fake *FakeVolume) Handle() string

func (*FakeVolume) HandleCallCount 

func (fake *FakeVolume) HandleCallCount() int

func (*FakeVolume) HandleCalls 

func (fake *FakeVolume) HandleCalls(stub func() string)

func (*FakeVolume) HandleReturns 

func (fake *FakeVolume) HandleReturns(result1 string)

func (*FakeVolume) HandleReturnsOnCall 

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

func (*FakeVolume) InitializeArtifact 

func (fake *FakeVolume) InitializeArtifact(arg1 string, arg2 int) (db.WorkerArtifact, error)

func (*FakeVolume) InitializeArtifactArgsForCall 

func (fake *FakeVolume) InitializeArtifactArgsForCall(i int) (string, int)

func (*FakeVolume) InitializeArtifactCallCount 

func (fake *FakeVolume) InitializeArtifactCallCount() int

func (*FakeVolume) InitializeArtifactCalls 

func (fake *FakeVolume) InitializeArtifactCalls(stub func(string, int) (db.WorkerArtifact, error))

func (*FakeVolume) InitializeArtifactReturns 

func (fake *FakeVolume) InitializeArtifactReturns(result1 db.WorkerArtifact, result2 error)

func (*FakeVolume) InitializeArtifactReturnsOnCall 

func (fake *FakeVolume) InitializeArtifactReturnsOnCall(i int, result1 db.WorkerArtifact, result2 error)

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

func (fake *FakeVolume) InitializeResourceCacheCalls(stub func(db.UsedResourceCache) error)

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

func (fake *FakeVolume) InitializeTaskCacheCalls(stub func(lager.Logger, int, string, string, bool) error)

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

func (fake *FakeVolume) PathCalls(stub func() string)

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

func (fake *FakeVolume) PropertiesCalls(stub func() (baggageclaim.VolumeProperties, error))

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

func (fake *FakeVolume) SetPrivilegedCalls(stub func(bool) error)

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(arg1 string, arg2 string) error

func (*FakeVolume) SetPropertyArgsForCall 

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

func (*FakeVolume) SetPropertyCallCount 

func (fake *FakeVolume) SetPropertyCallCount() int

func (*FakeVolume) SetPropertyCalls 

func (fake *FakeVolume) SetPropertyCalls(stub func(string, string) error)

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(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding, arg4 io.Reader) error

func (*FakeVolume) StreamInArgsForCall 

func (fake *FakeVolume) StreamInArgsForCall(i int) (context.Context, string, baggageclaim.Encoding, io.Reader)

func (*FakeVolume) StreamInCallCount 

func (fake *FakeVolume) StreamInCallCount() int

func (*FakeVolume) StreamInCalls 

func (fake *FakeVolume) StreamInCalls(stub func(context.Context, string, baggageclaim.Encoding, io.Reader) error)

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(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding) (io.ReadCloser, error)

func (*FakeVolume) StreamOutArgsForCall 

func (fake *FakeVolume) StreamOutArgsForCall(i int) (context.Context, string, baggageclaim.Encoding)

func (*FakeVolume) StreamOutCallCount 

func (fake *FakeVolume) StreamOutCallCount() int

func (*FakeVolume) StreamOutCalls 

func (fake *FakeVolume) StreamOutCalls(stub func(context.Context, string, baggageclaim.Encoding) (io.ReadCloser, error))

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)

func (*FakeVolume) StreamP2pOut 

func (fake *FakeVolume) StreamP2pOut(arg1 context.Context, arg2 string, arg3 string, arg4 baggageclaim.Encoding) error

func (*FakeVolume) StreamP2pOutArgsForCall 

func (fake *FakeVolume) StreamP2pOutArgsForCall(i int) (context.Context, string, string, baggageclaim.Encoding)

func (*FakeVolume) StreamP2pOutCallCount 

func (fake *FakeVolume) StreamP2pOutCallCount() int

func (*FakeVolume) StreamP2pOutCalls 

func (fake *FakeVolume) StreamP2pOutCalls(stub func(context.Context, string, string, baggageclaim.Encoding) error)

func (*FakeVolume) StreamP2pOutReturns 

func (fake *FakeVolume) StreamP2pOutReturns(result1 error)

func (*FakeVolume) StreamP2pOutReturnsOnCall 

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

func (*FakeVolume) WorkerName 

func (fake *FakeVolume) WorkerName() string

func (*FakeVolume) WorkerNameCallCount 

func (fake *FakeVolume) WorkerNameCallCount() int

func (*FakeVolume) WorkerNameCalls 

func (fake *FakeVolume) WorkerNameCalls(stub func() string)

func (*FakeVolume) WorkerNameReturns 

func (fake *FakeVolume) WorkerNameReturns(result1 string)

func (*FakeVolume) WorkerNameReturnsOnCall 

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

type FakeVolumeClient 

type FakeVolumeClient struct {
	CreateVolumeStub func(lager.Logger, worker.VolumeSpec, int, string, db.VolumeType) (worker.Volume, error)

	CreateVolumeForTaskCacheStub func(lager.Logger, worker.VolumeSpec, int, int, string, 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)

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

	FindOrCreateVolumeForResourceCertsStub func(lager.Logger) (worker.Volume, bool, error)

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

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

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

func (*FakeVolumeClient) CreateVolume 

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

func (*FakeVolumeClient) CreateVolumeArgsForCall 

func (fake *FakeVolumeClient) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, string, db.VolumeType)

func (*FakeVolumeClient) CreateVolumeCallCount 

func (fake *FakeVolumeClient) CreateVolumeCallCount() int

func (*FakeVolumeClient) CreateVolumeCalls 

func (fake *FakeVolumeClient) CreateVolumeCalls(stub func(lager.Logger, worker.VolumeSpec, int, string, db.VolumeType) (worker.Volume, error))

func (*FakeVolumeClient) CreateVolumeForTaskCache 

func (fake *FakeVolumeClient) CreateVolumeForTaskCache(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 int, arg5 string, arg6 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) CreateVolumeForTaskCacheCalls 

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheCalls(stub func(lager.Logger, worker.VolumeSpec, int, int, string, string) (worker.Volume, error))

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

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

func (*FakeVolumeClient) CreateVolumeReturnsOnCall 

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

func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCalls(stub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, worker.Volume, int, string) (worker.Volume, error))

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

func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCalls(stub func(lager.Logger, worker.VolumeSpec, int, string) (worker.Volume, error))

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

func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCalls(stub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, int, string) (worker.Volume, error))

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

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCerts(arg1 lager.Logger) (worker.Volume, bool, error)

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsArgsForCall 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsArgsForCall(i int) lager.Logger

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsCallCount 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsCallCount() int

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsCalls 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsCalls(stub func(lager.Logger) (worker.Volume, bool, error))

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsReturns 

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

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsReturnsOnCall 

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

func (fake *FakeVolumeClient) FindVolumeForResourceCacheCalls(stub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error))

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(arg1 lager.Logger, arg2 int, arg3 int, arg4 string, arg5 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) FindVolumeForTaskCacheCalls 

func (fake *FakeVolumeClient) FindVolumeForTaskCacheCalls(stub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error))

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

func (fake *FakeVolumeClient) LookupVolumeCalls(stub func(lager.Logger, string) (worker.Volume, bool, error))

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 {
	ActiveTasksStub func() (int, error)

	BuildContainersStub func() int

	CertsVolumeStub func(lager.Logger) (worker.Volume, bool, error)

	CreateVolumeStub func(lager.Logger, worker.VolumeSpec, int, db.VolumeType) (worker.Volume, error)

	DecreaseActiveTasksStub func() error

	DescriptionStub func() string

	EphemeralStub func() bool

	FetchStub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string) (worker.GetResult, worker.Volume, error)

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

	FindOrCreateContainerStub func(context.Context, lager.Logger, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec) (worker.Container, error)

	FindResourceCacheForVolumeStub func(worker.Volume) (db.UsedResourceCache, bool, error)

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

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

	GardenClientStub func() gclient.Client

	IncreaseActiveTasksStub func() error

	IsOwnedByTeamStub func() bool

	IsVersionCompatibleStub func(lager.Logger, version.Version) bool

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

	NameStub func() string

	ResourceTypesStub func() []atc.WorkerResourceType

	SatisfiesStub func(lager.Logger, worker.WorkerSpec) bool

	TagsStub func() atc.Tags

	UptimeStub func() time.Duration
	// contains filtered or unexported fields
}

func (*FakeWorker) ActiveTasks 

func (fake *FakeWorker) ActiveTasks() (int, error)

func (*FakeWorker) ActiveTasksCallCount 

func (fake *FakeWorker) ActiveTasksCallCount() int

func (*FakeWorker) ActiveTasksCalls 

func (fake *FakeWorker) ActiveTasksCalls(stub func() (int, error))

func (*FakeWorker) ActiveTasksReturns 

func (fake *FakeWorker) ActiveTasksReturns(result1 int, result2 error)

func (*FakeWorker) ActiveTasksReturnsOnCall 

func (fake *FakeWorker) ActiveTasksReturnsOnCall(i int, result1 int, result2 error)

func (*FakeWorker) BuildContainers 

func (fake *FakeWorker) BuildContainers() int

func (*FakeWorker) BuildContainersCallCount 

func (fake *FakeWorker) BuildContainersCallCount() int

func (*FakeWorker) BuildContainersCalls 

func (fake *FakeWorker) BuildContainersCalls(stub func() int)

func (*FakeWorker) BuildContainersReturns 

func (fake *FakeWorker) BuildContainersReturns(result1 int)

func (*FakeWorker) BuildContainersReturnsOnCall 

func (fake *FakeWorker) BuildContainersReturnsOnCall(i int, result1 int)

func (*FakeWorker) CertsVolume 

func (fake *FakeWorker) CertsVolume(arg1 lager.Logger) (worker.Volume, bool, error)

func (*FakeWorker) CertsVolumeArgsForCall 

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

func (*FakeWorker) CertsVolumeCallCount 

func (fake *FakeWorker) CertsVolumeCallCount() int

func (*FakeWorker) CertsVolumeCalls 

func (fake *FakeWorker) CertsVolumeCalls(stub func(lager.Logger) (worker.Volume, bool, error))

func (*FakeWorker) CertsVolumeReturns 

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

func (*FakeWorker) CertsVolumeReturnsOnCall 

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

func (*FakeWorker) CreateVolume 

func (fake *FakeWorker) CreateVolume(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 db.VolumeType) (worker.Volume, error)

func (*FakeWorker) CreateVolumeArgsForCall 

func (fake *FakeWorker) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, db.VolumeType)

func (*FakeWorker) CreateVolumeCallCount 

func (fake *FakeWorker) CreateVolumeCallCount() int

func (*FakeWorker) CreateVolumeCalls 

func (fake *FakeWorker) CreateVolumeCalls(stub func(lager.Logger, worker.VolumeSpec, int, db.VolumeType) (worker.Volume, error))

func (*FakeWorker) CreateVolumeReturns 

func (fake *FakeWorker) CreateVolumeReturns(result1 worker.Volume, result2 error)

func (*FakeWorker) CreateVolumeReturnsOnCall 

func (fake *FakeWorker) CreateVolumeReturnsOnCall(i int, result1 worker.Volume, result2 error)

func (*FakeWorker) DecreaseActiveTasks 

func (fake *FakeWorker) DecreaseActiveTasks() error

func (*FakeWorker) DecreaseActiveTasksCallCount 

func (fake *FakeWorker) DecreaseActiveTasksCallCount() int

func (*FakeWorker) DecreaseActiveTasksCalls 

func (fake *FakeWorker) DecreaseActiveTasksCalls(stub func() error)

func (*FakeWorker) DecreaseActiveTasksReturns 

func (fake *FakeWorker) DecreaseActiveTasksReturns(result1 error)

func (*FakeWorker) DecreaseActiveTasksReturnsOnCall 

func (fake *FakeWorker) DecreaseActiveTasksReturnsOnCall(i int, result1 error)

func (*FakeWorker) Description 

func (fake *FakeWorker) Description() string

func (*FakeWorker) DescriptionCallCount 

func (fake *FakeWorker) DescriptionCallCount() int

func (*FakeWorker) DescriptionCalls 

func (fake *FakeWorker) DescriptionCalls(stub func() string)

func (*FakeWorker) DescriptionReturns 

func (fake *FakeWorker) DescriptionReturns(result1 string)

func (*FakeWorker) DescriptionReturnsOnCall 

func (fake *FakeWorker) DescriptionReturnsOnCall(i int, result1 string)

func (*FakeWorker) Ephemeral 

func (fake *FakeWorker) Ephemeral() bool

func (*FakeWorker) EphemeralCallCount 

func (fake *FakeWorker) EphemeralCallCount() int

func (*FakeWorker) EphemeralCalls 

func (fake *FakeWorker) EphemeralCalls(stub func() bool)

func (*FakeWorker) EphemeralReturns 

func (fake *FakeWorker) EphemeralReturns(result1 bool)

func (*FakeWorker) EphemeralReturnsOnCall 

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

func (*FakeWorker) Fetch 

func (fake *FakeWorker) Fetch(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerMetadata, arg4 worker.Worker, arg5 worker.ContainerSpec, arg6 runtime.ProcessSpec, arg7 resource.Resource, arg8 db.ContainerOwner, arg9 db.UsedResourceCache, arg10 string) (worker.GetResult, worker.Volume, error)

func (*FakeWorker) FetchArgsForCall 

func (fake *FakeWorker) FetchArgsForCall(i int) (context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string)

func (*FakeWorker) FetchCallCount 

func (fake *FakeWorker) FetchCallCount() int

func (*FakeWorker) FetchCalls 

func (fake *FakeWorker) FetchCalls(stub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, worker.ContainerSpec, runtime.ProcessSpec, resource.Resource, db.ContainerOwner, db.UsedResourceCache, string) (worker.GetResult, worker.Volume, error))

func (*FakeWorker) FetchReturns 

func (fake *FakeWorker) FetchReturns(result1 worker.GetResult, result2 worker.Volume, result3 error)

func (*FakeWorker) FetchReturnsOnCall 

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

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

func (fake *FakeWorker) FindContainerByHandleCalls(stub func(lager.Logger, int, string) (worker.Container, bool, error))

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 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, arg4 db.ContainerMetadata, arg5 worker.ContainerSpec) (worker.Container, error)

func (*FakeWorker) FindOrCreateContainerArgsForCall 

func (fake *FakeWorker) FindOrCreateContainerArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec)

func (*FakeWorker) FindOrCreateContainerCallCount 

func (fake *FakeWorker) FindOrCreateContainerCallCount() int

func (*FakeWorker) FindOrCreateContainerCalls 

func (fake *FakeWorker) FindOrCreateContainerCalls(stub func(context.Context, lager.Logger, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec) (worker.Container, error))

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

func (fake *FakeWorker) FindResourceCacheForVolume(arg1 worker.Volume) (db.UsedResourceCache, bool, error)

func (*FakeWorker) FindResourceCacheForVolumeArgsForCall 

func (fake *FakeWorker) FindResourceCacheForVolumeArgsForCall(i int) worker.Volume

func (*FakeWorker) FindResourceCacheForVolumeCallCount 

func (fake *FakeWorker) FindResourceCacheForVolumeCallCount() int

func (*FakeWorker) FindResourceCacheForVolumeCalls 

func (fake *FakeWorker) FindResourceCacheForVolumeCalls(stub func(worker.Volume) (db.UsedResourceCache, bool, error))

func (*FakeWorker) FindResourceCacheForVolumeReturns 

func (fake *FakeWorker) FindResourceCacheForVolumeReturns(result1 db.UsedResourceCache, result2 bool, result3 error)

func (*FakeWorker) FindResourceCacheForVolumeReturnsOnCall 

func (fake *FakeWorker) FindResourceCacheForVolumeReturnsOnCall(i int, result1 db.UsedResourceCache, result2 bool, result3 error)

func (*FakeWorker) FindVolumeForResourceCache 

func (fake *FakeWorker) FindVolumeForResourceCache(arg1 lager.Logger, arg2 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) FindVolumeForResourceCacheCalls 

func (fake *FakeWorker) FindVolumeForResourceCacheCalls(stub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error))

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

func (fake *FakeWorker) FindVolumeForTaskCacheCalls(stub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error))

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

func (fake *FakeWorker) GardenClient() gclient.Client

func (*FakeWorker) GardenClientCallCount 

func (fake *FakeWorker) GardenClientCallCount() int

func (*FakeWorker) GardenClientCalls 

func (fake *FakeWorker) GardenClientCalls(stub func() gclient.Client)

func (*FakeWorker) GardenClientReturns 

func (fake *FakeWorker) GardenClientReturns(result1 gclient.Client)

func (*FakeWorker) GardenClientReturnsOnCall 

func (fake *FakeWorker) GardenClientReturnsOnCall(i int, result1 gclient.Client)

func (*FakeWorker) IncreaseActiveTasks 

func (fake *FakeWorker) IncreaseActiveTasks() error

func (*FakeWorker) IncreaseActiveTasksCallCount 

func (fake *FakeWorker) IncreaseActiveTasksCallCount() int

func (*FakeWorker) IncreaseActiveTasksCalls 

func (fake *FakeWorker) IncreaseActiveTasksCalls(stub func() error)

func (*FakeWorker) IncreaseActiveTasksReturns 

func (fake *FakeWorker) IncreaseActiveTasksReturns(result1 error)

func (*FakeWorker) IncreaseActiveTasksReturnsOnCall 

func (fake *FakeWorker) IncreaseActiveTasksReturnsOnCall(i int, result1 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) IsOwnedByTeamCalls 

func (fake *FakeWorker) IsOwnedByTeamCalls(stub func() bool)

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

func (fake *FakeWorker) IsVersionCompatibleCalls(stub func(lager.Logger, version.Version) bool)

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

func (fake *FakeWorker) LookupVolumeCalls(stub func(lager.Logger, string) (worker.Volume, bool, error))

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

func (fake *FakeWorker) NameCalls(stub func() string)

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

func (fake *FakeWorker) ResourceTypesCalls(stub func() []atc.WorkerResourceType)

func (*FakeWorker) ResourceTypesReturns 

func (fake *FakeWorker) ResourceTypesReturns(result1 []atc.WorkerResourceType)

func (*FakeWorker) ResourceTypesReturnsOnCall 

func (fake *FakeWorker) ResourceTypesReturnsOnCall(i int, result1 []atc.WorkerResourceType)

func (*FakeWorker) Satisfies 

func (fake *FakeWorker) Satisfies(arg1 lager.Logger, arg2 worker.WorkerSpec) bool

func (*FakeWorker) SatisfiesArgsForCall 

func (fake *FakeWorker) SatisfiesArgsForCall(i int) (lager.Logger, worker.WorkerSpec)

func (*FakeWorker) SatisfiesCallCount 

func (fake *FakeWorker) SatisfiesCallCount() int

func (*FakeWorker) SatisfiesCalls 

func (fake *FakeWorker) SatisfiesCalls(stub func(lager.Logger, worker.WorkerSpec) bool)

func (*FakeWorker) SatisfiesReturns 

func (fake *FakeWorker) SatisfiesReturns(result1 bool)

func (*FakeWorker) SatisfiesReturnsOnCall 

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

func (*FakeWorker) Tags 

func (fake *FakeWorker) Tags() atc.Tags

func (*FakeWorker) TagsCallCount 

func (fake *FakeWorker) TagsCallCount() int

func (*FakeWorker) TagsCalls 

func (fake *FakeWorker) TagsCalls(stub func() atc.Tags)

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

func (fake *FakeWorker) UptimeCalls(stub func() time.Duration)

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 {
	FindWorkerForContainerStub func(lager.Logger, int, string) (worker.Worker, bool, error)

	FindWorkerForVolumeStub func(lager.Logger, int, string) (worker.Worker, bool, error)

	FindWorkersForContainerByOwnerStub func(lager.Logger, db.ContainerOwner) ([]worker.Worker, error)

	NewGardenWorkerStub func(lager.Logger, db.Worker, int) worker.Worker

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

func (*FakeWorkerProvider) FindWorkerForContainer 

func (fake *FakeWorkerProvider) FindWorkerForContainer(arg1 lager.Logger, arg2 int, arg3 string) (worker.Worker, bool, error)

func (*FakeWorkerProvider) FindWorkerForContainerArgsForCall 

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

func (*FakeWorkerProvider) FindWorkerForContainerCallCount 

func (fake *FakeWorkerProvider) FindWorkerForContainerCallCount() int

func (*FakeWorkerProvider) FindWorkerForContainerCalls 

func (fake *FakeWorkerProvider) FindWorkerForContainerCalls(stub func(lager.Logger, int, string) (worker.Worker, bool, error))

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

func (fake *FakeWorkerProvider) FindWorkerForVolume(arg1 lager.Logger, arg2 int, arg3 string) (worker.Worker, bool, error)

func (*FakeWorkerProvider) FindWorkerForVolumeArgsForCall 

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

func (*FakeWorkerProvider) FindWorkerForVolumeCallCount 

func (fake *FakeWorkerProvider) FindWorkerForVolumeCallCount() int

func (*FakeWorkerProvider) FindWorkerForVolumeCalls 

func (fake *FakeWorkerProvider) FindWorkerForVolumeCalls(stub func(lager.Logger, int, string) (worker.Worker, bool, error))

func (*FakeWorkerProvider) FindWorkerForVolumeReturns 

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

func (*FakeWorkerProvider) FindWorkerForVolumeReturnsOnCall 

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

func (*FakeWorkerProvider) FindWorkersForContainerByOwner 

func (fake *FakeWorkerProvider) FindWorkersForContainerByOwner(arg1 lager.Logger, arg2 db.ContainerOwner) ([]worker.Worker, error)

func (*FakeWorkerProvider) FindWorkersForContainerByOwnerArgsForCall 

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

func (*FakeWorkerProvider) FindWorkersForContainerByOwnerCallCount 

func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerCallCount() int

func (*FakeWorkerProvider) FindWorkersForContainerByOwnerCalls 

func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerCalls(stub func(lager.Logger, db.ContainerOwner) ([]worker.Worker, error))

func (*FakeWorkerProvider) FindWorkersForContainerByOwnerReturns 

func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerReturns(result1 []worker.Worker, result2 error)

func (*FakeWorkerProvider) FindWorkersForContainerByOwnerReturnsOnCall 

func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerReturnsOnCall(i int, result1 []worker.Worker, result2 error)

func (*FakeWorkerProvider) Invocations 

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

func (*FakeWorkerProvider) NewGardenWorker 

func (fake *FakeWorkerProvider) NewGardenWorker(arg1 lager.Logger, arg2 db.Worker, arg3 int) worker.Worker

func (*FakeWorkerProvider) NewGardenWorkerArgsForCall 

func (fake *FakeWorkerProvider) NewGardenWorkerArgsForCall(i int) (lager.Logger, db.Worker, int)

func (*FakeWorkerProvider) NewGardenWorkerCallCount 

func (fake *FakeWorkerProvider) NewGardenWorkerCallCount() int

func (*FakeWorkerProvider) NewGardenWorkerCalls 

func (fake *FakeWorkerProvider) NewGardenWorkerCalls(stub func(lager.Logger, db.Worker, int) worker.Worker)

func (*FakeWorkerProvider) NewGardenWorkerReturns 

func (fake *FakeWorkerProvider) NewGardenWorkerReturns(result1 worker.Worker)

func (*FakeWorkerProvider) NewGardenWorkerReturnsOnCall 

func (fake *FakeWorkerProvider) NewGardenWorkerReturnsOnCall(i int, result1 worker.Worker)

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

func (fake *FakeWorkerProvider) RunningWorkersCalls(stub func(lager.Logger) ([]worker.Worker, error))

func (*FakeWorkerProvider) RunningWorkersReturns 

func (fake *FakeWorkerProvider) RunningWorkersReturns(result1 []worker.Worker, result2 error)

func (*FakeWorkerProvider) RunningWorkersReturnsOnCall 

func (fake *FakeWorkerProvider) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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