Versions in this module Expand all Collapse all v6 v6.4.2 Aug 17, 2020 Changes in this version + type FakeArtifactDestination struct + StreamInStub func(context.Context, string, baggageclaim.Encoding, io.Reader) error + func (fake *FakeArtifactDestination) Invocations() map[string][][]interface{} + func (fake *FakeArtifactDestination) StreamIn(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding, arg4 io.Reader) error + func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (context.Context, string, baggageclaim.Encoding, io.Reader) + func (fake *FakeArtifactDestination) StreamInCallCount() int + func (fake *FakeArtifactDestination) StreamInCalls(stub func(context.Context, string, baggageclaim.Encoding, io.Reader) error) + func (fake *FakeArtifactDestination) StreamInReturns(result1 error) + func (fake *FakeArtifactDestination) StreamInReturnsOnCall(i int, result1 error) + type FakeArtifactSource struct + ExistsOnStub func(lager.Logger, worker.Worker) (worker.Volume, bool, error) + func (fake *FakeArtifactSource) ExistsOn(arg1 lager.Logger, arg2 worker.Worker) (worker.Volume, bool, error) + func (fake *FakeArtifactSource) ExistsOnArgsForCall(i int) (lager.Logger, worker.Worker) + func (fake *FakeArtifactSource) ExistsOnCallCount() int + func (fake *FakeArtifactSource) ExistsOnCalls(stub func(lager.Logger, worker.Worker) (worker.Volume, bool, error)) + func (fake *FakeArtifactSource) ExistsOnReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeArtifactSource) ExistsOnReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeArtifactSource) Invocations() map[string][][]interface{} + type FakeBindMountSource struct + VolumeOnStub func(worker.Worker) (garden.BindMount, bool, error) + func (fake *FakeBindMountSource) Invocations() map[string][][]interface{} + func (fake *FakeBindMountSource) VolumeOn(arg1 worker.Worker) (garden.BindMount, bool, error) + func (fake *FakeBindMountSource) VolumeOnArgsForCall(i int) worker.Worker + func (fake *FakeBindMountSource) VolumeOnCallCount() int + func (fake *FakeBindMountSource) VolumeOnCalls(stub func(worker.Worker) (garden.BindMount, bool, error)) + func (fake *FakeBindMountSource) VolumeOnReturns(result1 garden.BindMount, result2 bool, result3 error) + func (fake *FakeBindMountSource) VolumeOnReturnsOnCall(i int, result1 garden.BindMount, result2 bool, result3 error) + type FakeClient struct + CreateVolumeStub func(lager.Logger, worker.VolumeSpec, worker.WorkerSpec, db.VolumeType) (worker.Volume, error) + FindContainerStub func(lager.Logger, int, string) (worker.Container, bool, error) + FindVolumeStub func(lager.Logger, int, string) (worker.Volume, bool, error) + RunCheckStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) (worker.CheckResult, error) + RunGetStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) (worker.GetResult, error) + RunPutStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) (worker.PutResult, error) + RunTaskStepStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) (worker.TaskResult, error) + StreamFileFromArtifactStub func(context.Context, lager.Logger, runtime.Artifact, string) (io.ReadCloser, error) + func (fake *FakeClient) CreateVolume(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 worker.WorkerSpec, ...) (worker.Volume, error) + func (fake *FakeClient) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, worker.WorkerSpec, db.VolumeType) + func (fake *FakeClient) CreateVolumeCallCount() int + func (fake *FakeClient) CreateVolumeCalls(...) + func (fake *FakeClient) CreateVolumeReturns(result1 worker.Volume, result2 error) + func (fake *FakeClient) CreateVolumeReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeClient) FindContainer(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error) + func (fake *FakeClient) FindContainerArgsForCall(i int) (lager.Logger, int, string) + func (fake *FakeClient) FindContainerCallCount() int + func (fake *FakeClient) FindContainerCalls(stub func(lager.Logger, int, string) (worker.Container, bool, error)) + func (fake *FakeClient) FindContainerReturns(result1 worker.Container, result2 bool, result3 error) + func (fake *FakeClient) FindContainerReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error) + func (fake *FakeClient) FindVolume(arg1 lager.Logger, arg2 int, arg3 string) (worker.Volume, bool, error) + func (fake *FakeClient) FindVolumeArgsForCall(i int) (lager.Logger, int, string) + func (fake *FakeClient) FindVolumeCallCount() int + func (fake *FakeClient) FindVolumeCalls(stub func(lager.Logger, int, string) (worker.Volume, bool, error)) + func (fake *FakeClient) FindVolumeReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeClient) FindVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeClient) Invocations() map[string][][]interface{} + func (fake *FakeClient) RunCheckStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, ...) (worker.CheckResult, error) + func (fake *FakeClient) RunCheckStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) + func (fake *FakeClient) RunCheckStepCallCount() int + func (fake *FakeClient) RunCheckStepCalls(...) + func (fake *FakeClient) RunCheckStepReturns(result1 worker.CheckResult, result2 error) + func (fake *FakeClient) RunCheckStepReturnsOnCall(i int, result1 worker.CheckResult, result2 error) + func (fake *FakeClient) RunGetStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, ...) (worker.GetResult, error) + func (fake *FakeClient) RunGetStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) + func (fake *FakeClient) RunGetStepCallCount() int + func (fake *FakeClient) RunGetStepCalls(...) + func (fake *FakeClient) RunGetStepReturns(result1 worker.GetResult, result2 error) + func (fake *FakeClient) RunGetStepReturnsOnCall(i int, result1 worker.GetResult, result2 error) + func (fake *FakeClient) RunPutStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, ...) (worker.PutResult, error) + func (fake *FakeClient) RunPutStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) + func (fake *FakeClient) RunPutStepCallCount() int + func (fake *FakeClient) RunPutStepCalls(...) + func (fake *FakeClient) RunPutStepReturns(result1 worker.PutResult, result2 error) + func (fake *FakeClient) RunPutStepReturnsOnCall(i int, result1 worker.PutResult, result2 error) + func (fake *FakeClient) RunTaskStep(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, ...) (worker.TaskResult, error) + func (fake *FakeClient) RunTaskStepArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) + func (fake *FakeClient) RunTaskStepCallCount() int + func (fake *FakeClient) RunTaskStepCalls(...) + func (fake *FakeClient) RunTaskStepReturns(result1 worker.TaskResult, result2 error) + func (fake *FakeClient) RunTaskStepReturnsOnCall(i int, result1 worker.TaskResult, result2 error) + func (fake *FakeClient) StreamFileFromArtifact(arg1 context.Context, arg2 lager.Logger, arg3 runtime.Artifact, arg4 string) (io.ReadCloser, error) + func (fake *FakeClient) StreamFileFromArtifactArgsForCall(i int) (context.Context, lager.Logger, runtime.Artifact, string) + func (fake *FakeClient) StreamFileFromArtifactCallCount() int + func (fake *FakeClient) StreamFileFromArtifactCalls(...) + func (fake *FakeClient) StreamFileFromArtifactReturns(result1 io.ReadCloser, result2 error) + func (fake *FakeClient) StreamFileFromArtifactReturnsOnCall(i int, result1 io.ReadCloser, result2 error) + type FakeContainer struct + AttachStub func(context.Context, string, garden.ProcessIO) (garden.Process, error) + BulkNetOutStub func([]garden.NetOutRule) error + CurrentBandwidthLimitsStub func() (garden.BandwidthLimits, error) + CurrentCPULimitsStub func() (garden.CPULimits, error) + CurrentDiskLimitsStub func() (garden.DiskLimits, error) + CurrentMemoryLimitsStub func() (garden.MemoryLimits, error) + DestroyStub func() error + HandleStub func() string + InfoStub func() (garden.ContainerInfo, error) + MetricsStub func() (garden.Metrics, error) + NetInStub func(uint32, uint32) (uint32, uint32, error) + NetOutStub func(garden.NetOutRule) error + PropertiesStub func() (garden.Properties, error) + PropertyStub func(string) (string, error) + RemovePropertyStub func(string) error + RunScriptStub func(context.Context, string, []string, []byte, interface{}, io.Writer, bool) error + RunStub func(context.Context, garden.ProcessSpec, garden.ProcessIO) (garden.Process, error) + SetGraceTimeStub func(time.Duration) error + SetPropertyStub func(string, string) error + StopStub func(bool) error + StreamInStub func(garden.StreamInSpec) error + StreamOutStub func(garden.StreamOutSpec) (io.ReadCloser, error) + UpdateLastHijackStub func() error + VolumeMountsStub func() []worker.VolumeMount + WorkerNameStub func() string + func (fake *FakeContainer) Attach(arg1 context.Context, arg2 string, arg3 garden.ProcessIO) (garden.Process, error) + func (fake *FakeContainer) AttachArgsForCall(i int) (context.Context, string, garden.ProcessIO) + func (fake *FakeContainer) AttachCallCount() int + func (fake *FakeContainer) AttachCalls(stub func(context.Context, string, garden.ProcessIO) (garden.Process, error)) + func (fake *FakeContainer) AttachReturns(result1 garden.Process, result2 error) + func (fake *FakeContainer) AttachReturnsOnCall(i int, result1 garden.Process, result2 error) + func (fake *FakeContainer) BulkNetOut(arg1 []garden.NetOutRule) error + func (fake *FakeContainer) BulkNetOutArgsForCall(i int) []garden.NetOutRule + func (fake *FakeContainer) BulkNetOutCallCount() int + func (fake *FakeContainer) BulkNetOutCalls(stub func([]garden.NetOutRule) error) + func (fake *FakeContainer) BulkNetOutReturns(result1 error) + func (fake *FakeContainer) BulkNetOutReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) CurrentBandwidthLimits() (garden.BandwidthLimits, error) + func (fake *FakeContainer) CurrentBandwidthLimitsCallCount() int + func (fake *FakeContainer) CurrentBandwidthLimitsCalls(stub func() (garden.BandwidthLimits, error)) + func (fake *FakeContainer) CurrentBandwidthLimitsReturns(result1 garden.BandwidthLimits, result2 error) + func (fake *FakeContainer) CurrentBandwidthLimitsReturnsOnCall(i int, result1 garden.BandwidthLimits, result2 error) + func (fake *FakeContainer) CurrentCPULimits() (garden.CPULimits, error) + func (fake *FakeContainer) CurrentCPULimitsCallCount() int + func (fake *FakeContainer) CurrentCPULimitsCalls(stub func() (garden.CPULimits, error)) + func (fake *FakeContainer) CurrentCPULimitsReturns(result1 garden.CPULimits, result2 error) + func (fake *FakeContainer) CurrentCPULimitsReturnsOnCall(i int, result1 garden.CPULimits, result2 error) + func (fake *FakeContainer) CurrentDiskLimits() (garden.DiskLimits, error) + func (fake *FakeContainer) CurrentDiskLimitsCallCount() int + func (fake *FakeContainer) CurrentDiskLimitsCalls(stub func() (garden.DiskLimits, error)) + func (fake *FakeContainer) CurrentDiskLimitsReturns(result1 garden.DiskLimits, result2 error) + func (fake *FakeContainer) CurrentDiskLimitsReturnsOnCall(i int, result1 garden.DiskLimits, result2 error) + func (fake *FakeContainer) CurrentMemoryLimits() (garden.MemoryLimits, error) + func (fake *FakeContainer) CurrentMemoryLimitsCallCount() int + func (fake *FakeContainer) CurrentMemoryLimitsCalls(stub func() (garden.MemoryLimits, error)) + func (fake *FakeContainer) CurrentMemoryLimitsReturns(result1 garden.MemoryLimits, result2 error) + func (fake *FakeContainer) CurrentMemoryLimitsReturnsOnCall(i int, result1 garden.MemoryLimits, result2 error) + func (fake *FakeContainer) Destroy() error + func (fake *FakeContainer) DestroyCallCount() int + func (fake *FakeContainer) DestroyCalls(stub func() error) + func (fake *FakeContainer) DestroyReturns(result1 error) + func (fake *FakeContainer) DestroyReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) Handle() string + func (fake *FakeContainer) HandleCallCount() int + func (fake *FakeContainer) HandleCalls(stub func() string) + func (fake *FakeContainer) HandleReturns(result1 string) + func (fake *FakeContainer) HandleReturnsOnCall(i int, result1 string) + func (fake *FakeContainer) Info() (garden.ContainerInfo, error) + func (fake *FakeContainer) InfoCallCount() int + func (fake *FakeContainer) InfoCalls(stub func() (garden.ContainerInfo, error)) + func (fake *FakeContainer) InfoReturns(result1 garden.ContainerInfo, result2 error) + func (fake *FakeContainer) InfoReturnsOnCall(i int, result1 garden.ContainerInfo, result2 error) + func (fake *FakeContainer) Invocations() map[string][][]interface{} + func (fake *FakeContainer) Metrics() (garden.Metrics, error) + func (fake *FakeContainer) MetricsCallCount() int + func (fake *FakeContainer) MetricsCalls(stub func() (garden.Metrics, error)) + func (fake *FakeContainer) MetricsReturns(result1 garden.Metrics, result2 error) + func (fake *FakeContainer) MetricsReturnsOnCall(i int, result1 garden.Metrics, result2 error) + func (fake *FakeContainer) NetIn(arg1 uint32, arg2 uint32) (uint32, uint32, error) + func (fake *FakeContainer) NetInArgsForCall(i int) (uint32, uint32) + func (fake *FakeContainer) NetInCallCount() int + func (fake *FakeContainer) NetInCalls(stub func(uint32, uint32) (uint32, uint32, error)) + func (fake *FakeContainer) NetInReturns(result1 uint32, result2 uint32, result3 error) + func (fake *FakeContainer) NetInReturnsOnCall(i int, result1 uint32, result2 uint32, result3 error) + func (fake *FakeContainer) NetOut(arg1 garden.NetOutRule) error + func (fake *FakeContainer) NetOutArgsForCall(i int) garden.NetOutRule + func (fake *FakeContainer) NetOutCallCount() int + func (fake *FakeContainer) NetOutCalls(stub func(garden.NetOutRule) error) + func (fake *FakeContainer) NetOutReturns(result1 error) + func (fake *FakeContainer) NetOutReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) Properties() (garden.Properties, error) + func (fake *FakeContainer) PropertiesCallCount() int + func (fake *FakeContainer) PropertiesCalls(stub func() (garden.Properties, error)) + func (fake *FakeContainer) PropertiesReturns(result1 garden.Properties, result2 error) + func (fake *FakeContainer) PropertiesReturnsOnCall(i int, result1 garden.Properties, result2 error) + func (fake *FakeContainer) Property(arg1 string) (string, error) + func (fake *FakeContainer) PropertyArgsForCall(i int) string + func (fake *FakeContainer) PropertyCallCount() int + func (fake *FakeContainer) PropertyCalls(stub func(string) (string, error)) + func (fake *FakeContainer) PropertyReturns(result1 string, result2 error) + func (fake *FakeContainer) PropertyReturnsOnCall(i int, result1 string, result2 error) + func (fake *FakeContainer) RemoveProperty(arg1 string) error + func (fake *FakeContainer) RemovePropertyArgsForCall(i int) string + func (fake *FakeContainer) RemovePropertyCallCount() int + func (fake *FakeContainer) RemovePropertyCalls(stub func(string) error) + func (fake *FakeContainer) RemovePropertyReturns(result1 error) + func (fake *FakeContainer) RemovePropertyReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) Run(arg1 context.Context, arg2 garden.ProcessSpec, arg3 garden.ProcessIO) (garden.Process, error) + func (fake *FakeContainer) RunArgsForCall(i int) (context.Context, garden.ProcessSpec, garden.ProcessIO) + func (fake *FakeContainer) RunCallCount() int + func (fake *FakeContainer) RunCalls(...) + func (fake *FakeContainer) RunReturns(result1 garden.Process, result2 error) + func (fake *FakeContainer) RunReturnsOnCall(i int, result1 garden.Process, result2 error) + func (fake *FakeContainer) RunScript(arg1 context.Context, arg2 string, arg3 []string, arg4 []byte, ...) error + func (fake *FakeContainer) RunScriptArgsForCall(i int) (context.Context, string, []string, []byte, interface{}, io.Writer, bool) + func (fake *FakeContainer) RunScriptCallCount() int + func (fake *FakeContainer) RunScriptCalls(...) + func (fake *FakeContainer) RunScriptReturns(result1 error) + func (fake *FakeContainer) RunScriptReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) SetGraceTime(arg1 time.Duration) error + func (fake *FakeContainer) SetGraceTimeArgsForCall(i int) time.Duration + func (fake *FakeContainer) SetGraceTimeCallCount() int + func (fake *FakeContainer) SetGraceTimeCalls(stub func(time.Duration) error) + func (fake *FakeContainer) SetGraceTimeReturns(result1 error) + func (fake *FakeContainer) SetGraceTimeReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) SetProperty(arg1 string, arg2 string) error + func (fake *FakeContainer) SetPropertyArgsForCall(i int) (string, string) + func (fake *FakeContainer) SetPropertyCallCount() int + func (fake *FakeContainer) SetPropertyCalls(stub func(string, string) error) + func (fake *FakeContainer) SetPropertyReturns(result1 error) + func (fake *FakeContainer) SetPropertyReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) Stop(arg1 bool) error + func (fake *FakeContainer) StopArgsForCall(i int) bool + func (fake *FakeContainer) StopCallCount() int + func (fake *FakeContainer) StopCalls(stub func(bool) error) + func (fake *FakeContainer) StopReturns(result1 error) + func (fake *FakeContainer) StopReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) StreamIn(arg1 garden.StreamInSpec) error + func (fake *FakeContainer) StreamInArgsForCall(i int) garden.StreamInSpec + func (fake *FakeContainer) StreamInCallCount() int + func (fake *FakeContainer) StreamInCalls(stub func(garden.StreamInSpec) error) + func (fake *FakeContainer) StreamInReturns(result1 error) + func (fake *FakeContainer) StreamInReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) StreamOut(arg1 garden.StreamOutSpec) (io.ReadCloser, error) + func (fake *FakeContainer) StreamOutArgsForCall(i int) garden.StreamOutSpec + func (fake *FakeContainer) StreamOutCallCount() int + func (fake *FakeContainer) StreamOutCalls(stub func(garden.StreamOutSpec) (io.ReadCloser, error)) + func (fake *FakeContainer) StreamOutReturns(result1 io.ReadCloser, result2 error) + func (fake *FakeContainer) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error) + func (fake *FakeContainer) UpdateLastHijack() error + func (fake *FakeContainer) UpdateLastHijackCallCount() int + func (fake *FakeContainer) UpdateLastHijackCalls(stub func() error) + func (fake *FakeContainer) UpdateLastHijackReturns(result1 error) + func (fake *FakeContainer) UpdateLastHijackReturnsOnCall(i int, result1 error) + func (fake *FakeContainer) VolumeMounts() []worker.VolumeMount + func (fake *FakeContainer) VolumeMountsCallCount() int + func (fake *FakeContainer) VolumeMountsCalls(stub func() []worker.VolumeMount) + func (fake *FakeContainer) VolumeMountsReturns(result1 []worker.VolumeMount) + func (fake *FakeContainer) VolumeMountsReturnsOnCall(i int, result1 []worker.VolumeMount) + func (fake *FakeContainer) WorkerName() string + func (fake *FakeContainer) WorkerNameCallCount() int + func (fake *FakeContainer) WorkerNameCalls(stub func() string) + func (fake *FakeContainer) WorkerNameReturns(result1 string) + func (fake *FakeContainer) WorkerNameReturnsOnCall(i int, result1 string) + type FakeContainerPlacementStrategy struct + ChooseStub func(lager.Logger, []worker.Worker, worker.ContainerSpec) (worker.Worker, error) + ModifiesActiveTasksStub func() bool + func (fake *FakeContainerPlacementStrategy) Choose(arg1 lager.Logger, arg2 []worker.Worker, arg3 worker.ContainerSpec) (worker.Worker, error) + func (fake *FakeContainerPlacementStrategy) ChooseArgsForCall(i int) (lager.Logger, []worker.Worker, worker.ContainerSpec) + func (fake *FakeContainerPlacementStrategy) ChooseCallCount() int + func (fake *FakeContainerPlacementStrategy) ChooseCalls(...) + func (fake *FakeContainerPlacementStrategy) ChooseReturns(result1 worker.Worker, result2 error) + func (fake *FakeContainerPlacementStrategy) ChooseReturnsOnCall(i int, result1 worker.Worker, result2 error) + func (fake *FakeContainerPlacementStrategy) Invocations() map[string][][]interface{} + func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasks() bool + func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksCallCount() int + func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksCalls(stub func() bool) + func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksReturns(result1 bool) + func (fake *FakeContainerPlacementStrategy) ModifiesActiveTasksReturnsOnCall(i int, result1 bool) + type FakeFetchSource struct + CreateStub func(context.Context) (worker.GetResult, worker.Volume, error) + FindStub func() (worker.GetResult, worker.Volume, bool, error) + func (fake *FakeFetchSource) Create(arg1 context.Context) (worker.GetResult, worker.Volume, error) + func (fake *FakeFetchSource) CreateArgsForCall(i int) context.Context + func (fake *FakeFetchSource) CreateCallCount() int + func (fake *FakeFetchSource) CreateCalls(stub func(context.Context) (worker.GetResult, worker.Volume, error)) + func (fake *FakeFetchSource) CreateReturns(result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeFetchSource) CreateReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeFetchSource) Find() (worker.GetResult, worker.Volume, bool, error) + func (fake *FakeFetchSource) FindCallCount() int + func (fake *FakeFetchSource) FindCalls(stub func() (worker.GetResult, worker.Volume, bool, error)) + func (fake *FakeFetchSource) FindReturns(result1 worker.GetResult, result2 worker.Volume, result3 bool, result4 error) + func (fake *FakeFetchSource) FindReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 bool, ...) + func (fake *FakeFetchSource) Invocations() map[string][][]interface{} + type FakeFetchSourceFactory struct + NewFetchSourceStub func(lager.Logger, worker.Worker, db.ContainerOwner, db.UsedResourceCache, ...) worker.FetchSource + func (fake *FakeFetchSourceFactory) Invocations() map[string][][]interface{} + func (fake *FakeFetchSourceFactory) NewFetchSource(arg1 lager.Logger, arg2 worker.Worker, arg3 db.ContainerOwner, ...) worker.FetchSource + func (fake *FakeFetchSourceFactory) NewFetchSourceArgsForCall(i int) (lager.Logger, worker.Worker, db.ContainerOwner, db.UsedResourceCache, ...) + func (fake *FakeFetchSourceFactory) NewFetchSourceCallCount() int + func (fake *FakeFetchSourceFactory) NewFetchSourceCalls(...) + func (fake *FakeFetchSourceFactory) NewFetchSourceReturns(result1 worker.FetchSource) + func (fake *FakeFetchSourceFactory) NewFetchSourceReturnsOnCall(i int, result1 worker.FetchSource) + type FakeFetcher struct + FetchStub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, ...) (worker.GetResult, worker.Volume, error) + func (fake *FakeFetcher) Fetch(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerMetadata, ...) (worker.GetResult, worker.Volume, error) + func (fake *FakeFetcher) FetchArgsForCall(i int) (context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, ...) + func (fake *FakeFetcher) FetchCallCount() int + func (fake *FakeFetcher) FetchCalls(...) + func (fake *FakeFetcher) FetchReturns(result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeFetcher) Invocations() map[string][][]interface{} + type FakeImage struct + FetchForContainerStub func(context.Context, lager.Logger, db.CreatingContainer) (worker.FetchedImage, error) + func (fake *FakeImage) FetchForContainer(arg1 context.Context, arg2 lager.Logger, arg3 db.CreatingContainer) (worker.FetchedImage, error) + func (fake *FakeImage) FetchForContainerArgsForCall(i int) (context.Context, lager.Logger, db.CreatingContainer) + func (fake *FakeImage) FetchForContainerCallCount() int + func (fake *FakeImage) FetchForContainerCalls(...) + func (fake *FakeImage) FetchForContainerReturns(result1 worker.FetchedImage, result2 error) + func (fake *FakeImage) FetchForContainerReturnsOnCall(i int, result1 worker.FetchedImage, result2 error) + func (fake *FakeImage) Invocations() map[string][][]interface{} + type FakeImageFactory struct + GetImageStub func(lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int, ...) (worker.Image, error) + func (fake *FakeImageFactory) GetImage(arg1 lager.Logger, arg2 worker.Worker, arg3 worker.VolumeClient, ...) (worker.Image, error) + func (fake *FakeImageFactory) GetImageArgsForCall(i int) (lager.Logger, worker.Worker, worker.VolumeClient, worker.ImageSpec, int, ...) + func (fake *FakeImageFactory) GetImageCallCount() int + func (fake *FakeImageFactory) GetImageCalls(...) + func (fake *FakeImageFactory) GetImageReturns(result1 worker.Image, result2 error) + func (fake *FakeImageFactory) GetImageReturnsOnCall(i int, result1 worker.Image, result2 error) + func (fake *FakeImageFactory) Invocations() map[string][][]interface{} + type FakeImageFetchingDelegate struct + ImageVersionDeterminedStub func(db.UsedResourceCache) error + RedactImageSourceStub func(atc.Source) (atc.Source, error) + StderrStub func() io.Writer + StdoutStub func() io.Writer + func (fake *FakeImageFetchingDelegate) ImageVersionDetermined(arg1 db.UsedResourceCache) error + func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedArgsForCall(i int) db.UsedResourceCache + func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCallCount() int + func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedCalls(stub func(db.UsedResourceCache) error) + func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturns(result1 error) + func (fake *FakeImageFetchingDelegate) ImageVersionDeterminedReturnsOnCall(i int, result1 error) + func (fake *FakeImageFetchingDelegate) Invocations() map[string][][]interface{} + func (fake *FakeImageFetchingDelegate) RedactImageSource(arg1 atc.Source) (atc.Source, error) + func (fake *FakeImageFetchingDelegate) RedactImageSourceArgsForCall(i int) atc.Source + func (fake *FakeImageFetchingDelegate) RedactImageSourceCallCount() int + func (fake *FakeImageFetchingDelegate) RedactImageSourceCalls(stub func(atc.Source) (atc.Source, error)) + func (fake *FakeImageFetchingDelegate) RedactImageSourceReturns(result1 atc.Source, result2 error) + func (fake *FakeImageFetchingDelegate) RedactImageSourceReturnsOnCall(i int, result1 atc.Source, result2 error) + func (fake *FakeImageFetchingDelegate) Stderr() io.Writer + func (fake *FakeImageFetchingDelegate) StderrCallCount() int + func (fake *FakeImageFetchingDelegate) StderrCalls(stub func() io.Writer) + func (fake *FakeImageFetchingDelegate) StderrReturns(result1 io.Writer) + func (fake *FakeImageFetchingDelegate) StderrReturnsOnCall(i int, result1 io.Writer) + func (fake *FakeImageFetchingDelegate) Stdout() io.Writer + func (fake *FakeImageFetchingDelegate) StdoutCallCount() int + func (fake *FakeImageFetchingDelegate) StdoutCalls(stub func() io.Writer) + func (fake *FakeImageFetchingDelegate) StdoutReturns(result1 io.Writer) + func (fake *FakeImageFetchingDelegate) StdoutReturnsOnCall(i int, result1 io.Writer) + type FakeInputSource struct + DestinationPathStub func() string + SourceStub func() worker.ArtifactSource + func (fake *FakeInputSource) DestinationPath() string + func (fake *FakeInputSource) DestinationPathCallCount() int + func (fake *FakeInputSource) DestinationPathCalls(stub func() string) + func (fake *FakeInputSource) DestinationPathReturns(result1 string) + func (fake *FakeInputSource) DestinationPathReturnsOnCall(i int, result1 string) + func (fake *FakeInputSource) Invocations() map[string][][]interface{} + func (fake *FakeInputSource) Source() worker.ArtifactSource + func (fake *FakeInputSource) SourceCallCount() int + func (fake *FakeInputSource) SourceCalls(stub func() worker.ArtifactSource) + func (fake *FakeInputSource) SourceReturns(result1 worker.ArtifactSource) + func (fake *FakeInputSource) SourceReturnsOnCall(i int, result1 worker.ArtifactSource) + type FakePool struct + ContainerInWorkerStub func(lager.Logger, db.ContainerOwner, worker.WorkerSpec) (bool, error) + FindOrChooseWorkerForContainerStub func(context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) (worker.Worker, error) + FindOrChooseWorkerStub func(lager.Logger, worker.WorkerSpec) (worker.Worker, error) + func (fake *FakePool) ContainerInWorker(arg1 lager.Logger, arg2 db.ContainerOwner, arg3 worker.WorkerSpec) (bool, error) + func (fake *FakePool) ContainerInWorkerArgsForCall(i int) (lager.Logger, db.ContainerOwner, worker.WorkerSpec) + func (fake *FakePool) ContainerInWorkerCallCount() int + func (fake *FakePool) ContainerInWorkerCalls(stub func(lager.Logger, db.ContainerOwner, worker.WorkerSpec) (bool, error)) + func (fake *FakePool) ContainerInWorkerReturns(result1 bool, result2 error) + func (fake *FakePool) ContainerInWorkerReturnsOnCall(i int, result1 bool, result2 error) + func (fake *FakePool) FindOrChooseWorker(arg1 lager.Logger, arg2 worker.WorkerSpec) (worker.Worker, error) + func (fake *FakePool) FindOrChooseWorkerArgsForCall(i int) (lager.Logger, worker.WorkerSpec) + func (fake *FakePool) FindOrChooseWorkerCallCount() int + func (fake *FakePool) FindOrChooseWorkerCalls(stub func(lager.Logger, worker.WorkerSpec) (worker.Worker, error)) + func (fake *FakePool) FindOrChooseWorkerForContainer(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerOwner, ...) (worker.Worker, error) + func (fake *FakePool) FindOrChooseWorkerForContainerArgsForCall(i int) (context.Context, lager.Logger, db.ContainerOwner, worker.ContainerSpec, ...) + func (fake *FakePool) FindOrChooseWorkerForContainerCallCount() int + func (fake *FakePool) FindOrChooseWorkerForContainerCalls(...) + func (fake *FakePool) FindOrChooseWorkerForContainerReturns(result1 worker.Worker, result2 error) + func (fake *FakePool) FindOrChooseWorkerForContainerReturnsOnCall(i int, result1 worker.Worker, result2 error) + func (fake *FakePool) FindOrChooseWorkerReturns(result1 worker.Worker, result2 error) + func (fake *FakePool) FindOrChooseWorkerReturnsOnCall(i int, result1 worker.Worker, result2 error) + func (fake *FakePool) Invocations() map[string][][]interface{} + type FakeStreamableArtifactSource struct + ExistsOnStub func(lager.Logger, worker.Worker) (worker.Volume, bool, error) + StreamFileStub func(context.Context, string) (io.ReadCloser, error) + StreamToStub func(context.Context, worker.ArtifactDestination) error + func (fake *FakeStreamableArtifactSource) ExistsOn(arg1 lager.Logger, arg2 worker.Worker) (worker.Volume, bool, error) + func (fake *FakeStreamableArtifactSource) ExistsOnArgsForCall(i int) (lager.Logger, worker.Worker) + func (fake *FakeStreamableArtifactSource) ExistsOnCallCount() int + func (fake *FakeStreamableArtifactSource) ExistsOnCalls(stub func(lager.Logger, worker.Worker) (worker.Volume, bool, error)) + func (fake *FakeStreamableArtifactSource) ExistsOnReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeStreamableArtifactSource) ExistsOnReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeStreamableArtifactSource) Invocations() map[string][][]interface{} + func (fake *FakeStreamableArtifactSource) StreamFile(arg1 context.Context, arg2 string) (io.ReadCloser, error) + func (fake *FakeStreamableArtifactSource) StreamFileArgsForCall(i int) (context.Context, string) + func (fake *FakeStreamableArtifactSource) StreamFileCallCount() int + func (fake *FakeStreamableArtifactSource) StreamFileCalls(stub func(context.Context, string) (io.ReadCloser, error)) + func (fake *FakeStreamableArtifactSource) StreamFileReturns(result1 io.ReadCloser, result2 error) + func (fake *FakeStreamableArtifactSource) StreamFileReturnsOnCall(i int, result1 io.ReadCloser, result2 error) + func (fake *FakeStreamableArtifactSource) StreamTo(arg1 context.Context, arg2 worker.ArtifactDestination) error + func (fake *FakeStreamableArtifactSource) StreamToArgsForCall(i int) (context.Context, worker.ArtifactDestination) + func (fake *FakeStreamableArtifactSource) StreamToCallCount() int + func (fake *FakeStreamableArtifactSource) StreamToCalls(stub func(context.Context, worker.ArtifactDestination) error) + func (fake *FakeStreamableArtifactSource) StreamToReturns(result1 error) + func (fake *FakeStreamableArtifactSource) StreamToReturnsOnCall(i int, result1 error) + type FakeVolume struct + COWStrategyStub func() baggageclaim.COWStrategy + CreateChildForContainerStub func(db.CreatingContainer, string) (db.CreatingVolume, error) + DestroyStub func() error + GetResourceCacheIDStub func() int + HandleStub func() string + InitializeArtifactStub func(string, int) (db.WorkerArtifact, error) + InitializeResourceCacheStub func(db.UsedResourceCache) error + InitializeTaskCacheStub func(lager.Logger, int, string, string, bool) error + PathStub func() string + PropertiesStub func() (baggageclaim.VolumeProperties, error) + SetPrivilegedStub func(bool) error + SetPropertyStub func(string, string) error + StreamInStub func(context.Context, string, baggageclaim.Encoding, io.Reader) error + StreamOutStub func(context.Context, string, baggageclaim.Encoding) (io.ReadCloser, error) + WorkerNameStub func() string + func (fake *FakeVolume) COWStrategy() baggageclaim.COWStrategy + func (fake *FakeVolume) COWStrategyCallCount() int + func (fake *FakeVolume) COWStrategyCalls(stub func() baggageclaim.COWStrategy) + func (fake *FakeVolume) COWStrategyReturns(result1 baggageclaim.COWStrategy) + func (fake *FakeVolume) COWStrategyReturnsOnCall(i int, result1 baggageclaim.COWStrategy) + func (fake *FakeVolume) CreateChildForContainer(arg1 db.CreatingContainer, arg2 string) (db.CreatingVolume, error) + func (fake *FakeVolume) CreateChildForContainerArgsForCall(i int) (db.CreatingContainer, string) + func (fake *FakeVolume) CreateChildForContainerCallCount() int + func (fake *FakeVolume) CreateChildForContainerCalls(stub func(db.CreatingContainer, string) (db.CreatingVolume, error)) + func (fake *FakeVolume) CreateChildForContainerReturns(result1 db.CreatingVolume, result2 error) + func (fake *FakeVolume) CreateChildForContainerReturnsOnCall(i int, result1 db.CreatingVolume, result2 error) + func (fake *FakeVolume) Destroy() error + func (fake *FakeVolume) DestroyCallCount() int + func (fake *FakeVolume) DestroyCalls(stub func() error) + func (fake *FakeVolume) DestroyReturns(result1 error) + func (fake *FakeVolume) DestroyReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) GetResourceCacheID() int + func (fake *FakeVolume) GetResourceCacheIDCallCount() int + func (fake *FakeVolume) GetResourceCacheIDCalls(stub func() int) + func (fake *FakeVolume) GetResourceCacheIDReturns(result1 int) + func (fake *FakeVolume) GetResourceCacheIDReturnsOnCall(i int, result1 int) + func (fake *FakeVolume) Handle() string + func (fake *FakeVolume) HandleCallCount() int + func (fake *FakeVolume) HandleCalls(stub func() string) + func (fake *FakeVolume) HandleReturns(result1 string) + func (fake *FakeVolume) HandleReturnsOnCall(i int, result1 string) + func (fake *FakeVolume) InitializeArtifact(arg1 string, arg2 int) (db.WorkerArtifact, error) + func (fake *FakeVolume) InitializeArtifactArgsForCall(i int) (string, int) + func (fake *FakeVolume) InitializeArtifactCallCount() int + func (fake *FakeVolume) InitializeArtifactCalls(stub func(string, int) (db.WorkerArtifact, error)) + func (fake *FakeVolume) InitializeArtifactReturns(result1 db.WorkerArtifact, result2 error) + func (fake *FakeVolume) InitializeArtifactReturnsOnCall(i int, result1 db.WorkerArtifact, result2 error) + func (fake *FakeVolume) InitializeResourceCache(arg1 db.UsedResourceCache) error + func (fake *FakeVolume) InitializeResourceCacheArgsForCall(i int) db.UsedResourceCache + func (fake *FakeVolume) InitializeResourceCacheCallCount() int + func (fake *FakeVolume) InitializeResourceCacheCalls(stub func(db.UsedResourceCache) error) + func (fake *FakeVolume) InitializeResourceCacheReturns(result1 error) + func (fake *FakeVolume) InitializeResourceCacheReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) InitializeTaskCache(arg1 lager.Logger, arg2 int, arg3 string, arg4 string, arg5 bool) error + func (fake *FakeVolume) InitializeTaskCacheArgsForCall(i int) (lager.Logger, int, string, string, bool) + func (fake *FakeVolume) InitializeTaskCacheCallCount() int + func (fake *FakeVolume) InitializeTaskCacheCalls(stub func(lager.Logger, int, string, string, bool) error) + func (fake *FakeVolume) InitializeTaskCacheReturns(result1 error) + func (fake *FakeVolume) InitializeTaskCacheReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) Invocations() map[string][][]interface{} + func (fake *FakeVolume) Path() string + func (fake *FakeVolume) PathCallCount() int + func (fake *FakeVolume) PathCalls(stub func() string) + func (fake *FakeVolume) PathReturns(result1 string) + func (fake *FakeVolume) PathReturnsOnCall(i int, result1 string) + func (fake *FakeVolume) Properties() (baggageclaim.VolumeProperties, error) + func (fake *FakeVolume) PropertiesCallCount() int + func (fake *FakeVolume) PropertiesCalls(stub func() (baggageclaim.VolumeProperties, error)) + func (fake *FakeVolume) PropertiesReturns(result1 baggageclaim.VolumeProperties, result2 error) + func (fake *FakeVolume) PropertiesReturnsOnCall(i int, result1 baggageclaim.VolumeProperties, result2 error) + func (fake *FakeVolume) SetPrivileged(arg1 bool) error + func (fake *FakeVolume) SetPrivilegedArgsForCall(i int) bool + func (fake *FakeVolume) SetPrivilegedCallCount() int + func (fake *FakeVolume) SetPrivilegedCalls(stub func(bool) error) + func (fake *FakeVolume) SetPrivilegedReturns(result1 error) + func (fake *FakeVolume) SetPrivilegedReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) SetProperty(arg1 string, arg2 string) error + func (fake *FakeVolume) SetPropertyArgsForCall(i int) (string, string) + func (fake *FakeVolume) SetPropertyCallCount() int + func (fake *FakeVolume) SetPropertyCalls(stub func(string, string) error) + func (fake *FakeVolume) SetPropertyReturns(result1 error) + func (fake *FakeVolume) SetPropertyReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) StreamIn(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding, arg4 io.Reader) error + func (fake *FakeVolume) StreamInArgsForCall(i int) (context.Context, string, baggageclaim.Encoding, io.Reader) + func (fake *FakeVolume) StreamInCallCount() int + func (fake *FakeVolume) StreamInCalls(stub func(context.Context, string, baggageclaim.Encoding, io.Reader) error) + func (fake *FakeVolume) StreamInReturns(result1 error) + func (fake *FakeVolume) StreamInReturnsOnCall(i int, result1 error) + func (fake *FakeVolume) StreamOut(arg1 context.Context, arg2 string, arg3 baggageclaim.Encoding) (io.ReadCloser, error) + func (fake *FakeVolume) StreamOutArgsForCall(i int) (context.Context, string, baggageclaim.Encoding) + func (fake *FakeVolume) StreamOutCallCount() int + func (fake *FakeVolume) StreamOutCalls(...) + func (fake *FakeVolume) StreamOutReturns(result1 io.ReadCloser, result2 error) + func (fake *FakeVolume) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error) + func (fake *FakeVolume) WorkerName() string + func (fake *FakeVolume) WorkerNameCallCount() int + func (fake *FakeVolume) WorkerNameCalls(stub func() string) + func (fake *FakeVolume) WorkerNameReturns(result1 string) + func (fake *FakeVolume) WorkerNameReturnsOnCall(i int, result1 string) + type FakeVolumeClient struct + CreateVolumeForTaskCacheStub func(lager.Logger, worker.VolumeSpec, int, int, string, string) (worker.Volume, error) + CreateVolumeStub func(lager.Logger, worker.VolumeSpec, int, string, db.VolumeType) (worker.Volume, error) + FindOrCreateCOWVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, worker.Volume, int, ...) (worker.Volume, error) + FindOrCreateVolumeForBaseResourceTypeStub func(lager.Logger, worker.VolumeSpec, int, string) (worker.Volume, error) + FindOrCreateVolumeForContainerStub func(lager.Logger, worker.VolumeSpec, db.CreatingContainer, int, string) (worker.Volume, error) + FindOrCreateVolumeForResourceCertsStub func(lager.Logger) (worker.Volume, bool, error) + FindVolumeForResourceCacheStub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error) + FindVolumeForTaskCacheStub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error) + LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error) + func (fake *FakeVolumeClient) CreateVolume(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 string, ...) (worker.Volume, error) + func (fake *FakeVolumeClient) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, string, db.VolumeType) + func (fake *FakeVolumeClient) CreateVolumeCallCount() int + func (fake *FakeVolumeClient) CreateVolumeCalls(...) + func (fake *FakeVolumeClient) CreateVolumeForTaskCache(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 int, arg5 string, ...) (worker.Volume, error) + func (fake *FakeVolumeClient) CreateVolumeForTaskCacheArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, int, string, string) + func (fake *FakeVolumeClient) CreateVolumeForTaskCacheCallCount() int + func (fake *FakeVolumeClient) CreateVolumeForTaskCacheCalls(...) + func (fake *FakeVolumeClient) CreateVolumeForTaskCacheReturns(result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) CreateVolumeForTaskCacheReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) CreateVolumeReturns(result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) CreateVolumeReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 db.CreatingContainer, ...) (worker.Volume, error) + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, db.CreatingContainer, worker.Volume, int, ...) + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCallCount() int + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerCalls(...) + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturns(result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateCOWVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceType(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 string) (worker.Volume, error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, string) + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCallCount() int + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeCalls(stub func(lager.Logger, worker.VolumeSpec, int, string) (worker.Volume, error)) + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturns(result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForBaseResourceTypeReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainer(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 db.CreatingContainer, arg4 int, ...) (worker.Volume, error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerArgsForCall(i int) (lager.Logger, worker.VolumeSpec, db.CreatingContainer, int, string) + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCallCount() int + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerCalls(...) + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturns(result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForContainerReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCerts(arg1 lager.Logger) (worker.Volume, bool, error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsArgsForCall(i int) lager.Logger + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsCallCount() int + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsCalls(stub func(lager.Logger) (worker.Volume, bool, error)) + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) FindOrCreateVolumeForResourceCertsReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) FindVolumeForResourceCache(arg1 lager.Logger, arg2 db.UsedResourceCache) (worker.Volume, bool, error) + func (fake *FakeVolumeClient) FindVolumeForResourceCacheArgsForCall(i int) (lager.Logger, db.UsedResourceCache) + func (fake *FakeVolumeClient) FindVolumeForResourceCacheCallCount() int + func (fake *FakeVolumeClient) FindVolumeForResourceCacheCalls(stub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error)) + func (fake *FakeVolumeClient) FindVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) FindVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) FindVolumeForTaskCache(arg1 lager.Logger, arg2 int, arg3 int, arg4 string, arg5 string) (worker.Volume, bool, error) + func (fake *FakeVolumeClient) FindVolumeForTaskCacheArgsForCall(i int) (lager.Logger, int, int, string, string) + func (fake *FakeVolumeClient) FindVolumeForTaskCacheCallCount() int + func (fake *FakeVolumeClient) FindVolumeForTaskCacheCalls(stub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error)) + func (fake *FakeVolumeClient) FindVolumeForTaskCacheReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) FindVolumeForTaskCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) Invocations() map[string][][]interface{} + func (fake *FakeVolumeClient) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error) + func (fake *FakeVolumeClient) LookupVolumeArgsForCall(i int) (lager.Logger, string) + func (fake *FakeVolumeClient) LookupVolumeCallCount() int + func (fake *FakeVolumeClient) LookupVolumeCalls(stub func(lager.Logger, string) (worker.Volume, bool, error)) + func (fake *FakeVolumeClient) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeVolumeClient) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + type FakeWorker struct + ActiveTasksStub func() (int, error) + BuildContainersStub func() int + CertsVolumeStub func(lager.Logger) (worker.Volume, bool, error) + CreateVolumeStub func(lager.Logger, worker.VolumeSpec, int, db.VolumeType) (worker.Volume, error) + DecreaseActiveTasksStub func() error + DescriptionStub func() string + EphemeralStub func() bool + FetchStub func(context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, ...) (worker.GetResult, worker.Volume, error) + FindContainerByHandleStub func(lager.Logger, int, string) (worker.Container, bool, error) + FindOrCreateContainerStub func(context.Context, lager.Logger, worker.ImageFetchingDelegate, db.ContainerOwner, ...) (worker.Container, error) + FindResourceCacheForVolumeStub func(worker.Volume) (db.UsedResourceCache, bool, error) + FindVolumeForResourceCacheStub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error) + FindVolumeForTaskCacheStub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error) + GardenClientStub func() gclient.Client + IncreaseActiveTasksStub func() error + IsOwnedByTeamStub func() bool + IsVersionCompatibleStub func(lager.Logger, version.Version) bool + LookupVolumeStub func(lager.Logger, string) (worker.Volume, bool, error) + NameStub func() string + ResourceTypesStub func() []atc.WorkerResourceType + SatisfiesStub func(lager.Logger, worker.WorkerSpec) bool + TagsStub func() atc.Tags + UptimeStub func() time.Duration + func (fake *FakeWorker) ActiveTasks() (int, error) + func (fake *FakeWorker) ActiveTasksCallCount() int + func (fake *FakeWorker) ActiveTasksCalls(stub func() (int, error)) + func (fake *FakeWorker) ActiveTasksReturns(result1 int, result2 error) + func (fake *FakeWorker) ActiveTasksReturnsOnCall(i int, result1 int, result2 error) + func (fake *FakeWorker) BuildContainers() int + func (fake *FakeWorker) BuildContainersCallCount() int + func (fake *FakeWorker) BuildContainersCalls(stub func() int) + func (fake *FakeWorker) BuildContainersReturns(result1 int) + func (fake *FakeWorker) BuildContainersReturnsOnCall(i int, result1 int) + func (fake *FakeWorker) CertsVolume(arg1 lager.Logger) (worker.Volume, bool, error) + func (fake *FakeWorker) CertsVolumeArgsForCall(i int) lager.Logger + func (fake *FakeWorker) CertsVolumeCallCount() int + func (fake *FakeWorker) CertsVolumeCalls(stub func(lager.Logger) (worker.Volume, bool, error)) + func (fake *FakeWorker) CertsVolumeReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) CertsVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) CreateVolume(arg1 lager.Logger, arg2 worker.VolumeSpec, arg3 int, arg4 db.VolumeType) (worker.Volume, error) + func (fake *FakeWorker) CreateVolumeArgsForCall(i int) (lager.Logger, worker.VolumeSpec, int, db.VolumeType) + func (fake *FakeWorker) CreateVolumeCallCount() int + func (fake *FakeWorker) CreateVolumeCalls(...) + func (fake *FakeWorker) CreateVolumeReturns(result1 worker.Volume, result2 error) + func (fake *FakeWorker) CreateVolumeReturnsOnCall(i int, result1 worker.Volume, result2 error) + func (fake *FakeWorker) DecreaseActiveTasks() error + func (fake *FakeWorker) DecreaseActiveTasksCallCount() int + func (fake *FakeWorker) DecreaseActiveTasksCalls(stub func() error) + func (fake *FakeWorker) DecreaseActiveTasksReturns(result1 error) + func (fake *FakeWorker) DecreaseActiveTasksReturnsOnCall(i int, result1 error) + func (fake *FakeWorker) Description() string + func (fake *FakeWorker) DescriptionCallCount() int + func (fake *FakeWorker) DescriptionCalls(stub func() string) + func (fake *FakeWorker) DescriptionReturns(result1 string) + func (fake *FakeWorker) DescriptionReturnsOnCall(i int, result1 string) + func (fake *FakeWorker) Ephemeral() bool + func (fake *FakeWorker) EphemeralCallCount() int + func (fake *FakeWorker) EphemeralCalls(stub func() bool) + func (fake *FakeWorker) EphemeralReturns(result1 bool) + func (fake *FakeWorker) EphemeralReturnsOnCall(i int, result1 bool) + func (fake *FakeWorker) Fetch(arg1 context.Context, arg2 lager.Logger, arg3 db.ContainerMetadata, ...) (worker.GetResult, worker.Volume, error) + func (fake *FakeWorker) FetchArgsForCall(i int) (context.Context, lager.Logger, db.ContainerMetadata, worker.Worker, ...) + func (fake *FakeWorker) FetchCallCount() int + func (fake *FakeWorker) FetchCalls(...) + func (fake *FakeWorker) FetchReturns(result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeWorker) FetchReturnsOnCall(i int, result1 worker.GetResult, result2 worker.Volume, result3 error) + func (fake *FakeWorker) FindContainerByHandle(arg1 lager.Logger, arg2 int, arg3 string) (worker.Container, bool, error) + func (fake *FakeWorker) FindContainerByHandleArgsForCall(i int) (lager.Logger, int, string) + func (fake *FakeWorker) FindContainerByHandleCallCount() int + func (fake *FakeWorker) FindContainerByHandleCalls(stub func(lager.Logger, int, string) (worker.Container, bool, error)) + func (fake *FakeWorker) FindContainerByHandleReturns(result1 worker.Container, result2 bool, result3 error) + func (fake *FakeWorker) FindContainerByHandleReturnsOnCall(i int, result1 worker.Container, result2 bool, result3 error) + func (fake *FakeWorker) FindOrCreateContainer(arg1 context.Context, arg2 lager.Logger, arg3 worker.ImageFetchingDelegate, ...) (worker.Container, error) + func (fake *FakeWorker) FindOrCreateContainerArgsForCall(i int) (context.Context, lager.Logger, worker.ImageFetchingDelegate, db.ContainerOwner, ...) + func (fake *FakeWorker) FindOrCreateContainerCallCount() int + func (fake *FakeWorker) FindOrCreateContainerCalls(...) + func (fake *FakeWorker) FindOrCreateContainerReturns(result1 worker.Container, result2 error) + func (fake *FakeWorker) FindOrCreateContainerReturnsOnCall(i int, result1 worker.Container, result2 error) + func (fake *FakeWorker) FindResourceCacheForVolume(arg1 worker.Volume) (db.UsedResourceCache, bool, error) + func (fake *FakeWorker) FindResourceCacheForVolumeArgsForCall(i int) worker.Volume + func (fake *FakeWorker) FindResourceCacheForVolumeCallCount() int + func (fake *FakeWorker) FindResourceCacheForVolumeCalls(stub func(worker.Volume) (db.UsedResourceCache, bool, error)) + func (fake *FakeWorker) FindResourceCacheForVolumeReturns(result1 db.UsedResourceCache, result2 bool, result3 error) + func (fake *FakeWorker) FindResourceCacheForVolumeReturnsOnCall(i int, result1 db.UsedResourceCache, result2 bool, result3 error) + func (fake *FakeWorker) FindVolumeForResourceCache(arg1 lager.Logger, arg2 db.UsedResourceCache) (worker.Volume, bool, error) + func (fake *FakeWorker) FindVolumeForResourceCacheArgsForCall(i int) (lager.Logger, db.UsedResourceCache) + func (fake *FakeWorker) FindVolumeForResourceCacheCallCount() int + func (fake *FakeWorker) FindVolumeForResourceCacheCalls(stub func(lager.Logger, db.UsedResourceCache) (worker.Volume, bool, error)) + func (fake *FakeWorker) FindVolumeForResourceCacheReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) FindVolumeForResourceCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) FindVolumeForTaskCache(arg1 lager.Logger, arg2 int, arg3 int, arg4 string, arg5 string) (worker.Volume, bool, error) + func (fake *FakeWorker) FindVolumeForTaskCacheArgsForCall(i int) (lager.Logger, int, int, string, string) + func (fake *FakeWorker) FindVolumeForTaskCacheCallCount() int + func (fake *FakeWorker) FindVolumeForTaskCacheCalls(stub func(lager.Logger, int, int, string, string) (worker.Volume, bool, error)) + func (fake *FakeWorker) FindVolumeForTaskCacheReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) FindVolumeForTaskCacheReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) GardenClient() gclient.Client + func (fake *FakeWorker) GardenClientCallCount() int + func (fake *FakeWorker) GardenClientCalls(stub func() gclient.Client) + func (fake *FakeWorker) GardenClientReturns(result1 gclient.Client) + func (fake *FakeWorker) GardenClientReturnsOnCall(i int, result1 gclient.Client) + func (fake *FakeWorker) IncreaseActiveTasks() error + func (fake *FakeWorker) IncreaseActiveTasksCallCount() int + func (fake *FakeWorker) IncreaseActiveTasksCalls(stub func() error) + func (fake *FakeWorker) IncreaseActiveTasksReturns(result1 error) + func (fake *FakeWorker) IncreaseActiveTasksReturnsOnCall(i int, result1 error) + func (fake *FakeWorker) Invocations() map[string][][]interface{} + func (fake *FakeWorker) IsOwnedByTeam() bool + func (fake *FakeWorker) IsOwnedByTeamCallCount() int + func (fake *FakeWorker) IsOwnedByTeamCalls(stub func() bool) + func (fake *FakeWorker) IsOwnedByTeamReturns(result1 bool) + func (fake *FakeWorker) IsOwnedByTeamReturnsOnCall(i int, result1 bool) + func (fake *FakeWorker) IsVersionCompatible(arg1 lager.Logger, arg2 version.Version) bool + func (fake *FakeWorker) IsVersionCompatibleArgsForCall(i int) (lager.Logger, version.Version) + func (fake *FakeWorker) IsVersionCompatibleCallCount() int + func (fake *FakeWorker) IsVersionCompatibleCalls(stub func(lager.Logger, version.Version) bool) + func (fake *FakeWorker) IsVersionCompatibleReturns(result1 bool) + func (fake *FakeWorker) IsVersionCompatibleReturnsOnCall(i int, result1 bool) + func (fake *FakeWorker) LookupVolume(arg1 lager.Logger, arg2 string) (worker.Volume, bool, error) + func (fake *FakeWorker) LookupVolumeArgsForCall(i int) (lager.Logger, string) + func (fake *FakeWorker) LookupVolumeCallCount() int + func (fake *FakeWorker) LookupVolumeCalls(stub func(lager.Logger, string) (worker.Volume, bool, error)) + func (fake *FakeWorker) LookupVolumeReturns(result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) LookupVolumeReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error) + func (fake *FakeWorker) Name() string + func (fake *FakeWorker) NameCallCount() int + func (fake *FakeWorker) NameCalls(stub func() string) + func (fake *FakeWorker) NameReturns(result1 string) + func (fake *FakeWorker) NameReturnsOnCall(i int, result1 string) + func (fake *FakeWorker) ResourceTypes() []atc.WorkerResourceType + func (fake *FakeWorker) ResourceTypesCallCount() int + func (fake *FakeWorker) ResourceTypesCalls(stub func() []atc.WorkerResourceType) + func (fake *FakeWorker) ResourceTypesReturns(result1 []atc.WorkerResourceType) + func (fake *FakeWorker) ResourceTypesReturnsOnCall(i int, result1 []atc.WorkerResourceType) + func (fake *FakeWorker) Satisfies(arg1 lager.Logger, arg2 worker.WorkerSpec) bool + func (fake *FakeWorker) SatisfiesArgsForCall(i int) (lager.Logger, worker.WorkerSpec) + func (fake *FakeWorker) SatisfiesCallCount() int + func (fake *FakeWorker) SatisfiesCalls(stub func(lager.Logger, worker.WorkerSpec) bool) + func (fake *FakeWorker) SatisfiesReturns(result1 bool) + func (fake *FakeWorker) SatisfiesReturnsOnCall(i int, result1 bool) + func (fake *FakeWorker) Tags() atc.Tags + func (fake *FakeWorker) TagsCallCount() int + func (fake *FakeWorker) TagsCalls(stub func() atc.Tags) + func (fake *FakeWorker) TagsReturns(result1 atc.Tags) + func (fake *FakeWorker) TagsReturnsOnCall(i int, result1 atc.Tags) + func (fake *FakeWorker) Uptime() time.Duration + func (fake *FakeWorker) UptimeCallCount() int + func (fake *FakeWorker) UptimeCalls(stub func() time.Duration) + func (fake *FakeWorker) UptimeReturns(result1 time.Duration) + func (fake *FakeWorker) UptimeReturnsOnCall(i int, result1 time.Duration) + type FakeWorkerProvider struct + FindWorkerForContainerStub func(lager.Logger, int, string) (worker.Worker, bool, error) + FindWorkerForVolumeStub func(lager.Logger, int, string) (worker.Worker, bool, error) + FindWorkersForContainerByOwnerStub func(lager.Logger, db.ContainerOwner) ([]worker.Worker, error) + NewGardenWorkerStub func(lager.Logger, db.Worker, int) worker.Worker + RunningWorkersStub func(lager.Logger) ([]worker.Worker, error) + func (fake *FakeWorkerProvider) FindWorkerForContainer(arg1 lager.Logger, arg2 int, arg3 string) (worker.Worker, bool, error) + func (fake *FakeWorkerProvider) FindWorkerForContainerArgsForCall(i int) (lager.Logger, int, string) + func (fake *FakeWorkerProvider) FindWorkerForContainerCallCount() int + func (fake *FakeWorkerProvider) FindWorkerForContainerCalls(stub func(lager.Logger, int, string) (worker.Worker, bool, error)) + func (fake *FakeWorkerProvider) FindWorkerForContainerReturns(result1 worker.Worker, result2 bool, result3 error) + func (fake *FakeWorkerProvider) FindWorkerForContainerReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error) + func (fake *FakeWorkerProvider) FindWorkerForVolume(arg1 lager.Logger, arg2 int, arg3 string) (worker.Worker, bool, error) + func (fake *FakeWorkerProvider) FindWorkerForVolumeArgsForCall(i int) (lager.Logger, int, string) + func (fake *FakeWorkerProvider) FindWorkerForVolumeCallCount() int + func (fake *FakeWorkerProvider) FindWorkerForVolumeCalls(stub func(lager.Logger, int, string) (worker.Worker, bool, error)) + func (fake *FakeWorkerProvider) FindWorkerForVolumeReturns(result1 worker.Worker, result2 bool, result3 error) + func (fake *FakeWorkerProvider) FindWorkerForVolumeReturnsOnCall(i int, result1 worker.Worker, result2 bool, result3 error) + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwner(arg1 lager.Logger, arg2 db.ContainerOwner) ([]worker.Worker, error) + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerArgsForCall(i int) (lager.Logger, db.ContainerOwner) + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerCallCount() int + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerCalls(stub func(lager.Logger, db.ContainerOwner) ([]worker.Worker, error)) + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerReturns(result1 []worker.Worker, result2 error) + func (fake *FakeWorkerProvider) FindWorkersForContainerByOwnerReturnsOnCall(i int, result1 []worker.Worker, result2 error) + func (fake *FakeWorkerProvider) Invocations() map[string][][]interface{} + func (fake *FakeWorkerProvider) NewGardenWorker(arg1 lager.Logger, arg2 db.Worker, arg3 int) worker.Worker + func (fake *FakeWorkerProvider) NewGardenWorkerArgsForCall(i int) (lager.Logger, db.Worker, int) + func (fake *FakeWorkerProvider) NewGardenWorkerCallCount() int + func (fake *FakeWorkerProvider) NewGardenWorkerCalls(stub func(lager.Logger, db.Worker, int) worker.Worker) + func (fake *FakeWorkerProvider) NewGardenWorkerReturns(result1 worker.Worker) + func (fake *FakeWorkerProvider) NewGardenWorkerReturnsOnCall(i int, result1 worker.Worker) + func (fake *FakeWorkerProvider) RunningWorkers(arg1 lager.Logger) ([]worker.Worker, error) + func (fake *FakeWorkerProvider) RunningWorkersArgsForCall(i int) lager.Logger + func (fake *FakeWorkerProvider) RunningWorkersCallCount() int + func (fake *FakeWorkerProvider) RunningWorkersCalls(stub func(lager.Logger) ([]worker.Worker, error)) + func (fake *FakeWorkerProvider) RunningWorkersReturns(result1 []worker.Worker, result2 error) + func (fake *FakeWorkerProvider) RunningWorkersReturnsOnCall(i int, result1 []worker.Worker, result2 error)