workerfakes

package
v0.0.0-...-484f906 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2016 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeClient 

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

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

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

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

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

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

	CreateVolumeStub func(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

	ListVolumesStub func(lager.Logger, worker.VolumeProperties) ([]worker.Volume, error)

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

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

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

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

	GetWorkerStub func(workerName string) (worker.Worker, error)
	// contains filtered or unexported fields
}

func (*FakeClient) AllSatisfying 

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

func (*FakeClient) AllSatisfyingArgsForCall 

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

func (*FakeClient) AllSatisfyingCallCount 

func (fake *FakeClient) AllSatisfyingCallCount() int

func (*FakeClient) AllSatisfyingReturns 

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

func (*FakeClient) CreateContainer 

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

func (*FakeClient) CreateContainerArgsForCall 

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

func (*FakeClient) CreateContainerCallCount 

func (fake *FakeClient) CreateContainerCallCount() int

func (*FakeClient) CreateContainerReturns 

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

func (*FakeClient) CreateVolume 

func (fake *FakeClient) CreateVolume(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

func (*FakeClient) CreateVolumeArgsForCall 

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

func (*FakeClient) CreateVolumeCallCount 

func (fake *FakeClient) CreateVolumeCallCount() int

func (*FakeClient) CreateVolumeReturns 

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

func (*FakeClient) FindContainerForIdentifier 

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

func (*FakeClient) FindContainerForIdentifierArgsForCall 

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

func (*FakeClient) FindContainerForIdentifierCallCount 

func (fake *FakeClient) FindContainerForIdentifierCallCount() int

func (*FakeClient) FindContainerForIdentifierReturns 

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

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

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

func (*FakeClient) FindVolumeArgsForCall 

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

func (*FakeClient) FindVolumeCallCount 

func (fake *FakeClient) FindVolumeCallCount() int

func (*FakeClient) FindVolumeReturns 

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

func (*FakeClient) GetWorker 

func (fake *FakeClient) GetWorker(workerName string) (worker.Worker, error)

func (*FakeClient) GetWorkerArgsForCall 

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

func (*FakeClient) GetWorkerCallCount 

func (fake *FakeClient) GetWorkerCallCount() int

func (*FakeClient) GetWorkerReturns 

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

func (*FakeClient) Invocations 

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

func (*FakeClient) ListVolumes 

func (fake *FakeClient) ListVolumes(arg1 lager.Logger, arg2 worker.VolumeProperties) ([]worker.Volume, error)

func (*FakeClient) ListVolumesArgsForCall 

func (fake *FakeClient) ListVolumesArgsForCall(i int) (lager.Logger, worker.VolumeProperties)

func (*FakeClient) ListVolumesCallCount 

func (fake *FakeClient) ListVolumesCallCount() int

func (*FakeClient) ListVolumesReturns 

func (fake *FakeClient) ListVolumesReturns(result1 []worker.Volume, result2 error)

func (*FakeClient) LookupContainer 

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

func (*FakeClient) LookupContainerArgsForCall 

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

func (*FakeClient) LookupContainerCallCount 

func (fake *FakeClient) LookupContainerCallCount() int

func (*FakeClient) LookupContainerReturns 

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

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

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

func (*FakeClient) SatisfyingArgsForCall 

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

func (*FakeClient) SatisfyingCallCount 

func (fake *FakeClient) SatisfyingCallCount() int

func (*FakeClient) SatisfyingReturns 

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

func (*FakeClient) ValidateResourceCheckVersion 

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

func (*FakeClient) ValidateResourceCheckVersionArgsForCall 

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

func (*FakeClient) ValidateResourceCheckVersionCallCount 

func (fake *FakeClient) ValidateResourceCheckVersionCallCount() int

func (*FakeClient) ValidateResourceCheckVersionReturns 

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

func (*FakeClient) Workers 

func (fake *FakeClient) Workers() ([]worker.Worker, error)

func (*FakeClient) WorkersCallCount 

func (fake *FakeClient) WorkersCallCount() int

func (*FakeClient) WorkersReturns 

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

	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

	ReleaseStub func(*time.Duration)

	VolumesStub func() []worker.Volume

	VolumeMountsStub func() []worker.VolumeMount

	WorkerNameStub func() string
	// 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) CurrentBandwidthLimits 

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

func (*FakeContainer) CurrentBandwidthLimitsCallCount 

func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int

func (*FakeContainer) CurrentBandwidthLimitsReturns 

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

func (*FakeContainer) CurrentCPULimits 

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

func (*FakeContainer) CurrentCPULimitsCallCount 

func (fake *FakeContainer) CurrentCPULimitsCallCount() int

func (*FakeContainer) CurrentCPULimitsReturns 

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

func (*FakeContainer) CurrentDiskLimits 

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

func (*FakeContainer) CurrentDiskLimitsCallCount 

func (fake *FakeContainer) CurrentDiskLimitsCallCount() int

func (*FakeContainer) CurrentDiskLimitsReturns 

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

func (*FakeContainer) CurrentMemoryLimits 

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

func (*FakeContainer) CurrentMemoryLimitsCallCount 

func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int

func (*FakeContainer) CurrentMemoryLimitsReturns 

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

func (*FakeContainer) Destroy 

func (fake *FakeContainer) Destroy() error

func (*FakeContainer) DestroyCallCount 

func (fake *FakeContainer) DestroyCallCount() int

func (*FakeContainer) DestroyReturns 

func (fake *FakeContainer) DestroyReturns(result1 error)

func (*FakeContainer) Handle 

func (fake *FakeContainer) Handle() string

func (*FakeContainer) HandleCallCount 

func (fake *FakeContainer) HandleCallCount() int

func (*FakeContainer) HandleReturns 

func (fake *FakeContainer) HandleReturns(result1 string)

func (*FakeContainer) Info 

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

func (*FakeContainer) InfoCallCount 

func (fake *FakeContainer) InfoCallCount() int

func (*FakeContainer) InfoReturns 

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

func (*FakeContainer) Invocations 

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

func (*FakeContainer) Metrics 

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

func (*FakeContainer) MetricsCallCount 

func (fake *FakeContainer) MetricsCallCount() int

func (*FakeContainer) MetricsReturns 

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

func (*FakeContainer) NetIn 

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

func (*FakeContainer) NetInArgsForCall 

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

func (*FakeContainer) NetInCallCount 

func (fake *FakeContainer) NetInCallCount() int

func (*FakeContainer) NetInReturns 

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

func (*FakeContainer) NetOut 

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

func (*FakeContainer) NetOutArgsForCall 

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

func (*FakeContainer) NetOutCallCount 

func (fake *FakeContainer) NetOutCallCount() int

func (*FakeContainer) NetOutReturns 

func (fake *FakeContainer) NetOutReturns(result1 error)

func (*FakeContainer) Properties 

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

func (*FakeContainer) PropertiesCallCount 

func (fake *FakeContainer) PropertiesCallCount() int

func (*FakeContainer) PropertiesReturns 

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

func (*FakeContainer) Property 

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

func (*FakeContainer) PropertyArgsForCall 

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

func (*FakeContainer) PropertyCallCount 

func (fake *FakeContainer) PropertyCallCount() int

func (*FakeContainer) PropertyReturns 

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

func (*FakeContainer) Release 

func (fake *FakeContainer) Release(arg1 *time.Duration)

func (*FakeContainer) ReleaseArgsForCall 

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

func (*FakeContainer) ReleaseCallCount 

func (fake *FakeContainer) ReleaseCallCount() int

func (*FakeContainer) RemoveProperty 

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

func (*FakeContainer) RemovePropertyArgsForCall 

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

func (*FakeContainer) RemovePropertyCallCount 

func (fake *FakeContainer) RemovePropertyCallCount() int

func (*FakeContainer) RemovePropertyReturns 

func (fake *FakeContainer) RemovePropertyReturns(result1 error)

func (*FakeContainer) Run 

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

func (*FakeContainer) RunArgsForCall 

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

func (*FakeContainer) RunCallCount 

func (fake *FakeContainer) RunCallCount() int

func (*FakeContainer) RunReturns 

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

func (*FakeContainer) SetGraceTime 

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

func (*FakeContainer) SetGraceTimeArgsForCall 

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

func (*FakeContainer) SetGraceTimeCallCount 

func (fake *FakeContainer) SetGraceTimeCallCount() int

func (*FakeContainer) SetGraceTimeReturns 

func (fake *FakeContainer) SetGraceTimeReturns(result1 error)

func (*FakeContainer) SetProperty 

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

func (*FakeContainer) SetPropertyArgsForCall 

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

func (*FakeContainer) SetPropertyCallCount 

func (fake *FakeContainer) SetPropertyCallCount() int

func (*FakeContainer) SetPropertyReturns 

func (fake *FakeContainer) SetPropertyReturns(result1 error)

func (*FakeContainer) Stop 

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

func (*FakeContainer) StopArgsForCall 

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

func (*FakeContainer) StopCallCount 

func (fake *FakeContainer) StopCallCount() int

func (*FakeContainer) StopReturns 

func (fake *FakeContainer) StopReturns(result1 error)

func (*FakeContainer) StreamIn 

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

func (*FakeContainer) StreamInArgsForCall 

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

func (*FakeContainer) StreamInCallCount 

func (fake *FakeContainer) StreamInCallCount() int

func (*FakeContainer) StreamInReturns 

func (fake *FakeContainer) StreamInReturns(result1 error)

func (*FakeContainer) StreamOut 

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

func (*FakeContainer) StreamOutArgsForCall 

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

func (*FakeContainer) StreamOutCallCount 

func (fake *FakeContainer) StreamOutCallCount() int

func (*FakeContainer) StreamOutReturns 

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

func (*FakeContainer) VolumeMounts 

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

func (*FakeContainer) VolumeMountsCallCount 

func (fake *FakeContainer) VolumeMountsCallCount() int

func (*FakeContainer) VolumeMountsReturns 

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

func (*FakeContainer) Volumes 

func (fake *FakeContainer) Volumes() []worker.Volume

func (*FakeContainer) VolumesCallCount 

func (fake *FakeContainer) VolumesCallCount() int

func (*FakeContainer) VolumesReturns 

func (fake *FakeContainer) VolumesReturns(result1 []worker.Volume)

func (*FakeContainer) WorkerName 

func (fake *FakeContainer) WorkerName() string

func (*FakeContainer) WorkerNameCallCount 

func (fake *FakeContainer) WorkerNameCallCount() int

func (*FakeContainer) WorkerNameReturns 

func (fake *FakeContainer) WorkerNameReturns(result1 string)

type FakeGardenConnectionFactory 

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

func (*FakeGardenConnectionFactory) BuildConnection 

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

func (*FakeGardenConnectionFactory) BuildConnectionCallCount 

func (fake *FakeGardenConnectionFactory) BuildConnectionCallCount() int

func (*FakeGardenConnectionFactory) BuildConnectionReturns 

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

func (*FakeGardenConnectionFactory) Invocations 

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

type FakeGardenWorkerDB 

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

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

	UpdateExpiresAtOnContainerStub func(handle string, ttl time.Duration) error

	ReapContainerStub func(string) error

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

	InsertVolumeStub func(db.Volume) error

	SetVolumeTTLAndSizeInBytesStub func(string, time.Duration, int64) error

	GetVolumeTTLStub func(string) (time.Duration, bool, error)

	GetVolumesByIdentifierStub func(db.VolumeIdentifier) ([]db.SavedVolume, error)
	// contains filtered or unexported fields
}

