workerfakes

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

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

 Go to latest Published: Jul 5, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeArtifactDestination 

type FakeArtifactDestination struct {
	StreamInStub func(string, io.Reader) error
	// contains filtered or unexported fields
}

func (*FakeArtifactDestination) Invocations 

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

func (*FakeArtifactDestination) StreamIn 

func (fake *FakeArtifactDestination) StreamIn(arg1 string, arg2 io.Reader) error

func (*FakeArtifactDestination) StreamInArgsForCall 

func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (string, io.Reader)

func (*FakeArtifactDestination) StreamInCallCount 

func (fake *FakeArtifactDestination) StreamInCallCount() int

func (*FakeArtifactDestination) StreamInReturns 

func (fake *FakeArtifactDestination) StreamInReturns(result1 error)

func (*FakeArtifactDestination) StreamInReturnsOnCall 

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

type FakeArtifactSource 

type FakeArtifactSource struct {
	StreamToStub func(worker.ArtifactDestination) error

	StreamFileStub func(path string) (io.ReadCloser, error)

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

func (*FakeArtifactSource) Invocations 

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

func (*FakeArtifactSource) StreamFile 

func (fake *FakeArtifactSource) StreamFile(path string) (io.ReadCloser, error)

func (*FakeArtifactSource) StreamFileArgsForCall 

func (fake *FakeArtifactSource) StreamFileArgsForCall(i int) string

func (*FakeArtifactSource) StreamFileCallCount 

func (fake *FakeArtifactSource) StreamFileCallCount() int

func (*FakeArtifactSource) StreamFileReturns 

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

func (*FakeArtifactSource) StreamFileReturnsOnCall 

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

func (*FakeArtifactSource) StreamTo 

func (fake *FakeArtifactSource) StreamTo(arg1 worker.ArtifactDestination) error

func (*FakeArtifactSource) StreamToArgsForCall 

func (fake *FakeArtifactSource) StreamToArgsForCall(i int) worker.ArtifactDestination

func (*FakeArtifactSource) StreamToCallCount 

func (fake *FakeArtifactSource) StreamToCallCount() int

func (*FakeArtifactSource) StreamToReturns 

func (fake *FakeArtifactSource) StreamToReturns(result1 error)

func (*FakeArtifactSource) StreamToReturnsOnCall 

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

func (*FakeArtifactSource) VolumeOn 

func (fake *FakeArtifactSource) VolumeOn(arg1 worker.Worker) (worker.Volume, bool, error)

func (*FakeArtifactSource) VolumeOnArgsForCall 

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

func (*FakeArtifactSource) VolumeOnCallCount 

func (fake *FakeArtifactSource) VolumeOnCallCount() int

func (*FakeArtifactSource) VolumeOnReturns 

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

func (*FakeArtifactSource) VolumeOnReturnsOnCall 

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

type 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) 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 {
	FindOrCreateContainerStub func(context.Context, lager.Logger, worker.ImageFetchingDelegate, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes) (worker.Container, error)

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

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

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

	SatisfyingStub func(lager.Logger, worker.WorkerSpec, creds.VersionedResourceTypes) (worker.Worker, error)

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

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

func (*FakeClient) AllSatisfying 

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

func (*FakeClient) AllSatisfyingArgsForCall 

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

func (*FakeClient) AllSatisfyingCallCount 

func (fake *FakeClient) AllSatisfyingCallCount() int

func (*FakeClient) AllSatisfyingReturns 

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

func (*FakeClient) AllSatisfyingReturnsOnCall 

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

func (*FakeClient) FindContainerByHandle 

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

func (*FakeClient) FindContainerByHandleArgsForCall 

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

func (*FakeClient) FindContainerByHandleCallCount 

func (fake *FakeClient) FindContainerByHandleCallCount() int

func (*FakeClient) FindContainerByHandleReturns 

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

func (*FakeClient) FindContainerByHandleReturnsOnCall 

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

func (*FakeClient) FindOrCreateContainer 

func (fake *FakeClient) FindOrCreateContainer(arg1 context.Context, arg2 lager.Logger, arg3 worker.ImageFetchingDelegate, arg4 db.ContainerOwner, arg5 db.ContainerMetadata, arg6 worker.ContainerSpec, arg7 creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeClient) FindOrCreateContainerArgsForCall 

func (fake *FakeClient) FindOrCreateContainerArgsForCall(i int) (context.Context, lager.Logger, worker.ImageFetchingDelegate, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes)

func (*FakeClient) FindOrCreateContainerCallCount 

func (fake *FakeClient) FindOrCreateContainerCallCount() int

func (*FakeClient) FindOrCreateContainerReturns 

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

func (*FakeClient) FindOrCreateContainerReturnsOnCall 

func (fake *FakeClient) FindOrCreateContainerReturnsOnCall(i int, result1 worker.Container, result2 error)

func (*FakeClient) FindResourceTypeByPath 

func (fake *FakeClient) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)

func (*FakeClient) FindResourceTypeByPathArgsForCall 

func (fake *FakeClient) FindResourceTypeByPathArgsForCall(i int) string

func (*FakeClient) FindResourceTypeByPathCallCount 

func (fake *FakeClient) FindResourceTypeByPathCallCount() int

func (*FakeClient) FindResourceTypeByPathReturns 

func (fake *FakeClient) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)

func (*FakeClient) FindResourceTypeByPathReturnsOnCall 

func (fake *FakeClient) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)

func (*FakeClient) Invocations 

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

func (*FakeClient) LookupVolume 

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

