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
Index ¶
- type FakeCache
- func (fake *FakeCache) Initialize() error
- func (fake *FakeCache) InitializeCallCount() int
- func (fake *FakeCache) InitializeReturns(result1 error)
- func (fake *FakeCache) InitializeReturnsOnCall(i int, result1 error)
- func (fake *FakeCache) Invocations() map[string][][]interface{}
- func (fake *FakeCache) IsInitialized() (bool, error)
- func (fake *FakeCache) IsInitializedCallCount() int
- func (fake *FakeCache) IsInitializedReturns(result1 bool, result2 error)
- func (fake *FakeCache) IsInitializedReturnsOnCall(i int, result1 bool, result2 error)
- func (fake *FakeCache) Volume() worker.Volume
- func (fake *FakeCache) VolumeCallCount() int
- func (fake *FakeCache) VolumeReturns(result1 worker.Volume)
- func (fake *FakeCache) VolumeReturnsOnCall(i int, result1 worker.Volume)
- type FakeFetchSource
- func (fake *FakeFetchSource) Initialize(signals <-chan os.Signal, ready chan<- struct{}) error
- func (fake *FakeFetchSource) InitializeArgsForCall(i int) (<-chan os.Signal, chan<- struct{})
- func (fake *FakeFetchSource) InitializeCallCount() int
- func (fake *FakeFetchSource) InitializeReturns(result1 error)
- func (fake *FakeFetchSource) InitializeReturnsOnCall(i int, result1 error)
- func (fake *FakeFetchSource) Invocations() map[string][][]interface{}
- func (fake *FakeFetchSource) IsInitialized() (bool, error)
- func (fake *FakeFetchSource) IsInitializedCallCount() int
- func (fake *FakeFetchSource) IsInitializedReturns(result1 bool, result2 error)
- func (fake *FakeFetchSource) IsInitializedReturnsOnCall(i int, result1 bool, result2 error)
- func (fake *FakeFetchSource) LockName() (string, error)
- func (fake *FakeFetchSource) LockNameCallCount() int
- func (fake *FakeFetchSource) LockNameReturns(result1 string, result2 error)
- func (fake *FakeFetchSource) LockNameReturnsOnCall(i int, result1 string, result2 error)
- func (fake *FakeFetchSource) VersionedSource() resource.VersionedSource
- func (fake *FakeFetchSource) VersionedSourceCallCount() int
- func (fake *FakeFetchSource) VersionedSourceReturns(result1 resource.VersionedSource)
- func (fake *FakeFetchSource) VersionedSourceReturnsOnCall(i int, result1 resource.VersionedSource)
- type FakeFetchSourceProvider
- func (fake *FakeFetchSourceProvider) Get() (resource.FetchSource, error)
- func (fake *FakeFetchSourceProvider) GetCallCount() int
- func (fake *FakeFetchSourceProvider) GetReturns(result1 resource.FetchSource, result2 error)
- func (fake *FakeFetchSourceProvider) GetReturnsOnCall(i int, result1 resource.FetchSource, result2 error)
- func (fake *FakeFetchSourceProvider) Invocations() map[string][][]interface{}
- type FakeFetchSourceProviderFactory
- func (fake *FakeFetchSourceProviderFactory) Invocations() map[string][][]interface{}
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProvider(logger lager.Logger, session resource.Session, metadata resource.Metadata, ...) resource.FetchSourceProvider
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall(i int) (lager.Logger, resource.Session, resource.Metadata, atc.Tags, int, ...)
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount() int
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns(result1 resource.FetchSourceProvider)
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturnsOnCall(i int, result1 resource.FetchSourceProvider)
- type FakeFetcher
- func (fake *FakeFetcher) Fetch(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, ...) (resource.FetchSource, error)
- func (fake *FakeFetcher) FetchArgsForCall(i int) (lager.Logger, resource.Session, atc.Tags, int, atc.VersionedResourceTypes, ...)
- func (fake *FakeFetcher) FetchCallCount() int
- func (fake *FakeFetcher) FetchReturns(result1 resource.FetchSource, result2 error)
- func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 resource.FetchSource, result2 error)
- func (fake *FakeFetcher) Invocations() map[string][][]interface{}
- type FakeFetcherFactory
- func (fake *FakeFetcherFactory) FetcherFor(workerClient worker.Client) resource.Fetcher
- func (fake *FakeFetcherFactory) FetcherForArgsForCall(i int) worker.Client
- func (fake *FakeFetcherFactory) FetcherForCallCount() int
- func (fake *FakeFetcherFactory) FetcherForReturns(result1 resource.Fetcher)
- func (fake *FakeFetcherFactory) FetcherForReturnsOnCall(i int, result1 resource.Fetcher)
- func (fake *FakeFetcherFactory) Invocations() map[string][][]interface{}
- type FakeLockDB
- func (fake *FakeLockDB) GetTaskLock(logger lager.Logger, lockName string) (lock.Lock, bool, error)
- func (fake *FakeLockDB) GetTaskLockArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeLockDB) GetTaskLockCallCount() int
- func (fake *FakeLockDB) GetTaskLockReturns(result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) GetTaskLockReturnsOnCall(i int, result1 lock.Lock, result2 bool, result3 error)
- func (fake *FakeLockDB) Invocations() map[string][][]interface{}
- type FakeResource
- func (fake *FakeResource) Check(arg1 atc.Source, arg2 atc.Version) ([]atc.Version, error)
- func (fake *FakeResource) CheckArgsForCall(i int) (atc.Source, atc.Version)
- func (fake *FakeResource) CheckCallCount() int
- func (fake *FakeResource) CheckReturns(result1 []atc.Version, result2 error)
- func (fake *FakeResource) CheckReturnsOnCall(i int, result1 []atc.Version, result2 error)
- func (fake *FakeResource) Container() worker.Container
- func (fake *FakeResource) ContainerCallCount() int
- func (fake *FakeResource) ContainerReturns(result1 worker.Container)
- func (fake *FakeResource) ContainerReturnsOnCall(i int, result1 worker.Container)
- func (fake *FakeResource) Get(arg1 worker.Volume, arg2 resource.IOConfig, arg3 atc.Source, arg4 atc.Params, ...) (resource.VersionedSource, error)
- func (fake *FakeResource) GetArgsForCall(i int) (worker.Volume, resource.IOConfig, atc.Source, atc.Params, atc.Version, ...)
- func (fake *FakeResource) GetCallCount() int
- func (fake *FakeResource) GetReturns(result1 resource.VersionedSource, result2 error)
- func (fake *FakeResource) GetReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
- func (fake *FakeResource) Invocations() map[string][][]interface{}
- func (fake *FakeResource) Put(arg1 resource.IOConfig, arg2 atc.Source, arg3 atc.Params, ...) (resource.VersionedSource, error)
- func (fake *FakeResource) PutArgsForCall(i int) (resource.IOConfig, atc.Source, atc.Params, <-chan os.Signal, chan<- struct{})
- func (fake *FakeResource) PutCallCount() int
- func (fake *FakeResource) PutReturns(result1 resource.VersionedSource, result2 error)
- func (fake *FakeResource) PutReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
- type FakeResourceFactory
- func (fake *FakeResourceFactory) Invocations() map[string][][]interface{}
- func (fake *FakeResourceFactory) NewCheckResource(logger lager.Logger, signals <-chan os.Signal, resourceUser dbng.ResourceUser, ...) (resource.Resource, error)
- func (fake *FakeResourceFactory) NewCheckResourceArgsForCall(i int) (lager.Logger, <-chan os.Signal, dbng.ResourceUser, dbng.ContainerMetadata, ...)
- func (fake *FakeResourceFactory) NewCheckResourceCallCount() int
- func (fake *FakeResourceFactory) NewCheckResourceReturns(result1 resource.Resource, result2 error)
- func (fake *FakeResourceFactory) NewCheckResourceReturnsOnCall(i int, result1 resource.Resource, result2 error)
- func (fake *FakeResourceFactory) NewPutResource(logger lager.Logger, signals <-chan os.Signal, buildID int, planID atc.PlanID, ...) (resource.Resource, error)
- func (fake *FakeResourceFactory) NewPutResourceArgsForCall(i int) (lager.Logger, <-chan os.Signal, int, atc.PlanID, dbng.ContainerMetadata, ...)
- func (fake *FakeResourceFactory) NewPutResourceCallCount() int
- func (fake *FakeResourceFactory) NewPutResourceReturns(result1 resource.Resource, result2 error)
- func (fake *FakeResourceFactory) NewPutResourceReturnsOnCall(i int, result1 resource.Resource, result2 error)
- type FakeResourceFactoryFactory
- func (fake *FakeResourceFactoryFactory) FactoryFor(workerClient worker.Client) resource.ResourceFactory
- func (fake *FakeResourceFactoryFactory) FactoryForArgsForCall(i int) worker.Client
- func (fake *FakeResourceFactoryFactory) FactoryForCallCount() int
- func (fake *FakeResourceFactoryFactory) FactoryForReturns(result1 resource.ResourceFactory)
- func (fake *FakeResourceFactoryFactory) FactoryForReturnsOnCall(i int, result1 resource.ResourceFactory)
- func (fake *FakeResourceFactoryFactory) Invocations() map[string][][]interface{}
- type FakeResourceInstance
- func (fake *FakeResourceInstance) CreateOn(arg1 lager.Logger, arg2 worker.Client) (worker.Volume, error)
- func (fake *FakeResourceInstance) CreateOnArgsForCall(i int) (lager.Logger, worker.Client)
- func (fake *FakeResourceInstance) CreateOnCallCount() int
- func (fake *FakeResourceInstance) CreateOnReturns(result1 worker.Volume, result2 error)
- func (fake *FakeResourceInstance) CreateOnReturnsOnCall(i int, result1 worker.Volume, result2 error)
- func (fake *FakeResourceInstance) FindInitializedOn(arg1 lager.Logger, arg2 worker.Client) (worker.Volume, bool, error)
- func (fake *FakeResourceInstance) FindInitializedOnArgsForCall(i int) (lager.Logger, worker.Client)
- func (fake *FakeResourceInstance) FindInitializedOnCallCount() int
- func (fake *FakeResourceInstance) FindInitializedOnReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeResourceInstance) FindInitializedOnReturnsOnCall(i int, result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeResourceInstance) Invocations() map[string][][]interface{}
- func (fake *FakeResourceInstance) ResourceCacheIdentifier() worker.ResourceCacheIdentifier
- func (fake *FakeResourceInstance) ResourceCacheIdentifierCallCount() int
- func (fake *FakeResourceInstance) ResourceCacheIdentifierReturns(result1 worker.ResourceCacheIdentifier)
- func (fake *FakeResourceInstance) ResourceCacheIdentifierReturnsOnCall(i int, result1 worker.ResourceCacheIdentifier)
- func (fake *FakeResourceInstance) ResourceUser() dbng.ResourceUser
- func (fake *FakeResourceInstance) ResourceUserCallCount() int
- func (fake *FakeResourceInstance) ResourceUserReturns(result1 dbng.ResourceUser)
- func (fake *FakeResourceInstance) ResourceUserReturnsOnCall(i int, result1 dbng.ResourceUser)
- type FakeResourceOptions
- func (fake *FakeResourceOptions) IOConfig() resource.IOConfig
- func (fake *FakeResourceOptions) IOConfigCallCount() int
- func (fake *FakeResourceOptions) IOConfigReturns(result1 resource.IOConfig)
- func (fake *FakeResourceOptions) IOConfigReturnsOnCall(i int, result1 resource.IOConfig)
- func (fake *FakeResourceOptions) Invocations() map[string][][]interface{}
- func (fake *FakeResourceOptions) LockName(workerName string) (string, error)
- func (fake *FakeResourceOptions) LockNameArgsForCall(i int) string
- func (fake *FakeResourceOptions) LockNameCallCount() int
- func (fake *FakeResourceOptions) LockNameReturns(result1 string, result2 error)
- func (fake *FakeResourceOptions) LockNameReturnsOnCall(i int, result1 string, result2 error)
- func (fake *FakeResourceOptions) Params() atc.Params
- func (fake *FakeResourceOptions) ParamsCallCount() int
- func (fake *FakeResourceOptions) ParamsReturns(result1 atc.Params)
- func (fake *FakeResourceOptions) ParamsReturnsOnCall(i int, result1 atc.Params)
- func (fake *FakeResourceOptions) ResourceType() resource.ResourceType
- func (fake *FakeResourceOptions) ResourceTypeCallCount() int
- func (fake *FakeResourceOptions) ResourceTypeReturns(result1 resource.ResourceType)
- func (fake *FakeResourceOptions) ResourceTypeReturnsOnCall(i int, result1 resource.ResourceType)
- func (fake *FakeResourceOptions) Source() atc.Source
- func (fake *FakeResourceOptions) SourceCallCount() int
- func (fake *FakeResourceOptions) SourceReturns(result1 atc.Source)
- func (fake *FakeResourceOptions) SourceReturnsOnCall(i int, result1 atc.Source)
- func (fake *FakeResourceOptions) Version() atc.Version
- func (fake *FakeResourceOptions) VersionCallCount() int
- func (fake *FakeResourceOptions) VersionReturns(result1 atc.Version)
- func (fake *FakeResourceOptions) VersionReturnsOnCall(i int, result1 atc.Version)
- type FakeVersionedSource
- func (fake *FakeVersionedSource) Invocations() map[string][][]interface{}
- func (fake *FakeVersionedSource) Metadata() []atc.MetadataField
- func (fake *FakeVersionedSource) MetadataCallCount() int
- func (fake *FakeVersionedSource) MetadataReturns(result1 []atc.MetadataField)
- func (fake *FakeVersionedSource) MetadataReturnsOnCall(i int, result1 []atc.MetadataField)
- func (fake *FakeVersionedSource) StreamIn(arg1 string, arg2 io.Reader) error
- func (fake *FakeVersionedSource) StreamInArgsForCall(i int) (string, io.Reader)
- func (fake *FakeVersionedSource) StreamInCallCount() int
- func (fake *FakeVersionedSource) StreamInReturns(result1 error)
- func (fake *FakeVersionedSource) StreamInReturnsOnCall(i int, result1 error)
- func (fake *FakeVersionedSource) StreamOut(arg1 string) (io.ReadCloser, error)
- func (fake *FakeVersionedSource) StreamOutArgsForCall(i int) string
- func (fake *FakeVersionedSource) StreamOutCallCount() int
- func (fake *FakeVersionedSource) StreamOutReturns(result1 io.ReadCloser, result2 error)
- func (fake *FakeVersionedSource) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
- func (fake *FakeVersionedSource) Version() atc.Version
- func (fake *FakeVersionedSource) VersionCallCount() int
- func (fake *FakeVersionedSource) VersionReturns(result1 atc.Version)
- func (fake *FakeVersionedSource) VersionReturnsOnCall(i int, result1 atc.Version)
- func (fake *FakeVersionedSource) Volume() worker.Volume
- func (fake *FakeVersionedSource) VolumeCallCount() int
- func (fake *FakeVersionedSource) VolumeReturns(result1 worker.Volume)
- func (fake *FakeVersionedSource) VolumeReturnsOnCall(i int, result1 worker.Volume)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeCache ¶
type FakeCache struct { IsInitializedStub func() (bool, error) InitializeStub func() error VolumeStub func() worker.Volume // contains filtered or unexported fields }
func (*FakeCache) Initialize ¶
func (*FakeCache) InitializeCallCount ¶
func (*FakeCache) InitializeReturns ¶
func (*FakeCache) InitializeReturnsOnCall ¶
func (*FakeCache) Invocations ¶
func (*FakeCache) IsInitialized ¶
func (*FakeCache) IsInitializedCallCount ¶
func (*FakeCache) IsInitializedReturns ¶
func (*FakeCache) IsInitializedReturnsOnCall ¶
func (*FakeCache) VolumeCallCount ¶
func (*FakeCache) VolumeReturns ¶
type FakeFetchSource ¶
type FakeFetchSource struct { IsInitializedStub func() (bool, error) LockNameStub func() (string, error) VersionedSourceStub func() resource.VersionedSource InitializeStub func(signals <-chan os.Signal, ready chan<- struct{}) error // contains filtered or unexported fields }
func (*FakeFetchSource) Initialize ¶
func (fake *FakeFetchSource) Initialize(signals <-chan os.Signal, ready chan<- struct{}) error
func (*FakeFetchSource) InitializeArgsForCall ¶
func (fake *FakeFetchSource) InitializeArgsForCall(i int) (<-chan os.Signal, chan<- struct{})
func (*FakeFetchSource) InitializeCallCount ¶
func (fake *FakeFetchSource) InitializeCallCount() int
func (*FakeFetchSource) InitializeReturns ¶
func (fake *FakeFetchSource) InitializeReturns(result1 error)
func (*FakeFetchSource) InitializeReturnsOnCall ¶
func (fake *FakeFetchSource) InitializeReturnsOnCall(i int, result1 error)
func (*FakeFetchSource) Invocations ¶
func (fake *FakeFetchSource) Invocations() map[string][][]interface{}
func (*FakeFetchSource) IsInitialized ¶
func (fake *FakeFetchSource) IsInitialized() (bool, error)
func (*FakeFetchSource) IsInitializedCallCount ¶
func (fake *FakeFetchSource) IsInitializedCallCount() int
func (*FakeFetchSource) IsInitializedReturns ¶
func (fake *FakeFetchSource) IsInitializedReturns(result1 bool, result2 error)
func (*FakeFetchSource) IsInitializedReturnsOnCall ¶
func (fake *FakeFetchSource) IsInitializedReturnsOnCall(i int, result1 bool, result2 error)
func (*FakeFetchSource) LockName ¶
func (fake *FakeFetchSource) LockName() (string, error)
func (*FakeFetchSource) LockNameCallCount ¶
func (fake *FakeFetchSource) LockNameCallCount() int
func (*FakeFetchSource) LockNameReturns ¶
func (fake *FakeFetchSource) LockNameReturns(result1 string, result2 error)
func (*FakeFetchSource) LockNameReturnsOnCall ¶
func (fake *FakeFetchSource) LockNameReturnsOnCall(i int, result1 string, result2 error)
func (*FakeFetchSource) VersionedSource ¶
func (fake *FakeFetchSource) VersionedSource() resource.VersionedSource
func (*FakeFetchSource) VersionedSourceCallCount ¶
func (fake *FakeFetchSource) VersionedSourceCallCount() int
func (*FakeFetchSource) VersionedSourceReturns ¶
func (fake *FakeFetchSource) VersionedSourceReturns(result1 resource.VersionedSource)
func (*FakeFetchSource) VersionedSourceReturnsOnCall ¶
func (fake *FakeFetchSource) VersionedSourceReturnsOnCall(i int, result1 resource.VersionedSource)
type FakeFetchSourceProvider ¶
type FakeFetchSourceProvider struct { GetStub func() (resource.FetchSource, error) // contains filtered or unexported fields }
func (*FakeFetchSourceProvider) Get ¶
func (fake *FakeFetchSourceProvider) Get() (resource.FetchSource, error)
func (*FakeFetchSourceProvider) GetCallCount ¶
func (fake *FakeFetchSourceProvider) GetCallCount() int
func (*FakeFetchSourceProvider) GetReturns ¶
func (fake *FakeFetchSourceProvider) GetReturns(result1 resource.FetchSource, result2 error)
func (*FakeFetchSourceProvider) GetReturnsOnCall ¶
func (fake *FakeFetchSourceProvider) GetReturnsOnCall(i int, result1 resource.FetchSource, result2 error)
func (*FakeFetchSourceProvider) Invocations ¶
func (fake *FakeFetchSourceProvider) Invocations() map[string][][]interface{}
type FakeFetchSourceProviderFactory ¶
type FakeFetchSourceProviderFactory struct { NewFetchSourceProviderStub func(logger lager.Logger, session resource.Session, metadata resource.Metadata, tags atc.Tags, teamID int, resourceTypes atc.VersionedResourceTypes, resourceInstance resource.ResourceInstance, resourceOptions resource.ResourceOptions, imageFetchingDelegate worker.ImageFetchingDelegate) resource.FetchSourceProvider // contains filtered or unexported fields }
func (*FakeFetchSourceProviderFactory) Invocations ¶
func (fake *FakeFetchSourceProviderFactory) Invocations() map[string][][]interface{}
func (*FakeFetchSourceProviderFactory) NewFetchSourceProvider ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProvider(logger lager.Logger, session resource.Session, metadata resource.Metadata, tags atc.Tags, teamID int, resourceTypes atc.VersionedResourceTypes, resourceInstance resource.ResourceInstance, resourceOptions resource.ResourceOptions, imageFetchingDelegate worker.ImageFetchingDelegate) resource.FetchSourceProvider
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall(i int) (lager.Logger, resource.Session, resource.Metadata, atc.Tags, int, atc.VersionedResourceTypes, resource.ResourceInstance, resource.ResourceOptions, worker.ImageFetchingDelegate)
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount() int
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns(result1 resource.FetchSourceProvider)
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderReturnsOnCall ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturnsOnCall(i int, result1 resource.FetchSourceProvider)
type FakeFetcher ¶
type FakeFetcher struct { FetchStub func(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, resourceTypes atc.VersionedResourceTypes, resourceInstance resource.ResourceInstance, metadata resource.Metadata, imageFetchingDelegate worker.ImageFetchingDelegate, resourceOptions resource.ResourceOptions, signals <-chan os.Signal, ready chan<- struct{}) (resource.FetchSource, error) // contains filtered or unexported fields }
func (*FakeFetcher) Fetch ¶
func (fake *FakeFetcher) Fetch(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, resourceTypes atc.VersionedResourceTypes, resourceInstance resource.ResourceInstance, metadata resource.Metadata, imageFetchingDelegate worker.ImageFetchingDelegate, resourceOptions resource.ResourceOptions, signals <-chan os.Signal, ready chan<- struct{}) (resource.FetchSource, error)
func (*FakeFetcher) FetchArgsForCall ¶
func (fake *FakeFetcher) FetchArgsForCall(i int) (lager.Logger, resource.Session, atc.Tags, int, atc.VersionedResourceTypes, resource.ResourceInstance, resource.Metadata, worker.ImageFetchingDelegate, resource.ResourceOptions, <-chan os.Signal, chan<- struct{})
func (*FakeFetcher) FetchCallCount ¶
func (fake *FakeFetcher) FetchCallCount() int
func (*FakeFetcher) FetchReturns ¶
func (fake *FakeFetcher) FetchReturns(result1 resource.FetchSource, result2 error)
func (*FakeFetcher) FetchReturnsOnCall ¶
func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 resource.FetchSource, result2 error)
func (*FakeFetcher) Invocations ¶
func (fake *FakeFetcher) Invocations() map[string][][]interface{}
type FakeFetcherFactory ¶
type FakeFetcherFactory struct { FetcherForStub func(workerClient worker.Client) resource.Fetcher // contains filtered or unexported fields }
func (*FakeFetcherFactory) FetcherFor ¶
func (fake *FakeFetcherFactory) FetcherFor(workerClient worker.Client) resource.Fetcher
func (*FakeFetcherFactory) FetcherForArgsForCall ¶
func (fake *FakeFetcherFactory) FetcherForArgsForCall(i int) worker.Client
func (*FakeFetcherFactory) FetcherForCallCount ¶
func (fake *FakeFetcherFactory) FetcherForCallCount() int
func (*FakeFetcherFactory) FetcherForReturns ¶
func (fake *FakeFetcherFactory) FetcherForReturns(result1 resource.Fetcher)
func (*FakeFetcherFactory) FetcherForReturnsOnCall ¶
func (fake *FakeFetcherFactory) FetcherForReturnsOnCall(i int, result1 resource.Fetcher)
func (*FakeFetcherFactory) Invocations ¶
func (fake *FakeFetcherFactory) Invocations() map[string][][]interface{}
type FakeLockDB ¶
type FakeLockDB struct { GetTaskLockStub func(logger lager.Logger, lockName string) (lock.Lock, bool, error) // contains filtered or unexported fields }
func (*FakeLockDB) GetTaskLock ¶
func (*FakeLockDB) GetTaskLockArgsForCall ¶
func (fake *FakeLockDB) GetTaskLockArgsForCall(i int) (lager.Logger, string)
func (*FakeLockDB) GetTaskLockCallCount ¶
func (fake *FakeLockDB) GetTaskLockCallCount() int
func (*FakeLockDB) GetTaskLockReturns ¶
func (fake *FakeLockDB) GetTaskLockReturns(result1 lock.Lock, result2 bool, result3 error)
func (*FakeLockDB) GetTaskLockReturnsOnCall ¶
func (*FakeLockDB) Invocations ¶
func (fake *FakeLockDB) Invocations() map[string][][]interface{}
type FakeResource ¶
type FakeResource struct { GetStub func(worker.Volume, resource.IOConfig, atc.Source, atc.Params, atc.Version, <-chan os.Signal, chan<- struct{}) (resource.VersionedSource, error) PutStub func(resource.IOConfig, atc.Source, atc.Params, <-chan os.Signal, chan<- struct{}) (resource.VersionedSource, error) CheckStub func(atc.Source, atc.Version) ([]atc.Version, error) ContainerStub func() worker.Container // contains filtered or unexported fields }
func (*FakeResource) CheckArgsForCall ¶
func (*FakeResource) CheckCallCount ¶
func (fake *FakeResource) CheckCallCount() int
func (*FakeResource) CheckReturns ¶
func (fake *FakeResource) CheckReturns(result1 []atc.Version, result2 error)
func (*FakeResource) CheckReturnsOnCall ¶
func (fake *FakeResource) CheckReturnsOnCall(i int, result1 []atc.Version, result2 error)
func (*FakeResource) Container ¶
func (fake *FakeResource) Container() worker.Container
func (*FakeResource) ContainerCallCount ¶
func (fake *FakeResource) ContainerCallCount() int
func (*FakeResource) ContainerReturns ¶
func (fake *FakeResource) ContainerReturns(result1 worker.Container)
func (*FakeResource) ContainerReturnsOnCall ¶
func (fake *FakeResource) ContainerReturnsOnCall(i int, result1 worker.Container)
func (*FakeResource) GetArgsForCall ¶
func (*FakeResource) GetCallCount ¶
func (fake *FakeResource) GetCallCount() int
func (*FakeResource) GetReturns ¶
func (fake *FakeResource) GetReturns(result1 resource.VersionedSource, result2 error)
func (*FakeResource) GetReturnsOnCall ¶
func (fake *FakeResource) GetReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
func (*FakeResource) Invocations ¶
func (fake *FakeResource) Invocations() map[string][][]interface{}
func (*FakeResource) PutArgsForCall ¶
func (*FakeResource) PutCallCount ¶
func (fake *FakeResource) PutCallCount() int
func (*FakeResource) PutReturns ¶
func (fake *FakeResource) PutReturns(result1 resource.VersionedSource, result2 error)
func (*FakeResource) PutReturnsOnCall ¶
func (fake *FakeResource) PutReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
type FakeResourceFactory ¶
type FakeResourceFactory struct { NewPutResourceStub func(logger lager.Logger, signals <-chan os.Signal, buildID int, planID atc.PlanID, metadata dbng.ContainerMetadata, containerSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate) (resource.Resource, error) NewCheckResourceStub func(logger lager.Logger, signals <-chan os.Signal, resourceUser dbng.ResourceUser, metadata dbng.ContainerMetadata, resourceSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceConfig atc.ResourceConfig) (resource.Resource, error) // contains filtered or unexported fields }
func (*FakeResourceFactory) Invocations ¶
func (fake *FakeResourceFactory) Invocations() map[string][][]interface{}
func (*FakeResourceFactory) NewCheckResource ¶
func (fake *FakeResourceFactory) NewCheckResource(logger lager.Logger, signals <-chan os.Signal, resourceUser dbng.ResourceUser, metadata dbng.ContainerMetadata, resourceSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate, resourceConfig atc.ResourceConfig) (resource.Resource, error)
func (*FakeResourceFactory) NewCheckResourceArgsForCall ¶
func (fake *FakeResourceFactory) NewCheckResourceArgsForCall(i int) (lager.Logger, <-chan os.Signal, dbng.ResourceUser, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, worker.ImageFetchingDelegate, atc.ResourceConfig)
func (*FakeResourceFactory) NewCheckResourceCallCount ¶
func (fake *FakeResourceFactory) NewCheckResourceCallCount() int
func (*FakeResourceFactory) NewCheckResourceReturns ¶
func (fake *FakeResourceFactory) NewCheckResourceReturns(result1 resource.Resource, result2 error)
func (*FakeResourceFactory) NewCheckResourceReturnsOnCall ¶
func (fake *FakeResourceFactory) NewCheckResourceReturnsOnCall(i int, result1 resource.Resource, result2 error)
func (*FakeResourceFactory) NewPutResource ¶
func (fake *FakeResourceFactory) NewPutResource(logger lager.Logger, signals <-chan os.Signal, buildID int, planID atc.PlanID, metadata dbng.ContainerMetadata, containerSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate) (resource.Resource, error)
func (*FakeResourceFactory) NewPutResourceArgsForCall ¶
func (fake *FakeResourceFactory) NewPutResourceArgsForCall(i int) (lager.Logger, <-chan os.Signal, int, atc.PlanID, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, worker.ImageFetchingDelegate)
func (*FakeResourceFactory) NewPutResourceCallCount ¶
func (fake *FakeResourceFactory) NewPutResourceCallCount() int
func (*FakeResourceFactory) NewPutResourceReturns ¶
func (fake *FakeResourceFactory) NewPutResourceReturns(result1 resource.Resource, result2 error)
func (*FakeResourceFactory) NewPutResourceReturnsOnCall ¶
func (fake *FakeResourceFactory) NewPutResourceReturnsOnCall(i int, result1 resource.Resource, result2 error)
type FakeResourceFactoryFactory ¶
type FakeResourceFactoryFactory struct { FactoryForStub func(workerClient worker.Client) resource.ResourceFactory // contains filtered or unexported fields }
func (*FakeResourceFactoryFactory) FactoryFor ¶
func (fake *FakeResourceFactoryFactory) FactoryFor(workerClient worker.Client) resource.ResourceFactory
func (*FakeResourceFactoryFactory) FactoryForArgsForCall ¶
func (fake *FakeResourceFactoryFactory) FactoryForArgsForCall(i int) worker.Client
func (*FakeResourceFactoryFactory) FactoryForCallCount ¶
func (fake *FakeResourceFactoryFactory) FactoryForCallCount() int
func (*FakeResourceFactoryFactory) FactoryForReturns ¶
func (fake *FakeResourceFactoryFactory) FactoryForReturns(result1 resource.ResourceFactory)
func (*FakeResourceFactoryFactory) FactoryForReturnsOnCall ¶
func (fake *FakeResourceFactoryFactory) FactoryForReturnsOnCall(i int, result1 resource.ResourceFactory)
func (*FakeResourceFactoryFactory) Invocations ¶
func (fake *FakeResourceFactoryFactory) Invocations() map[string][][]interface{}
type FakeResourceInstance ¶
type FakeResourceInstance struct { ResourceUserStub func() dbng.ResourceUser FindInitializedOnStub func(lager.Logger, worker.Client) (worker.Volume, bool, error) CreateOnStub func(lager.Logger, worker.Client) (worker.Volume, error) ResourceCacheIdentifierStub func() worker.ResourceCacheIdentifier // contains filtered or unexported fields }
func (*FakeResourceInstance) CreateOnArgsForCall ¶
func (*FakeResourceInstance) CreateOnCallCount ¶
func (fake *FakeResourceInstance) CreateOnCallCount() int
func (*FakeResourceInstance) CreateOnReturns ¶
func (fake *FakeResourceInstance) CreateOnReturns(result1 worker.Volume, result2 error)
func (*FakeResourceInstance) CreateOnReturnsOnCall ¶
func (fake *FakeResourceInstance) CreateOnReturnsOnCall(i int, result1 worker.Volume, result2 error)
func (*FakeResourceInstance) FindInitializedOn ¶
func (*FakeResourceInstance) FindInitializedOnArgsForCall ¶
func (*FakeResourceInstance) FindInitializedOnCallCount ¶
func (fake *FakeResourceInstance) FindInitializedOnCallCount() int
func (*FakeResourceInstance) FindInitializedOnReturns ¶
func (fake *FakeResourceInstance) FindInitializedOnReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeResourceInstance) FindInitializedOnReturnsOnCall ¶
func (*FakeResourceInstance) Invocations ¶
func (fake *FakeResourceInstance) Invocations() map[string][][]interface{}
func (*FakeResourceInstance) ResourceCacheIdentifier ¶
func (fake *FakeResourceInstance) ResourceCacheIdentifier() worker.ResourceCacheIdentifier
func (*FakeResourceInstance) ResourceCacheIdentifierCallCount ¶
func (fake *FakeResourceInstance) ResourceCacheIdentifierCallCount() int
func (*FakeResourceInstance) ResourceCacheIdentifierReturns ¶
func (fake *FakeResourceInstance) ResourceCacheIdentifierReturns(result1 worker.ResourceCacheIdentifier)
func (*FakeResourceInstance) ResourceCacheIdentifierReturnsOnCall ¶
func (fake *FakeResourceInstance) ResourceCacheIdentifierReturnsOnCall(i int, result1 worker.ResourceCacheIdentifier)
func (*FakeResourceInstance) ResourceUser ¶
func (fake *FakeResourceInstance) ResourceUser() dbng.ResourceUser
func (*FakeResourceInstance) ResourceUserCallCount ¶
func (fake *FakeResourceInstance) ResourceUserCallCount() int
func (*FakeResourceInstance) ResourceUserReturns ¶
func (fake *FakeResourceInstance) ResourceUserReturns(result1 dbng.ResourceUser)
func (*FakeResourceInstance) ResourceUserReturnsOnCall ¶
func (fake *FakeResourceInstance) ResourceUserReturnsOnCall(i int, result1 dbng.ResourceUser)
type FakeResourceOptions ¶
type FakeResourceOptions struct { IOConfigStub func() resource.IOConfig SourceStub func() atc.Source ParamsStub func() atc.Params VersionStub func() atc.Version ResourceTypeStub func() resource.ResourceType LockNameStub func(workerName string) (string, error) // contains filtered or unexported fields }
func (*FakeResourceOptions) IOConfig ¶
func (fake *FakeResourceOptions) IOConfig() resource.IOConfig
func (*FakeResourceOptions) IOConfigCallCount ¶
func (fake *FakeResourceOptions) IOConfigCallCount() int
func (*FakeResourceOptions) IOConfigReturns ¶
func (fake *FakeResourceOptions) IOConfigReturns(result1 resource.IOConfig)
func (*FakeResourceOptions) IOConfigReturnsOnCall ¶
func (fake *FakeResourceOptions) IOConfigReturnsOnCall(i int, result1 resource.IOConfig)
func (*FakeResourceOptions) Invocations ¶
func (fake *FakeResourceOptions) Invocations() map[string][][]interface{}
func (*FakeResourceOptions) LockName ¶
func (fake *FakeResourceOptions) LockName(workerName string) (string, error)
func (*FakeResourceOptions) LockNameArgsForCall ¶
func (fake *FakeResourceOptions) LockNameArgsForCall(i int) string
func (*FakeResourceOptions) LockNameCallCount ¶
func (fake *FakeResourceOptions) LockNameCallCount() int
func (*FakeResourceOptions) LockNameReturns ¶
func (fake *FakeResourceOptions) LockNameReturns(result1 string, result2 error)
func (*FakeResourceOptions) LockNameReturnsOnCall ¶
func (fake *FakeResourceOptions) LockNameReturnsOnCall(i int, result1 string, result2 error)
func (*FakeResourceOptions) Params ¶
func (fake *FakeResourceOptions) Params() atc.Params
func (*FakeResourceOptions) ParamsCallCount ¶
func (fake *FakeResourceOptions) ParamsCallCount() int
func (*FakeResourceOptions) ParamsReturns ¶
func (fake *FakeResourceOptions) ParamsReturns(result1 atc.Params)
func (*FakeResourceOptions) ParamsReturnsOnCall ¶
func (fake *FakeResourceOptions) ParamsReturnsOnCall(i int, result1 atc.Params)
func (*FakeResourceOptions) ResourceType ¶
func (fake *FakeResourceOptions) ResourceType() resource.ResourceType
func (*FakeResourceOptions) ResourceTypeCallCount ¶
func (fake *FakeResourceOptions) ResourceTypeCallCount() int
func (*FakeResourceOptions) ResourceTypeReturns ¶
func (fake *FakeResourceOptions) ResourceTypeReturns(result1 resource.ResourceType)
func (*FakeResourceOptions) ResourceTypeReturnsOnCall ¶
func (fake *FakeResourceOptions) ResourceTypeReturnsOnCall(i int, result1 resource.ResourceType)
func (*FakeResourceOptions) Source ¶
func (fake *FakeResourceOptions) Source() atc.Source
func (*FakeResourceOptions) SourceCallCount ¶
func (fake *FakeResourceOptions) SourceCallCount() int
func (*FakeResourceOptions) SourceReturns ¶
func (fake *FakeResourceOptions) SourceReturns(result1 atc.Source)
func (*FakeResourceOptions) SourceReturnsOnCall ¶
func (fake *FakeResourceOptions) SourceReturnsOnCall(i int, result1 atc.Source)
func (*FakeResourceOptions) Version ¶
func (fake *FakeResourceOptions) Version() atc.Version
func (*FakeResourceOptions) VersionCallCount ¶
func (fake *FakeResourceOptions) VersionCallCount() int
func (*FakeResourceOptions) VersionReturns ¶
func (fake *FakeResourceOptions) VersionReturns(result1 atc.Version)
func (*FakeResourceOptions) VersionReturnsOnCall ¶
func (fake *FakeResourceOptions) VersionReturnsOnCall(i int, result1 atc.Version)
type FakeVersionedSource ¶
type FakeVersionedSource struct { VersionStub func() atc.Version MetadataStub func() []atc.MetadataField StreamOutStub func(string) (io.ReadCloser, error) StreamInStub func(string, io.Reader) error VolumeStub func() worker.Volume // contains filtered or unexported fields }
func (*FakeVersionedSource) Invocations ¶
func (fake *FakeVersionedSource) Invocations() map[string][][]interface{}
func (*FakeVersionedSource) Metadata ¶
func (fake *FakeVersionedSource) Metadata() []atc.MetadataField
func (*FakeVersionedSource) MetadataCallCount ¶
func (fake *FakeVersionedSource) MetadataCallCount() int
func (*FakeVersionedSource) MetadataReturns ¶
func (fake *FakeVersionedSource) MetadataReturns(result1 []atc.MetadataField)
func (*FakeVersionedSource) MetadataReturnsOnCall ¶
func (fake *FakeVersionedSource) MetadataReturnsOnCall(i int, result1 []atc.MetadataField)
func (*FakeVersionedSource) StreamIn ¶
func (fake *FakeVersionedSource) StreamIn(arg1 string, arg2 io.Reader) error
func (*FakeVersionedSource) StreamInArgsForCall ¶
func (fake *FakeVersionedSource) StreamInArgsForCall(i int) (string, io.Reader)
func (*FakeVersionedSource) StreamInCallCount ¶
func (fake *FakeVersionedSource) StreamInCallCount() int
func (*FakeVersionedSource) StreamInReturns ¶
func (fake *FakeVersionedSource) StreamInReturns(result1 error)
func (*FakeVersionedSource) StreamInReturnsOnCall ¶
func (fake *FakeVersionedSource) StreamInReturnsOnCall(i int, result1 error)
func (*FakeVersionedSource) StreamOut ¶
func (fake *FakeVersionedSource) StreamOut(arg1 string) (io.ReadCloser, error)
func (*FakeVersionedSource) StreamOutArgsForCall ¶
func (fake *FakeVersionedSource) StreamOutArgsForCall(i int) string
func (*FakeVersionedSource) StreamOutCallCount ¶
func (fake *FakeVersionedSource) StreamOutCallCount() int
func (*FakeVersionedSource) StreamOutReturns ¶
func (fake *FakeVersionedSource) StreamOutReturns(result1 io.ReadCloser, result2 error)
func (*FakeVersionedSource) StreamOutReturnsOnCall ¶
func (fake *FakeVersionedSource) StreamOutReturnsOnCall(i int, result1 io.ReadCloser, result2 error)
func (*FakeVersionedSource) Version ¶
func (fake *FakeVersionedSource) Version() atc.Version
func (*FakeVersionedSource) VersionCallCount ¶
func (fake *FakeVersionedSource) VersionCallCount() int
func (*FakeVersionedSource) VersionReturns ¶
func (fake *FakeVersionedSource) VersionReturns(result1 atc.Version)
func (*FakeVersionedSource) VersionReturnsOnCall ¶
func (fake *FakeVersionedSource) VersionReturnsOnCall(i int, result1 atc.Version)
func (*FakeVersionedSource) Volume ¶
func (fake *FakeVersionedSource) Volume() worker.Volume
func (*FakeVersionedSource) VolumeCallCount ¶
func (fake *FakeVersionedSource) VolumeCallCount() int
func (*FakeVersionedSource) VolumeReturns ¶
func (fake *FakeVersionedSource) VolumeReturns(result1 worker.Volume)
func (*FakeVersionedSource) VolumeReturnsOnCall ¶
func (fake *FakeVersionedSource) VolumeReturnsOnCall(i int, result1 worker.Volume)
Source Files ¶
- fake_cache.go
- fake_fetch_source.go
- fake_fetch_source_provider.go
- fake_fetch_source_provider_factory.go
- fake_fetcher.go
- fake_fetcher_factory.go
- fake_lock_db.go
- fake_resource.go
- fake_resource_factory.go
- fake_resource_factory_factory.go
- fake_resource_instance.go
- fake_resource_options.go
- fake_versioned_source.go
Click to show internal directories.
Click to hide internal directories.