func (*FakeGardenWorkerDB) CreateContainer 

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

func (*FakeGardenWorkerDB) CreateContainerArgsForCall 

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

func (*FakeGardenWorkerDB) CreateContainerCallCount 

func (fake *FakeGardenWorkerDB) CreateContainerCallCount() int

func (*FakeGardenWorkerDB) CreateContainerReturns 

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

func (*FakeGardenWorkerDB) GetContainer 

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

func (*FakeGardenWorkerDB) GetContainerArgsForCall 

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

func (*FakeGardenWorkerDB) GetContainerCallCount 

func (fake *FakeGardenWorkerDB) GetContainerCallCount() int

func (*FakeGardenWorkerDB) GetContainerReturns 

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

func (*FakeGardenWorkerDB) GetPipelineByID 

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

func (*FakeGardenWorkerDB) GetPipelineByIDArgsForCall 

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

func (*FakeGardenWorkerDB) GetPipelineByIDCallCount 

func (fake *FakeGardenWorkerDB) GetPipelineByIDCallCount() int

func (*FakeGardenWorkerDB) GetPipelineByIDReturns 

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

func (*FakeGardenWorkerDB) GetVolumeTTL 

func (fake *FakeGardenWorkerDB) GetVolumeTTL(arg1 string) (time.Duration, bool, error)