func (*FakeClient) LookupVolumeArgsForCall 

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

func (*FakeClient) LookupVolumeCallCount 

func (fake *FakeClient) LookupVolumeCallCount() int

func (*FakeClient) LookupVolumeReturns 

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

func (*FakeClient) LookupVolumeReturnsOnCall 

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

func (*FakeClient) RunningWorkers 

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

func (*FakeClient) RunningWorkersArgsForCall 

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

func (*FakeClient) RunningWorkersCallCount 

func (fake *FakeClient) RunningWorkersCallCount() int

func (*FakeClient) RunningWorkersReturns 

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

func (*FakeClient) RunningWorkersReturnsOnCall 

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

func (*FakeClient) Satisfying 

func (fake *FakeClient) Satisfying(arg1 lager.Logger, arg2 worker.WorkerSpec, arg3 creds.VersionedResourceTypes) (worker.Worker, error)

func (*FakeClient) SatisfyingArgsForCall 

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

func (*FakeClient) SatisfyingCallCount 

func (fake *FakeClient) SatisfyingCallCount() int

func (*FakeClient) SatisfyingReturns 

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

func (*FakeClient) SatisfyingReturnsOnCall 

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

type FakeContainer 

type FakeContainer struct {
	HandleStub func() string

	StopStub func(kill bool) error

	InfoStub func() (garden.ContainerInfo, error)

	StreamInStub func(spec garden.StreamInSpec) error

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

	CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error)

	CurrentCPULimitsStub func() (garden.CPULimits, error)

	CurrentDiskLimitsStub func() (garden.DiskLimits, error)

	CurrentMemoryLimitsStub func() (garden.MemoryLimits, error)

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

	NetOutStub func(netOutRule garden.NetOutRule) error

	BulkNetOutStub func(netOutRules []garden.NetOutRule) error

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

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

	MetricsStub func() (garden.Metrics, error)

	SetGraceTimeStub func(graceTime time.Duration) error

	PropertiesStub func() (garden.Properties, error)

	PropertyStub func(name string) (string, error)

	SetPropertyStub func(name string, value string) error

	RemovePropertyStub func(name string) error

	DestroyStub func() error

	VolumeMountsStub func() []worker.VolumeMount

	WorkerNameStub func() string

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

func (*FakeContainer) Attach 

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

func (*FakeContainer) AttachArgsForCall 

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

func (*FakeContainer) AttachCallCount 

func (fake *FakeContainer) AttachCallCount() int

func (*FakeContainer) AttachReturns 

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

func (*FakeContainer) AttachReturnsOnCall 

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

func (*FakeContainer) BulkNetOut 

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

func (*FakeContainer) BulkNetOutArgsForCall 

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

func (*FakeContainer) BulkNetOutCallCount 

func (fake *FakeContainer) BulkNetOutCallCount() int

func (*FakeContainer) BulkNetOutReturns 

func (fake *FakeContainer) BulkNetOutReturns(result1 error)

func (*FakeContainer) BulkNetOutReturnsOnCall 

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

func (*FakeContainer) CurrentBandwidthLimits 

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

func (*FakeContainer) CurrentBandwidthLimitsCallCount 

func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int

func (*FakeContainer) CurrentBandwidthLimitsReturns 

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

func (*FakeContainer) CurrentBandwidthLimitsReturnsOnCall 

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

func (*FakeContainer) CurrentCPULimits 

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

func (*FakeContainer) CurrentCPULimitsCallCount 

func (fake *FakeContainer) CurrentCPULimitsCallCount() int

func (*FakeContainer) CurrentCPULimitsReturns 

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

func (*FakeContainer) CurrentCPULimitsReturnsOnCall 

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

func (*FakeContainer) CurrentDiskLimits 

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

func (*FakeContainer) CurrentDiskLimitsCallCount 

func (fake *FakeContainer) CurrentDiskLimitsCallCount() int

func (*FakeContainer) CurrentDiskLimitsReturns 

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

func (*FakeContainer) CurrentDiskLimitsReturnsOnCall 

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

func (*FakeContainer) CurrentMemoryLimits 

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

func (*FakeContainer) CurrentMemoryLimitsCallCount 

func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int

func (*FakeContainer) CurrentMemoryLimitsReturns 

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

func (*FakeContainer) CurrentMemoryLimitsReturnsOnCall 

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

func (*FakeContainer) Destroy 

func (fake *FakeContainer) Destroy() error

func (*FakeContainer) DestroyCallCount 

func (fake *FakeContainer) DestroyCallCount() int

func (*FakeContainer) DestroyReturns 

func (fake *FakeContainer) DestroyReturns(result1 error)

func (*FakeContainer) DestroyReturnsOnCall 

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

func (*FakeContainer) Handle 

func (fake *FakeContainer) Handle() string

func (*FakeContainer) HandleCallCount 

func (fake *FakeContainer) HandleCallCount() int

func (*FakeContainer) HandleReturns 

func (fake *FakeContainer) HandleReturns(result1 string)

func (*FakeContainer) HandleReturnsOnCall 

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

func (*FakeContainer) Info 

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

func (*FakeContainer) InfoCallCount 

func (fake *FakeContainer) InfoCallCount() int

func (*FakeContainer) InfoReturns 

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

func (*FakeContainer) InfoReturnsOnCall 

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

func (*FakeContainer) Invocations 

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

func (*FakeContainer) MarkAsHijacked 

func (fake *FakeContainer) MarkAsHijacked() error

func (*FakeContainer) MarkAsHijackedCallCount 

func (fake *FakeContainer) MarkAsHijackedCallCount() int

func (*FakeContainer) MarkAsHijackedReturns 

func (fake *FakeContainer) MarkAsHijackedReturns(result1 error)

func (*FakeContainer) MarkAsHijackedReturnsOnCall 

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

func (*FakeContainer) Metrics 

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

func (*FakeContainer) MetricsCallCount 

func (fake *FakeContainer) MetricsCallCount() int

func (*FakeContainer) MetricsReturns 

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

func (*FakeContainer) MetricsReturnsOnCall 

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

func (*FakeContainer) NetIn 

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

func (*FakeContainer) NetInArgsForCall 

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

func (*FakeContainer) NetInCallCount 

func (fake *FakeContainer) NetInCallCount() int

func (*FakeContainer) NetInReturns 

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

func (*FakeContainer) NetInReturnsOnCall 

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

func (*FakeContainer) NetOut 

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

func (*FakeContainer) NetOutArgsForCall 

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

func (*FakeContainer) NetOutCallCount 

func (fake *FakeContainer) NetOutCallCount() int

func (*FakeContainer) NetOutReturns 

func (fake *FakeContainer) NetOutReturns(result1 error)

func (*FakeContainer) NetOutReturnsOnCall 

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

func (*FakeContainer) Properties 

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

func (*FakeContainer) PropertiesCallCount 

func (fake *FakeContainer) PropertiesCallCount() int

func (*FakeContainer) PropertiesReturns 

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

func (*FakeContainer) PropertiesReturnsOnCall 

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

func (*FakeContainer) Property 

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

func (*FakeContainer) PropertyArgsForCall 

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

func (*FakeContainer) PropertyCallCount 

func (fake *FakeContainer) PropertyCallCount() int

func (*FakeContainer) PropertyReturns 

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

func (*FakeContainer) PropertyReturnsOnCall 

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

func (*FakeContainer) RemoveProperty 

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

func (*FakeContainer) RemovePropertyArgsForCall 

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

func (*FakeContainer) RemovePropertyCallCount 

func (fake *FakeContainer) RemovePropertyCallCount() int

func (*FakeContainer) RemovePropertyReturns 

func (fake *FakeContainer) RemovePropertyReturns(result1 error)

func (*FakeContainer) RemovePropertyReturnsOnCall 

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

func (*FakeContainer) Run 

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

func (*FakeContainer) RunArgsForCall 

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

func (*FakeContainer) RunCallCount 

func (fake *FakeContainer) RunCallCount() int

func (*FakeContainer) RunReturns 

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

func (*FakeContainer) RunReturnsOnCall 

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

func (*FakeContainer) SetGraceTime 

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

func (*FakeContainer) SetGraceTimeArgsForCall 

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

func (*FakeContainer) SetGraceTimeCallCount 

func (fake *FakeContainer) SetGraceTimeCallCount() int

func (*FakeContainer) SetGraceTimeReturns 

func (fake *FakeContainer) SetGraceTimeReturns(result1 error)

func (*FakeContainer) SetGraceTimeReturnsOnCall 

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

func (*FakeContainer) SetProperty 

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

func (*FakeContainer) SetPropertyArgsForCall 

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

func (*FakeContainer) SetPropertyCallCount 

func (fake *FakeContainer) SetPropertyCallCount() int

func (*FakeContainer) SetPropertyReturns 

func (fake *FakeContainer) SetPropertyReturns(result1 error)

func (*FakeContainer) SetPropertyReturnsOnCall 

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

func (*FakeContainer) Stop 

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

func (*FakeContainer) StopArgsForCall 

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

func (*FakeContainer) StopCallCount 

func (fake *FakeContainer) StopCallCount() int

func (*FakeContainer) StopReturns 

func (fake *FakeContainer) StopReturns(result1 error)

func (*FakeContainer) StopReturnsOnCall 

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

func (*FakeContainer) StreamIn 

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

func (*FakeContainer) StreamInArgsForCall 

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

func (*FakeContainer) StreamInCallCount 

func (fake *FakeContainer) StreamInCallCount() int

func (*FakeContainer) StreamInReturns 

func (fake *FakeContainer) StreamInReturns(result1 error)

func (*FakeContainer) StreamInReturnsOnCall 

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

func (*FakeContainer) StreamOut 

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

func (*FakeContainer) StreamOutArgsForCall 

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

func (*FakeContainer) StreamOutCallCount 

func (fake *FakeContainer) StreamOutCallCount() int

func (*FakeContainer) StreamOutReturns 

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

func (*FakeContainer) StreamOutReturnsOnCall 

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

func (*FakeContainer) VolumeMounts 

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

func (*FakeContainer) VolumeMountsCallCount 

func (fake *FakeContainer) VolumeMountsCallCount() int

func (*FakeContainer) VolumeMountsReturns 

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

func (*FakeContainer) VolumeMountsReturnsOnCall 

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

func (*FakeContainer) WorkerName 

func (fake *FakeContainer) WorkerName() string

func (*FakeContainer) WorkerNameCallCount 

func (fake *FakeContainer) WorkerNameCallCount() int

func (*FakeContainer) WorkerNameReturns 

func (fake *FakeContainer) WorkerNameReturns(result1 string)

func (*FakeContainer) WorkerNameReturnsOnCall 

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

type FakeContainerPlacementStrategy 

type FakeContainerPlacementStrategy struct {
	ChooseStub func([]worker.Worker, worker.ContainerSpec) (worker.Worker, error)
	// contains filtered or unexported fields
}

func (*FakeContainerPlacementStrategy) Choose 

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