func (*FakeGardenWorkerDB) GetVolumeTTLArgsForCall 

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

func (*FakeGardenWorkerDB) GetVolumeTTLCallCount 

func (fake *FakeGardenWorkerDB) GetVolumeTTLCallCount() int

func (*FakeGardenWorkerDB) GetVolumeTTLReturns 

func (fake *FakeGardenWorkerDB) GetVolumeTTLReturns(result1 time.Duration, result2 bool, result3 error)

func (*FakeGardenWorkerDB) GetVolumesByIdentifier 

func (fake *FakeGardenWorkerDB) GetVolumesByIdentifier(arg1 db.VolumeIdentifier) ([]db.SavedVolume, error)

func (*FakeGardenWorkerDB) GetVolumesByIdentifierArgsForCall 

func (fake *FakeGardenWorkerDB) GetVolumesByIdentifierArgsForCall(i int) db.VolumeIdentifier

func (*FakeGardenWorkerDB) GetVolumesByIdentifierCallCount 

func (fake *FakeGardenWorkerDB) GetVolumesByIdentifierCallCount() int

func (*FakeGardenWorkerDB) GetVolumesByIdentifierReturns 

func (fake *FakeGardenWorkerDB) GetVolumesByIdentifierReturns(result1 []db.SavedVolume, result2 error)

func (*FakeGardenWorkerDB) InsertVolume 

func (fake *FakeGardenWorkerDB) InsertVolume(arg1 db.Volume) error

func (*FakeGardenWorkerDB) InsertVolumeArgsForCall 

func (fake *FakeGardenWorkerDB) InsertVolumeArgsForCall(i int) db.Volume

func (*FakeGardenWorkerDB) InsertVolumeCallCount 

func (fake *FakeGardenWorkerDB) InsertVolumeCallCount() int

func (*FakeGardenWorkerDB) InsertVolumeReturns 

func (fake *FakeGardenWorkerDB) InsertVolumeReturns(result1 error)

func (*FakeGardenWorkerDB) Invocations 

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

func (*FakeGardenWorkerDB) ReapContainer 

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

func (*FakeGardenWorkerDB) ReapContainerArgsForCall 

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

func (*FakeGardenWorkerDB) ReapContainerCallCount 

func (fake *FakeGardenWorkerDB) ReapContainerCallCount() int

func (*FakeGardenWorkerDB) ReapContainerReturns 

func (fake *FakeGardenWorkerDB) ReapContainerReturns(result1 error)