func (*FakeContainerPlacementStrategy) ChooseArgsForCall 

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

func (*FakeContainerPlacementStrategy) ChooseCallCount 

func (fake *FakeContainerPlacementStrategy) ChooseCallCount() int

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{}

type FakeContainerProvider 

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

	FindOrCreateContainerStub func(ctx context.Context, logger lager.Logger, owner db.ContainerOwner, delegate worker.ImageFetchingDelegate, metadata db.ContainerMetadata, spec worker.ContainerSpec, resourceTypes creds.VersionedResourceTypes) (worker.Container, error)
	// contains filtered or unexported fields
}

func (*FakeContainerProvider) FindCreatedContainerByHandle 

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

func (*FakeContainerProvider) FindCreatedContainerByHandleArgsForCall 

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

func (*FakeContainerProvider) FindCreatedContainerByHandleCallCount 

func (fake *FakeContainerProvider) FindCreatedContainerByHandleCallCount() int

func (*FakeContainerProvider) FindCreatedContainerByHandleReturns 

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

func (*FakeContainerProvider) FindCreatedContainerByHandleReturnsOnCall 

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

func (*FakeContainerProvider) FindOrCreateContainer 

func (fake *FakeContainerProvider) FindOrCreateContainer(ctx context.Context, logger lager.Logger, owner db.ContainerOwner, delegate worker.ImageFetchingDelegate, metadata db.ContainerMetadata, spec worker.ContainerSpec, resourceTypes creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeContainerProvider) FindOrCreateContainerArgsForCall 

func (fake *FakeContainerProvider) FindOrCreateContainerArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ImageFetchingDelegate, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes)

func (*FakeContainerProvider) FindOrCreateContainerCallCount 

func (fake *FakeContainerProvider) FindOrCreateContainerCallCount() int

func (*FakeContainerProvider) FindOrCreateContainerReturns 

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

func (*FakeContainerProvider) FindOrCreateContainerReturnsOnCall 

func (fake *FakeContainerProvider) FindOrCreateContainerReturnsOnCall(i int, result1 worker.Container, result2 error)

func (*FakeContainerProvider) Invocations 

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

type FakeGardenConnectionFactory 

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

func (*FakeGardenConnectionFactory) BuildConnection 

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

func (*FakeGardenConnectionFactory) BuildConnectionCallCount 

func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int

func (*FakeGardenConnectionFactory) BuildConnectionReturns 

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

func (*FakeGardenConnectionFactory) BuildConnectionReturnsOnCall 

func (fake *FakeGardenConnectionFactory) BuildConnectionReturnsOnCall(i int, result1 gconn.Connection)

func (*FakeGardenConnectionFactory) Invocations 

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

type FakeImage 

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

func (*FakeImage) FetchForContainer 

func (fake *FakeImage) FetchForContainer(ctx context.Context, logger lager.Logger, container 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) FetchForContainerReturns 

func (fake *FakeImage) FetchForContainerReturns(result1 worker.FetchedImage, result2 error)

func (*FakeImage) FetchForContainerReturnsOnCall 

func (fake *FakeImage) FetchForContainerReturnsOnCall(i int, result1 worker.FetchedImage, result2 error)

func (*FakeImage) Invocations 

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

type FakeImageFactory 

type FakeImageFactory struct {
	GetImageStub func(logger lager.Logger, workerClient worker.Worker, volumeClient worker.VolumeClient, imageSpec worker.ImageSpec, teamID int, delegate worker.ImageFetchingDelegate, resourceTypes creds.VersionedResourceTypes) (worker.Image, error)
	// contains filtered or unexported fields
}

func (*FakeImageFactory) GetImage 

func (fake *FakeImageFactory) GetImage(logger lager.Logger, workerClient worker.Worker, volumeClient worker.VolumeClient, imageSpec worker.ImageSpec, teamID int, delegate worker.ImageFetchingDelegate, resourceTypes creds.VersionedResourceTypes) (worker.Image, error)

func (*FakeImageFactory) GetImageArgsForCall 

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

func (*FakeImageFactory) GetImageCallCount 

func (fake *FakeImageFactory) GetImageCallCount() int

func (*FakeImageFactory) GetImageReturns 

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

func (*FakeImageFactory) GetImageReturnsOnCall 

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

func (*FakeImageFactory) Invocations 

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

type FakeImageFetchingDelegate 

type FakeImageFetchingDelegate struct {
	StdoutStub func() io.Writer

	StderrStub func() io.Writer

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

func (*FakeImageFetchingDelegate) ImageVersionDetermined 

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

func (*FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall 

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

func (*FakeImageFetchingDelegate) ImageVersionDeterminedCallCount 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int

func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturns 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)

func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall(i int, result1 error)

func (*FakeImageFetchingDelegate) Invocations 

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

func (*FakeImageFetchingDelegate) Stderr 

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

func (*FakeImageFetchingDelegate) StderrCallCount 

func (fake *FakeImageFetchingDelegate) StderrCallCount() int

func (*FakeImageFetchingDelegate) StderrReturns 

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

func (*FakeImageFetchingDelegate) StderrReturnsOnCall 

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

func (*FakeImageFetchingDelegate) Stdout 

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

func (*FakeImageFetchingDelegate) StdoutCallCount 

func (fake *FakeImageFetchingDelegate) StdoutCallCount() int

func (*FakeImageFetchingDelegate) StdoutReturns 

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

func (*FakeImageFetchingDelegate) StdoutReturnsOnCall 

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

type FakeInputSource 

type FakeInputSource struct {
	SourceStub func() worker.ArtifactSource

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

func (*FakeInputSource) DestinationPath 

func (fake *FakeInputSource) DestinationPath() string

func (*FakeInputSource) DestinationPathCallCount 

func (fake *FakeInputSource) DestinationPathCallCount() int

func (*FakeInputSource) DestinationPathReturns 

func (fake *FakeInputSource) DestinationPathReturns(result1 string)

func (*FakeInputSource) DestinationPathReturnsOnCall 

func (fake *FakeInputSource) DestinationPathReturnsOnCall(i int, result1 string)

func (*FakeInputSource) Invocations 

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

func (*FakeInputSource) Source 

func (fake *FakeInputSource) Source() worker.ArtifactSource

func (*FakeInputSource) SourceCallCount 

func (fake *FakeInputSource) SourceCallCount() int

func (*FakeInputSource) SourceReturns 

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

func (*FakeInputSource) SourceReturnsOnCall 

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

type FakeSleeper 

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

func (*FakeSleeper) Invocations 

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

func (*FakeSleeper) Sleep 

func (fake *FakeSleeper) Sleep(arg1 time.Duration)

func (*FakeSleeper) SleepArgsForCall 

func (fake *FakeSleeper) SleepArgsForCall(i int) time.Duration

func (*FakeSleeper) SleepCallCount 

func (fake *FakeSleeper) SleepCallCount() int

type FakeVolume 

type FakeVolume struct {
	HandleStub func() string

	PathStub func() string

	SetPropertyStub func(key string, value string) error

	PropertiesStub func() (baggageclaim.VolumeProperties, error)

	SetPrivilegedStub func(bool) error

	StreamInStub func(path string, tarStream io.Reader) error

	StreamOutStub func(path string) (io.ReadCloser, error)

	COWStrategyStub func() baggageclaim.COWStrategy

	InitializeResourceCacheStub func(*db.UsedResourceCache) error

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

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

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

func (*FakeVolume) COWStrategy 

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

func (*FakeVolume) COWStrategyCallCount 

func (fake *FakeVolume) COWStrategyCallCount() int

func (*FakeVolume) COWStrategyReturns 

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

func (*FakeVolume) COWStrategyReturnsOnCall 

func (fake *FakeVolume) COWStrategyReturnsOnCall(i int, result1 baggageclaim.COWStrategy)

func (*FakeVolume) CreateChildForContainer 

func (fake *FakeVolume) CreateChildForContainer(arg1 db.CreatingContainer, arg2 string) (db.CreatingVolume, error)

func (*FakeVolume) CreateChildForContainerArgsForCall 

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

func (*FakeVolume) CreateChildForContainerCallCount 

func (fake *FakeVolume) CreateChildForContainerCallCount() int

func (*FakeVolume) CreateChildForContainerReturns 

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

func (*FakeVolume) CreateChildForContainerReturnsOnCall 

func (fake *FakeVolume) CreateChildForContainerReturnsOnCall(i int, result1 db.CreatingVolume, result2 error)

func (*FakeVolume) Destroy 

func (fake *FakeVolume) Destroy() error

func (*FakeVolume) DestroyCallCount 

func (fake *FakeVolume) DestroyCallCount() int

func (*FakeVolume) DestroyReturns 

func (fake *FakeVolume) DestroyReturns(result1 error)

func (*FakeVolume) DestroyReturnsOnCall 

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

func (*FakeVolume) Handle 

func (fake *FakeVolume) Handle() string

func (*FakeVolume) HandleCallCount 

func (fake *FakeVolume) HandleCallCount() int

func (*FakeVolume) HandleReturns 

func (fake *FakeVolume) HandleReturns(result1 string)

func (*FakeVolume) HandleReturnsOnCall 

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

func (*FakeVolume) InitializeResourceCache 

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

func (*FakeVolume) InitializeResourceCacheArgsForCall 

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

func (*FakeVolume) InitializeResourceCacheCallCount 

func (fake *FakeVolume) InitializeResourceCacheCallCount() int

func (*FakeVolume) InitializeResourceCacheReturns 

func (fake *FakeVolume) InitializeResourceCacheReturns(result1 error)

func (*FakeVolume) InitializeResourceCacheReturnsOnCall 

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

func (*FakeVolume) InitializeTaskCache 

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

func (*FakeVolume) InitializeTaskCacheArgsForCall 

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

func (*FakeVolume) InitializeTaskCacheCallCount 

func (fake *FakeVolume) InitializeTaskCacheCallCount() int

func (*FakeVolume) InitializeTaskCacheReturns 

func (fake *FakeVolume) InitializeTaskCacheReturns(result1 error)

func (*FakeVolume) InitializeTaskCacheReturnsOnCall 

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

func (*FakeVolume) Invocations 

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

func (*FakeVolume) Path 

func (fake *FakeVolume) Path() string

func (*FakeVolume) PathCallCount 

func (fake *FakeVolume) PathCallCount() int

func (*FakeVolume) PathReturns 

func (fake *FakeVolume) PathReturns(result1 string)

func (*FakeVolume) PathReturnsOnCall 

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

func (*FakeVolume) Properties 

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

func (*FakeVolume) PropertiesCallCount 

func (fake *FakeVolume) PropertiesCallCount() int

func (*FakeVolume) PropertiesReturns 

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

func (*FakeVolume) PropertiesReturnsOnCall 

func (fake *FakeVolume) PropertiesReturnsOnCall(i int, result1 baggageclaim.VolumeProperties, result2 error)

func (*FakeVolume) SetPrivileged 

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

func (*FakeVolume) SetPrivilegedArgsForCall 

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

func (*FakeVolume) SetPrivilegedCallCount 

func (fake *FakeVolume) SetPrivilegedCallCount() int

func (*FakeVolume) SetPrivilegedReturns 

func (fake *FakeVolume) SetPrivilegedReturns(result1 error)

func (*FakeVolume) SetPrivilegedReturnsOnCall 

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

func (*FakeVolume) SetProperty 

func (fake *FakeVolume) SetProperty(key string, value string) error

func (*FakeVolume) SetPropertyArgsForCall 

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

func (*FakeVolume) SetPropertyCallCount 

func (fake *FakeVolume) SetPropertyCallCount() int

func (*FakeVolume) SetPropertyReturns 

func (fake *FakeVolume) SetPropertyReturns(result1 error)

func (*FakeVolume) SetPropertyReturnsOnCall 

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

func (*FakeVolume) StreamIn 

func (fake *FakeVolume) StreamIn(path string, tarStream io.Reader) error

func (*FakeVolume) StreamInArgsForCall 

func (fake *FakeVolume) StreamInArgsForCall(i int) (string, io.Reader)

func (*FakeVolume) StreamInCallCount 

func (fake *FakeVolume) StreamInCallCount() int

func (*FakeVolume) StreamInReturns 

func (fake *FakeVolume) StreamInReturns(result1 error)

func (*FakeVolume) StreamInReturnsOnCall 

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

func (*FakeVolume) StreamOut 

func (fake *FakeVolume) StreamOut(path string) (io.ReadCloser, error)

func (*FakeVolume) StreamOutArgsForCall 

func (fake *FakeVolume) StreamOutArgsForCall(i int) string

func (*FakeVolume) StreamOutCallCount 

func (fake *FakeVolume) StreamOutCallCount() int

func (*FakeVolume) StreamOutReturns 

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

func (*FakeVolume) StreamOutReturnsOnCall 

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

type FakeVolumeClient 

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

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

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

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

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

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

	FindOrCreateVolumeForResourceCertsStub func(logger lager.Logger) (volume worker.Volume, found bool, err error)

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

func (*FakeVolumeClient) CreateVolumeForTaskCache 

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

func (*FakeVolumeClient) CreateVolumeForTaskCacheArgsForCall 

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

func (*FakeVolumeClient) CreateVolumeForTaskCacheCallCount 

func (fake *FakeVolumeClient) CreateVolumeForTaskCacheCallCount() int

func (*FakeVolumeClient) CreateVolumeForTaskCacheReturns 

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

func (*FakeVolumeClient) CreateVolumeForTaskCacheReturnsOnCall 

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

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainer 

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

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall 

func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, db.CreatingContainer, worker.Volume, int, string)

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount 

func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount() int

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturns 

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

func (*FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturnsOnCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceType 

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

func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeArgsForCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount 

func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount() int

func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturns 

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

func (*FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturnsOnCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForContainer 

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

func (*FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForContainerCallCount 

func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCallCount() int

func (*FakeVolumeClient) FindOrCreateVolumeForContainerReturns 

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

func (*FakeVolumeClient) FindOrCreateVolumeForContainerReturnsOnCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCerts 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCerts(logger lager.Logger) (volume worker.Volume, found bool, err error)

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsArgsForCall 

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

func (*FakeVolumeClient) FindOrCreateVolumeForResourceCertsCallCount 

func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsCallCount() int

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

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

func (*FakeVolumeClient) FindVolumeForResourceCacheReturnsOnCall 

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

func (*FakeVolumeClient) FindVolumeForTaskCache 

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

func (*FakeVolumeClient) FindVolumeForTaskCacheArgsForCall 

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

func (*FakeVolumeClient) FindVolumeForTaskCacheCallCount 

func (fake *FakeVolumeClient) FindVolumeForTaskCacheCallCount() int

func (*FakeVolumeClient) FindVolumeForTaskCacheReturns 

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

func (*FakeVolumeClient) FindVolumeForTaskCacheReturnsOnCall 

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

func (*FakeVolumeClient) Invocations 

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

func (*FakeVolumeClient) LookupVolume 

func (fake *FakeVolumeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)

func (*FakeVolumeClient) LookupVolumeArgsForCall 

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

func (*FakeVolumeClient) LookupVolumeCallCount 

func (fake *FakeVolumeClient) LookupVolumeCallCount() int

func (*FakeVolumeClient) LookupVolumeReturns 

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

func (*FakeVolumeClient) LookupVolumeReturnsOnCall 

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

type FakeWorker 

type FakeWorker struct {
	FindOrCreateContainerStub func(context.Context, lager.Logger, worker.ImageFetchingDelegate, db.ContainerOwner, db.ContainerMetadata, worker.ContainerSpec, creds.VersionedResourceTypes) (worker.Container, error)

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

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

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

	SatisfyingStub func(lager.Logger, worker.WorkerSpec, creds.VersionedResourceTypes) (worker.Worker, error)

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

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

	ActiveContainersStub func() int

	DescriptionStub func() string

	NameStub func() string

	ResourceTypesStub func() []atc.WorkerResourceType

	TagsStub func() atc.Tags

	UptimeStub func() time.Duration

	IsOwnedByTeamStub func() bool

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

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

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

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

	GardenClientStub func() garden.Client

	BaggageclaimClientStub func() baggageclaim.Client
	// contains filtered or unexported fields
}

func (*FakeWorker) ActiveContainers 

func (fake *FakeWorker) ActiveContainers() int

func (*FakeWorker) ActiveContainersCallCount 

func (fake *FakeWorker) ActiveContainersCallCount() int

func (*FakeWorker) ActiveContainersReturns 

func (fake *FakeWorker) ActiveContainersReturns(result1 int)

func (*FakeWorker) ActiveContainersReturnsOnCall 

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

func (*FakeWorker) AllSatisfying 

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

func (*FakeWorker) AllSatisfyingArgsForCall 

func (fake *FakeWorker) AllSatisfyingArgsForCall(i int) (lager.Logger, worker.WorkerSpec, creds.VersionedResourceTypes)

func (*FakeWorker) AllSatisfyingCallCount 

func (fake *FakeWorker) AllSatisfyingCallCount() int

func (*FakeWorker) AllSatisfyingReturns 

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

func (*FakeWorker) AllSatisfyingReturnsOnCall 

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

func (*FakeWorker) BaggageclaimClient 

func (fake *FakeWorker) BaggageclaimClient() baggageclaim.Client

func (*FakeWorker) BaggageclaimClientCallCount 

func (fake *FakeWorker) BaggageclaimClientCallCount() int

func (*FakeWorker) BaggageclaimClientReturns 

func (fake *FakeWorker) BaggageclaimClientReturns(result1 baggageclaim.Client)

func (*FakeWorker) BaggageclaimClientReturnsOnCall 

func (fake *FakeWorker) BaggageclaimClientReturnsOnCall(i int, result1 baggageclaim.Client)

func (*FakeWorker) CertsVolume 

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

func (*FakeWorker) CertsVolumeArgsForCall 

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

func (*FakeWorker) CertsVolumeCallCount 

func (fake *FakeWorker) CertsVolumeCallCount() int

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

func (fake *FakeWorker) Description() string

func (*FakeWorker) DescriptionCallCount 

func (fake *FakeWorker) DescriptionCallCount() int

func (*FakeWorker) DescriptionReturns 

func (fake *FakeWorker) DescriptionReturns(result1 string)

func (*FakeWorker) DescriptionReturnsOnCall 

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

func (*FakeWorker) FindContainerByHandle 

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

func (*FakeWorker) FindContainerByHandleArgsForCall 

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

func (*FakeWorker) FindContainerByHandleCallCount 

func (fake *FakeWorker) FindContainerByHandleCallCount() int

func (*FakeWorker) FindContainerByHandleReturns 

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

func (*FakeWorker) FindContainerByHandleReturnsOnCall 

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

func (*FakeWorker) FindOrCreateContainer 

func (fake *FakeWorker) FindOrCreateContainer(arg1 context.Context, arg2 lager.Logger, arg3 worker.ImageFetchingDelegate, arg4 db.ContainerOwner, arg5 db.ContainerMetadata, arg6 worker.ContainerSpec, arg7 creds.VersionedResourceTypes) (worker.Container, error)

func (*FakeWorker) FindOrCreateContainerArgsForCall 

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

func (*FakeWorker) FindOrCreateContainerCallCount 

func (fake *FakeWorker) FindOrCreateContainerCallCount() int

func (*FakeWorker) FindOrCreateContainerReturns 

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

func (*FakeWorker) FindOrCreateContainerReturnsOnCall 

func (fake *FakeWorker) FindOrCreateContainerReturnsOnCall(i int, result1 worker.Container, result2 error)

func (*FakeWorker) FindResourceTypeByPath 

func (fake *FakeWorker) FindResourceTypeByPath(path string) (atc.WorkerResourceType, bool)

func (*FakeWorker) FindResourceTypeByPathArgsForCall 

func (fake *FakeWorker) FindResourceTypeByPathArgsForCall(i int) string

func (*FakeWorker) FindResourceTypeByPathCallCount 

func (fake *FakeWorker) FindResourceTypeByPathCallCount() int

func (*FakeWorker) FindResourceTypeByPathReturns 

func (fake *FakeWorker) FindResourceTypeByPathReturns(result1 atc.WorkerResourceType, result2 bool)

func (*FakeWorker) FindResourceTypeByPathReturnsOnCall 

func (fake *FakeWorker) FindResourceTypeByPathReturnsOnCall(i int, result1 atc.WorkerResourceType, result2 bool)

func (*FakeWorker) FindVolumeForResourceCache 

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

func (*FakeWorker) FindVolumeForResourceCacheArgsForCall 

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

func (*FakeWorker) FindVolumeForResourceCacheCallCount 

func (fake *FakeWorker) FindVolumeForResourceCacheCallCount() int

func (*FakeWorker) FindVolumeForResourceCacheReturns 

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

func (*FakeWorker) FindVolumeForResourceCacheReturnsOnCall 

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

func (*FakeWorker) FindVolumeForTaskCache 

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

func (*FakeWorker) FindVolumeForTaskCacheArgsForCall 

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

func (*FakeWorker) FindVolumeForTaskCacheCallCount 

func (fake *FakeWorker) FindVolumeForTaskCacheCallCount() int

func (*FakeWorker) FindVolumeForTaskCacheReturns 

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

func (*FakeWorker) FindVolumeForTaskCacheReturnsOnCall 

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

func (*FakeWorker) GardenClient 

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

func (*FakeWorker) GardenClientCallCount 

func (fake *FakeWorker) GardenClientCallCount() int

func (*FakeWorker) GardenClientReturns 

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

func (*FakeWorker) GardenClientReturnsOnCall 

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

func (*FakeWorker) Invocations 

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

func (*FakeWorker) IsOwnedByTeam 

func (fake *FakeWorker) IsOwnedByTeam() bool

func (*FakeWorker) IsOwnedByTeamCallCount 

func (fake *FakeWorker) IsOwnedByTeamCallCount() int

func (*FakeWorker) IsOwnedByTeamReturns 

func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool)

func (*FakeWorker) IsOwnedByTeamReturnsOnCall 

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

func (*FakeWorker) IsVersionCompatible 

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

func (*FakeWorker) IsVersionCompatibleArgsForCall 

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

func (*FakeWorker) IsVersionCompatibleCallCount 

func (fake *FakeWorker) IsVersionCompatibleCallCount() int

func (*FakeWorker) IsVersionCompatibleReturns 

func (fake *FakeWorker) IsVersionCompatibleReturns(result1 bool)

func (*FakeWorker) IsVersionCompatibleReturnsOnCall 

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

func (*FakeWorker) LookupVolume 

func (fake *FakeWorker) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error)

func (*FakeWorker) LookupVolumeArgsForCall 

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

func (*FakeWorker) LookupVolumeCallCount 

func (fake *FakeWorker) LookupVolumeCallCount() int

func (*FakeWorker) LookupVolumeReturns 

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

func (*FakeWorker) LookupVolumeReturnsOnCall 

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

func (*FakeWorker) Name 

func (fake *FakeWorker) Name() string

func (*FakeWorker) NameCallCount 

func (fake *FakeWorker) NameCallCount() int

func (*FakeWorker) NameReturns 

func (fake *FakeWorker) NameReturns(result1 string)

func (*FakeWorker) NameReturnsOnCall 

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

func (*FakeWorker) ResourceTypes 

func (fake *FakeWorker) ResourceTypes() []atc.WorkerResourceType

func (*FakeWorker) ResourceTypesCallCount 

func (fake *FakeWorker) ResourceTypesCallCount() int

func (*FakeWorker) ResourceTypesReturns 

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

func (*FakeWorker) ResourceTypesReturnsOnCall 

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

func (*FakeWorker) RunningWorkers 

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

func (*FakeWorker) RunningWorkersArgsForCall 

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

func (*FakeWorker) RunningWorkersCallCount 

func (fake *FakeWorker) RunningWorkersCallCount() int

func (*FakeWorker) RunningWorkersReturns 

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

func (*FakeWorker) RunningWorkersReturnsOnCall 

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

func (*FakeWorker) Satisfying 

func (fake *FakeWorker) Satisfying(arg1 lager.Logger, arg2 worker.WorkerSpec, arg3 creds.VersionedResourceTypes) (worker.Worker, error)

func (*FakeWorker) SatisfyingArgsForCall 

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

func (*FakeWorker) SatisfyingCallCount 

func (fake *FakeWorker) SatisfyingCallCount() int

func (*FakeWorker) SatisfyingReturns 

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

func (*FakeWorker) SatisfyingReturnsOnCall 

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

func (*FakeWorker) Tags 

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

func (*FakeWorker) TagsCallCount 

func (fake *FakeWorker) TagsCallCount() int

func (*FakeWorker) TagsReturns 

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

func (*FakeWorker) TagsReturnsOnCall 

func (fake *FakeWorker) TagsReturnsOnCall(i int, result1 atc.Tags)

func (*FakeWorker) Uptime 

func (fake *FakeWorker) Uptime() time.Duration

func (*FakeWorker) UptimeCallCount 

func (fake *FakeWorker) UptimeCallCount() int

func (*FakeWorker) UptimeReturns 

func (fake *FakeWorker) UptimeReturns(result1 time.Duration)

func (*FakeWorker) UptimeReturnsOnCall 

func (fake *FakeWorker) UptimeReturnsOnCall(i int, result1 time.Duration)

type FakeWorkerProvider 

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

	FindWorkerForContainerStub func(logger lager.Logger, teamID int, handle string) (worker.Worker, bool, error)

	FindWorkerForContainerByOwnerStub func(logger lager.Logger, teamID int, owner db.ContainerOwner) (worker.Worker, bool, error)

	NewGardenWorkerStub func(logger lager.Logger, tikTok clock.Clock, savedWorker db.Worker) worker.Worker
	// contains filtered or unexported fields
}

func (*FakeWorkerProvider) FindWorkerForContainer 

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

func (*FakeWorkerProvider) FindWorkerForContainerArgsForCall 

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

func (*FakeWorkerProvider) FindWorkerForContainerByOwner 

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

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerArgsForCall 

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

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerCallCount 

func (fake *FakeWorkerProvider) FindWorkerForContainerByOwnerCallCount() int

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerReturns 

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

func (*FakeWorkerProvider) FindWorkerForContainerByOwnerReturnsOnCall 

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

func (*FakeWorkerProvider) FindWorkerForContainerCallCount 

func (fake *FakeWorkerProvider) FindWorkerForContainerCallCount() int

func (*FakeWorkerProvider) FindWorkerForContainerReturns 

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

func (*FakeWorkerProvider) FindWorkerForContainerReturnsOnCall 

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

func (*FakeWorkerProvider) Invocations 

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

func (*FakeWorkerProvider) NewGardenWorker 

func (fake *FakeWorkerProvider) NewGardenWorker(logger lager.Logger, tikTok clock.Clock, savedWorker db.Worker) worker.Worker

func (*FakeWorkerProvider) NewGardenWorkerArgsForCall 

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

func (*FakeWorkerProvider) NewGardenWorkerCallCount 

func (fake *FakeWorkerProvider) NewGardenWorkerCallCount() int

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