func (*FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytes 

func (fake *FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytes(arg1 string, arg2 time.Duration, arg3 int64) error

func (*FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesArgsForCall 

func (fake *FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesArgsForCall(i int) (string, time.Duration, int64)

func (*FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesCallCount 

func (fake *FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesCallCount() int

func (*FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesReturns 

func (fake *FakeGardenWorkerDB) SetVolumeTTLAndSizeInBytesReturns(result1 error)

func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainer 

func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error

func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerArgsForCall 

func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)

func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerCallCount 

func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerCallCount() int

func (*FakeGardenWorkerDB) UpdateExpiresAtOnContainerReturns 

func (fake *FakeGardenWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)

type FakeImage 

type FakeImage struct {
	FetchStub func() (worker.Volume, io.ReadCloser, atc.Version, error)
	// contains filtered or unexported fields
}

func (*FakeImage) Fetch 

func (fake *FakeImage) Fetch() (worker.Volume, io.ReadCloser, atc.Version, error)

func (*FakeImage) FetchCallCount 

func (fake *FakeImage) FetchCallCount() int

func (*FakeImage) FetchReturns 

func (fake *FakeImage) FetchReturns(result1 worker.Volume, result2 io.ReadCloser, result3 atc.Version, result4 error)

func (*FakeImage) Invocations 

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

type FakeImageFactory 

type FakeImageFactory struct {
	NewImageStub func(logger lager.Logger, cancel <-chan os.Signal, imageResource atc.ImageResource, id worker.Identifier, metadata worker.Metadata, tags atc.Tags, teamID int, resourceTypes atc.ResourceTypes, workerClient worker.Client, delegate worker.ImageFetchingDelegate, privileged bool) worker.Image
	// contains filtered or unexported fields
}

func (*FakeImageFactory) Invocations 

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

func (*FakeImageFactory) NewImage 

func (fake *FakeImageFactory) NewImage(logger lager.Logger, cancel <-chan os.Signal, imageResource atc.ImageResource, id worker.Identifier, metadata worker.Metadata, tags atc.Tags, teamID int, resourceTypes atc.ResourceTypes, workerClient worker.Client, delegate worker.ImageFetchingDelegate, privileged bool) worker.Image

func (*FakeImageFactory) NewImageArgsForCall 

func (fake *FakeImageFactory) NewImageArgsForCall(i int) (lager.Logger, <-chan os.Signal, atc.ImageResource, worker.Identifier, worker.Metadata, atc.Tags, int, atc.ResourceTypes, worker.Client, worker.ImageFetchingDelegate, bool)

func (*FakeImageFactory) NewImageCallCount 

func (fake *FakeImageFactory) NewImageCallCount() int

func (*FakeImageFactory) NewImageReturns 

func (fake *FakeImageFactory) NewImageReturns(result1 worker.Image)

type FakeImageFetchingDelegate 

type FakeImageFetchingDelegate struct {
	StderrStub func() io.Writer

	ImageVersionDeterminedStub func(worker.VolumeIdentifier) error
	// contains filtered or unexported fields
}

func (*FakeImageFetchingDelegate) ImageVersionDetermined 

func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 worker.VolumeIdentifier) error

func (*FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) worker.VolumeIdentifier

func (*FakeImageFetchingDelegate) ImageVersionDeterminedCallCount 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int

func (*FakeImageFetchingDelegate) ImageVersionDeterminedReturns 

func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error)

func (*FakeImageFetchingDelegate) Invocations 

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

func (*FakeImageFetchingDelegate) Stderr 

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

func (*FakeImageFetchingDelegate) StderrCallCount 

func (fake *FakeImageFetchingDelegate) StderrCallCount() int

func (*FakeImageFetchingDelegate) StderrReturns 

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

type FakeSaveWorkerDB 

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

func (*FakeSaveWorkerDB) Invocations 

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

func (*FakeSaveWorkerDB) SaveWorker 

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

func (*FakeSaveWorkerDB) SaveWorkerArgsForCall 

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

func (*FakeSaveWorkerDB) SaveWorkerCallCount 

func (fake *FakeSaveWorkerDB) SaveWorkerCallCount() int

func (*FakeSaveWorkerDB) SaveWorkerReturns 

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

type FakeSleeper 

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

func (*FakeSleeper) Invocations 

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

func (*FakeSleeper) Sleep 

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

func (*FakeSleeper) SleepArgsForCall 

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

func (*FakeSleeper) SleepCallCount 

func (fake *FakeSleeper) SleepCallCount() int

type FakeVolume 

type FakeVolume struct {
	HandleStub func() string

	PathStub func() string

	SetTTLStub func(time.Duration) error

	SetPropertyStub func(key string, value string) error

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

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

	ExpirationStub func() (time.Duration, time.Time, error)

	PropertiesStub func() (baggageclaim.VolumeProperties, error)

	ReleaseStub func(*time.Duration)

	SizeInBytesStub func() (int64, error)

	DestroyStub func() error

	HeartbeatingToDBStub func()
	// contains filtered or unexported fields
}

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

func (fake *FakeVolume) Expiration() (time.Duration, time.Time, error)

func (*FakeVolume) ExpirationCallCount 

func (fake *FakeVolume) ExpirationCallCount() int

func (*FakeVolume) ExpirationReturns 

func (fake *FakeVolume) ExpirationReturns(result1 time.Duration, result2 time.Time, result3 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) HeartbeatingToDB 

func (fake *FakeVolume) HeartbeatingToDB()

func (*FakeVolume) HeartbeatingToDBCallCount 

func (fake *FakeVolume) HeartbeatingToDBCallCount() int

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

func (fake *FakeVolume) Release(arg1 *time.Duration)

func (*FakeVolume) ReleaseArgsForCall 

func (fake *FakeVolume) ReleaseArgsForCall(i int) *time.Duration

func (*FakeVolume) ReleaseCallCount 

func (fake *FakeVolume) ReleaseCallCount() int

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

func (fake *FakeVolume) SetTTL(arg1 time.Duration) error

func (*FakeVolume) SetTTLArgsForCall 

func (fake *FakeVolume) SetTTLArgsForCall(i int) time.Duration

func (*FakeVolume) SetTTLCallCount 

func (fake *FakeVolume) SetTTLCallCount() int

func (*FakeVolume) SetTTLReturns 

func (fake *FakeVolume) SetTTLReturns(result1 error)

func (*FakeVolume) SizeInBytes 

func (fake *FakeVolume) SizeInBytes() (int64, error)

func (*FakeVolume) SizeInBytesCallCount 

func (fake *FakeVolume) SizeInBytesCallCount() int

func (*FakeVolume) SizeInBytesReturns 

func (fake *FakeVolume) SizeInBytesReturns(result1 int64, result2 error)

func (*FakeVolume) StreamIn 

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

func (*FakeVolume) StreamInArgsForCall 

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

func (*FakeVolume) StreamInCallCount 

func (fake *FakeVolume) StreamInCallCount() int

func (*FakeVolume) StreamInReturns 

func (fake *FakeVolume) StreamInReturns(result1 error)

func (*FakeVolume) StreamOut 

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

func (*FakeVolume) StreamOutArgsForCall 

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

func (*FakeVolume) StreamOutCallCount 

func (fake *FakeVolume) StreamOutCallCount() int

func (*FakeVolume) StreamOutReturns 

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

type FakeVolumeClient 

type FakeVolumeClient struct {
	FindVolumeStub func(lager.Logger, worker.VolumeSpec) (worker.Volume, bool, error)

	CreateVolumeStub func(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

	ListVolumesStub func(lager.Logger, worker.VolumeProperties) ([]worker.Volume, error)

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

func (*FakeVolumeClient) CreateVolume 

func (fake *FakeVolumeClient) CreateVolume(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

func (*FakeVolumeClient) CreateVolumeArgsForCall 

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

func (*FakeVolumeClient) CreateVolumeCallCount 

func (fake *FakeVolumeClient) CreateVolumeCallCount() int

func (*FakeVolumeClient) CreateVolumeReturns 

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

func (*FakeVolumeClient) FindVolume 

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

func (*FakeVolumeClient) FindVolumeArgsForCall 

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

func (*FakeVolumeClient) FindVolumeCallCount 

func (fake *FakeVolumeClient) FindVolumeCallCount() int

func (*FakeVolumeClient) FindVolumeReturns 

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

func (*FakeVolumeClient) Invocations 

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

func (*FakeVolumeClient) ListVolumes 

func (fake *FakeVolumeClient) ListVolumes(arg1 lager.Logger, arg2 worker.VolumeProperties) ([]worker.Volume, error)

func (*FakeVolumeClient) ListVolumesArgsForCall 

func (fake *FakeVolumeClient) ListVolumesArgsForCall(i int) (lager.Logger, worker.VolumeProperties)

func (*FakeVolumeClient) ListVolumesCallCount 

func (fake *FakeVolumeClient) ListVolumesCallCount() int

func (*FakeVolumeClient) ListVolumesReturns 

func (fake *FakeVolumeClient) ListVolumesReturns(result1 []worker.Volume, result2 error)

func (*FakeVolumeClient) LookupVolume 

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

func (*FakeVolumeClient) LookupVolumeArgsForCall 

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

func (*FakeVolumeClient) LookupVolumeCallCount 

func (fake *FakeVolumeClient) LookupVolumeCallCount() int

func (*FakeVolumeClient) LookupVolumeReturns 

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

type FakeVolumeFactory 

type FakeVolumeFactory struct {
	BuildStub func(lager.Logger, baggageclaim.Volume) (worker.Volume, bool, error)
	// contains filtered or unexported fields
}

func (*FakeVolumeFactory) Build 

func (fake *FakeVolumeFactory) Build(arg1 lager.Logger, arg2 baggageclaim.Volume) (worker.Volume, bool, error)

func (*FakeVolumeFactory) BuildArgsForCall 

func (fake *FakeVolumeFactory) BuildArgsForCall(i int) (lager.Logger, baggageclaim.Volume)

func (*FakeVolumeFactory) BuildCallCount 

func (fake *FakeVolumeFactory) BuildCallCount() int

func (*FakeVolumeFactory) BuildReturns 

func (fake *FakeVolumeFactory) BuildReturns(result1 worker.Volume, result2 bool, result3 error)

func (*FakeVolumeFactory) Invocations 

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

type FakeVolumeFactoryDB 

type FakeVolumeFactoryDB struct {
	GetVolumeTTLStub func(volumeHandle string) (time.Duration, bool, error)

	ReapVolumeStub func(handle string) error

	SetVolumeTTLAndSizeInBytesStub func(handle string, ttl time.Duration, sizeInBytes int64) error

	SetVolumeTTLStub func(handle string, ttl time.Duration) error
	// contains filtered or unexported fields
}

func (*FakeVolumeFactoryDB) GetVolumeTTL 

func (fake *FakeVolumeFactoryDB) GetVolumeTTL(volumeHandle string) (time.Duration, bool, error)

func (*FakeVolumeFactoryDB) GetVolumeTTLArgsForCall 

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

func (*FakeVolumeFactoryDB) GetVolumeTTLCallCount 

func (fake *FakeVolumeFactoryDB) GetVolumeTTLCallCount() int

func (*FakeVolumeFactoryDB) GetVolumeTTLReturns 

func (fake *FakeVolumeFactoryDB) GetVolumeTTLReturns(result1 time.Duration, result2 bool, result3 error)

func (*FakeVolumeFactoryDB) Invocations 

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

func (*FakeVolumeFactoryDB) ReapVolume 

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

func (*FakeVolumeFactoryDB) ReapVolumeArgsForCall 

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

func (*FakeVolumeFactoryDB) ReapVolumeCallCount 

func (fake *FakeVolumeFactoryDB) ReapVolumeCallCount() int

func (*FakeVolumeFactoryDB) ReapVolumeReturns 

func (fake *FakeVolumeFactoryDB) ReapVolumeReturns(result1 error)

func (*FakeVolumeFactoryDB) SetVolumeTTL 

func (fake *FakeVolumeFactoryDB) SetVolumeTTL(handle string, ttl time.Duration) error

func (*FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytes 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytes(handle string, ttl time.Duration, sizeInBytes int64) error

func (*FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesArgsForCall 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesArgsForCall(i int) (string, time.Duration, int64)

func (*FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesCallCount 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesCallCount() int

func (*FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesReturns 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLAndSizeInBytesReturns(result1 error)

func (*FakeVolumeFactoryDB) SetVolumeTTLArgsForCall 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)

func (*FakeVolumeFactoryDB) SetVolumeTTLCallCount 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLCallCount() int

func (*FakeVolumeFactoryDB) SetVolumeTTLReturns 

func (fake *FakeVolumeFactoryDB) SetVolumeTTLReturns(result1 error)

type FakeWorker 

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

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

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

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

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

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

	CreateVolumeStub func(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

	ListVolumesStub func(lager.Logger, worker.VolumeProperties) ([]worker.Volume, error)

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

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

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

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

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

	ActiveContainersStub func() int

	DescriptionStub func() string

	NameStub func() string

	UptimeStub func() time.Duration

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

func (*FakeWorker) ActiveContainers 

func (fake *FakeWorker) ActiveContainers() int

func (*FakeWorker) ActiveContainersCallCount 

func (fake *FakeWorker) ActiveContainersCallCount() int

func (*FakeWorker) ActiveContainersReturns 

func (fake *FakeWorker) ActiveContainersReturns(result1 int)

func (*FakeWorker) AllSatisfying 

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

func (*FakeWorker) AllSatisfyingArgsForCall 

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

func (*FakeWorker) AllSatisfyingCallCount 

func (fake *FakeWorker) AllSatisfyingCallCount() int

func (*FakeWorker) AllSatisfyingReturns 

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

func (*FakeWorker) CreateContainer 

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

func (*FakeWorker) CreateContainerArgsForCall 

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

func (*FakeWorker) CreateContainerCallCount 

func (fake *FakeWorker) CreateContainerCallCount() int

func (*FakeWorker) CreateContainerReturns 

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

func (*FakeWorker) CreateVolume 

func (fake *FakeWorker) CreateVolume(logger lager.Logger, vs worker.VolumeSpec, teamID int) (worker.Volume, error)

func (*FakeWorker) CreateVolumeArgsForCall 

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

func (*FakeWorker) CreateVolumeCallCount 

func (fake *FakeWorker) CreateVolumeCallCount() int

func (*FakeWorker) CreateVolumeReturns 

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

func (*FakeWorker) Description 

func (fake *FakeWorker) Description() string

func (*FakeWorker) DescriptionCallCount 

func (fake *FakeWorker) DescriptionCallCount() int

func (*FakeWorker) DescriptionReturns 

func (fake *FakeWorker) DescriptionReturns(result1 string)

func (*FakeWorker) FindContainerForIdentifier 

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

func (*FakeWorker) FindContainerForIdentifierArgsForCall 

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

func (*FakeWorker) FindContainerForIdentifierCallCount 

func (fake *FakeWorker) FindContainerForIdentifierCallCount() int

func (*FakeWorker) FindContainerForIdentifierReturns 

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

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

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

func (*FakeWorker) FindVolumeArgsForCall 

func (fake *FakeWorker) FindVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec)

func (*FakeWorker) FindVolumeCallCount 

func (fake *FakeWorker) FindVolumeCallCount() int

func (*FakeWorker) FindVolumeReturns 

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

func (*FakeWorker) GetWorker 

func (fake *FakeWorker) GetWorker(workerName string) (worker.Worker, error)

func (*FakeWorker) GetWorkerArgsForCall 

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

func (*FakeWorker) GetWorkerCallCount 

func (fake *FakeWorker) GetWorkerCallCount() int

func (*FakeWorker) GetWorkerReturns 

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

func (*FakeWorker) Invocations 

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

func (*FakeWorker) IsOwnedByTeam 

func (fake *FakeWorker) IsOwnedByTeam() bool

func (*FakeWorker) IsOwnedByTeamCallCount 

func (fake *FakeWorker) IsOwnedByTeamCallCount() int

func (*FakeWorker) IsOwnedByTeamReturns 

func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool)

func (*FakeWorker) ListVolumes 

func (fake *FakeWorker) ListVolumes(arg1 lager.Logger, arg2 worker.VolumeProperties) ([]worker.Volume, error)

func (*FakeWorker) ListVolumesArgsForCall 

func (fake *FakeWorker) ListVolumesArgsForCall(i int) (lager.Logger, worker.VolumeProperties)

func (*FakeWorker) ListVolumesCallCount 

func (fake *FakeWorker) ListVolumesCallCount() int

func (*FakeWorker) ListVolumesReturns 

func (fake *FakeWorker) ListVolumesReturns(result1 []worker.Volume, result2 error)

func (*FakeWorker) LookupContainer 

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

func (*FakeWorker) LookupContainerArgsForCall 

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

func (*FakeWorker) LookupContainerCallCount 

func (fake *FakeWorker) LookupContainerCallCount() int

func (*FakeWorker) LookupContainerReturns 

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

func (*FakeWorker) LookupVolume 

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

func (*FakeWorker) LookupVolumeArgsForCall 

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

func (*FakeWorker) LookupVolumeCallCount 

func (fake *FakeWorker) LookupVolumeCallCount() int

func (*FakeWorker) LookupVolumeReturns 

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

func (*FakeWorker) Name 

func (fake *FakeWorker) Name() string

func (*FakeWorker) NameCallCount 

func (fake *FakeWorker) NameCallCount() int

func (*FakeWorker) NameReturns 

func (fake *FakeWorker) NameReturns(result1 string)

func (*FakeWorker) Satisfying 

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

func (*FakeWorker) SatisfyingArgsForCall 

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

func (*FakeWorker) SatisfyingCallCount 

func (fake *FakeWorker) SatisfyingCallCount() int

func (*FakeWorker) SatisfyingReturns 

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

func (*FakeWorker) Uptime 

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

func (*FakeWorker) UptimeCallCount 

func (fake *FakeWorker) UptimeCallCount() int

func (*FakeWorker) UptimeReturns 

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

func (*FakeWorker) ValidateResourceCheckVersion 

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

func (*FakeWorker) ValidateResourceCheckVersionArgsForCall 

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

func (*FakeWorker) ValidateResourceCheckVersionCallCount 

func (fake *FakeWorker) ValidateResourceCheckVersionCallCount() int

func (*FakeWorker) ValidateResourceCheckVersionReturns 

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

func (*FakeWorker) Workers 

func (fake *FakeWorker) Workers() ([]worker.Worker, error)

func (*FakeWorker) WorkersCallCount 

func (fake *FakeWorker) WorkersCallCount() int

func (*FakeWorker) WorkersReturns 

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

type FakeWorkerDB 

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

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

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

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

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

	UpdateExpiresAtOnContainerStub func(handle string, ttl time.Duration) error

	ReapContainerStub func(handle string) error

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

	InsertVolumeStub func(db.Volume) error

	GetVolumesByIdentifierStub func(db.VolumeIdentifier) ([]db.SavedVolume, error)

	GetVolumeTTLStub func(volumeHandle string) (time.Duration, bool, error)

	ReapVolumeStub func(handle string) error

	SetVolumeTTLAndSizeInBytesStub func(string, time.Duration, int64) error

	SetVolumeTTLStub func(string, time.Duration) error
	// contains filtered or unexported fields
}

func (*FakeWorkerDB) CreateContainer 

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

func (*FakeWorkerDB) CreateContainerArgsForCall 

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

func (*FakeWorkerDB) CreateContainerCallCount 

func (fake *FakeWorkerDB) CreateContainerCallCount() int

func (*FakeWorkerDB) CreateContainerReturns 

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

func (*FakeWorkerDB) FindContainerByIdentifier 

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

func (*FakeWorkerDB) FindContainerByIdentifierArgsForCall 

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

func (*FakeWorkerDB) FindContainerByIdentifierCallCount 

func (fake *FakeWorkerDB) FindContainerByIdentifierCallCount() int

func (*FakeWorkerDB) FindContainerByIdentifierReturns 

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

func (*FakeWorkerDB) GetContainer 

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

func (*FakeWorkerDB) GetContainerArgsForCall 

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

func (*FakeWorkerDB) GetContainerCallCount 

func (fake *FakeWorkerDB) GetContainerCallCount() int

func (*FakeWorkerDB) GetContainerReturns 

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

func (*FakeWorkerDB) GetPipelineByID 

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

func (*FakeWorkerDB) GetPipelineByIDArgsForCall 

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

func (*FakeWorkerDB) GetPipelineByIDCallCount 

func (fake *FakeWorkerDB) GetPipelineByIDCallCount() int

func (*FakeWorkerDB) GetPipelineByIDReturns 

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

func (*FakeWorkerDB) GetVolumeTTL 

func (fake *FakeWorkerDB) GetVolumeTTL(volumeHandle string) (time.Duration, bool, error)

func (*FakeWorkerDB) GetVolumeTTLArgsForCall 

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

func (*FakeWorkerDB) GetVolumeTTLCallCount 

func (fake *FakeWorkerDB) GetVolumeTTLCallCount() int

func (*FakeWorkerDB) GetVolumeTTLReturns 

func (fake *FakeWorkerDB) GetVolumeTTLReturns(result1 time.Duration, result2 bool, result3 error)

func (*FakeWorkerDB) GetVolumesByIdentifier 

func (fake *FakeWorkerDB) GetVolumesByIdentifier(arg1 db.VolumeIdentifier) ([]db.SavedVolume, error)

func (*FakeWorkerDB) GetVolumesByIdentifierArgsForCall 

func (fake *FakeWorkerDB) GetVolumesByIdentifierArgsForCall(i int) db.VolumeIdentifier

func (*FakeWorkerDB) GetVolumesByIdentifierCallCount 

func (fake *FakeWorkerDB) GetVolumesByIdentifierCallCount() int

func (*FakeWorkerDB) GetVolumesByIdentifierReturns 

func (fake *FakeWorkerDB) GetVolumesByIdentifierReturns(result1 []db.SavedVolume, result2 error)

func (*FakeWorkerDB) GetWorker 

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

func (*FakeWorkerDB) GetWorkerArgsForCall 

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

func (*FakeWorkerDB) GetWorkerCallCount 

func (fake *FakeWorkerDB) GetWorkerCallCount() int

func (*FakeWorkerDB) GetWorkerReturns 

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

func (*FakeWorkerDB) InsertVolume 

func (fake *FakeWorkerDB) InsertVolume(arg1 db.Volume) error

func (*FakeWorkerDB) InsertVolumeArgsForCall 

func (fake *FakeWorkerDB) InsertVolumeArgsForCall(i int) db.Volume

func (*FakeWorkerDB) InsertVolumeCallCount 

func (fake *FakeWorkerDB) InsertVolumeCallCount() int

func (*FakeWorkerDB) InsertVolumeReturns 

func (fake *FakeWorkerDB) InsertVolumeReturns(result1 error)

func (*FakeWorkerDB) Invocations 

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

func (*FakeWorkerDB) ReapContainer 

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

func (*FakeWorkerDB) ReapContainerArgsForCall 

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

func (*FakeWorkerDB) ReapContainerCallCount 

func (fake *FakeWorkerDB) ReapContainerCallCount() int

func (*FakeWorkerDB) ReapContainerReturns 

func (fake *FakeWorkerDB) ReapContainerReturns(result1 error)

func (*FakeWorkerDB) ReapVolume 

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

func (*FakeWorkerDB) ReapVolumeArgsForCall 

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

func (*FakeWorkerDB) ReapVolumeCallCount 

func (fake *FakeWorkerDB) ReapVolumeCallCount() int

func (*FakeWorkerDB) ReapVolumeReturns 

func (fake *FakeWorkerDB) ReapVolumeReturns(result1 error)

func (*FakeWorkerDB) SetVolumeTTL 

func (fake *FakeWorkerDB) SetVolumeTTL(arg1 string, arg2 time.Duration) error

func (*FakeWorkerDB) SetVolumeTTLAndSizeInBytes 

func (fake *FakeWorkerDB) SetVolumeTTLAndSizeInBytes(arg1 string, arg2 time.Duration, arg3 int64) error

func (*FakeWorkerDB) SetVolumeTTLAndSizeInBytesArgsForCall 

func (fake *FakeWorkerDB) SetVolumeTTLAndSizeInBytesArgsForCall(i int) (string, time.Duration, int64)

func (*FakeWorkerDB) SetVolumeTTLAndSizeInBytesCallCount 

func (fake *FakeWorkerDB) SetVolumeTTLAndSizeInBytesCallCount() int

func (*FakeWorkerDB) SetVolumeTTLAndSizeInBytesReturns 

func (fake *FakeWorkerDB) SetVolumeTTLAndSizeInBytesReturns(result1 error)

func (*FakeWorkerDB) SetVolumeTTLArgsForCall 

func (fake *FakeWorkerDB) SetVolumeTTLArgsForCall(i int) (string, time.Duration)

func (*FakeWorkerDB) SetVolumeTTLCallCount 

func (fake *FakeWorkerDB) SetVolumeTTLCallCount() int

func (*FakeWorkerDB) SetVolumeTTLReturns 

func (fake *FakeWorkerDB) SetVolumeTTLReturns(result1 error)

func (*FakeWorkerDB) UpdateExpiresAtOnContainer 

func (fake *FakeWorkerDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error

func (*FakeWorkerDB) UpdateExpiresAtOnContainerArgsForCall 

func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerArgsForCall(i int) (string, time.Duration)

func (*FakeWorkerDB) UpdateExpiresAtOnContainerCallCount 

func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerCallCount() int

func (*FakeWorkerDB) UpdateExpiresAtOnContainerReturns 

func (fake *FakeWorkerDB) UpdateExpiresAtOnContainerReturns(result1 error)

func (*FakeWorkerDB) Workers 

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

func (*FakeWorkerDB) WorkersCallCount 

func (fake *FakeWorkerDB) WorkersCallCount() int

func (*FakeWorkerDB) WorkersReturns 

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

type FakeWorkerProvider 

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

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

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

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

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

func (*FakeWorkerProvider) FindContainerForIdentifier 

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

func (*FakeWorkerProvider) FindContainerForIdentifierArgsForCall 

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

func (*FakeWorkerProvider) FindContainerForIdentifierCallCount 

func (fake *FakeWorkerProvider) FindContainerForIdentifierCallCount() int

func (*FakeWorkerProvider) FindContainerForIdentifierReturns 

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

func (*FakeWorkerProvider) GetContainer 

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

func (*FakeWorkerProvider) GetContainerArgsForCall 

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

func (*FakeWorkerProvider) GetContainerCallCount 

func (fake *FakeWorkerProvider) GetContainerCallCount() int

func (*FakeWorkerProvider) GetContainerReturns 

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

func (*FakeWorkerProvider) GetWorker 

func (fake *FakeWorkerProvider) GetWorker(arg1 string) (worker.Worker, bool, error)

func (*FakeWorkerProvider) GetWorkerArgsForCall 

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

func (*FakeWorkerProvider) GetWorkerCallCount 

func (fake *FakeWorkerProvider) GetWorkerCallCount() int

func (*FakeWorkerProvider) GetWorkerReturns 

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

func (*FakeWorkerProvider) Invocations 

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

func (*FakeWorkerProvider) ReapContainer 

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

func (*FakeWorkerProvider) ReapContainerArgsForCall 

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

func (*FakeWorkerProvider) ReapContainerCallCount 

func (fake *FakeWorkerProvider) ReapContainerCallCount() int

func (*FakeWorkerProvider) ReapContainerReturns 

func (fake *FakeWorkerProvider) ReapContainerReturns(result1 error)

func (*FakeWorkerProvider) Workers 

func (fake *FakeWorkerProvider) Workers() ([]worker.Worker, error)

func (*FakeWorkerProvider) WorkersCallCount 

func (fake *FakeWorkerProvider) WorkersCallCount() int

func (*FakeWorkerProvider) WorkersReturns 

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