Documentation ¶
Overview ¶
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
Code generated by counterfeiter. DO NOT EDIT.
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) FindInitialized() (resource.VersionedSource, bool, error)
- func (fake *FakeFetchSource) FindInitializedCallCount() int
- func (fake *FakeFetchSource) FindInitializedReturns(result1 resource.VersionedSource, result2 bool, result3 error)
- func (fake *FakeFetchSource) FindInitializedReturnsOnCall(i int, result1 resource.VersionedSource, result2 bool, result3 error)
- func (fake *FakeFetchSource) Initialize(signals <-chan os.Signal, ready chan<- struct{}) (resource.VersionedSource, error)
- func (fake *FakeFetchSource) InitializeArgsForCall(i int) (<-chan os.Signal, chan<- struct{})
- func (fake *FakeFetchSource) InitializeCallCount() int
- func (fake *FakeFetchSource) InitializeReturns(result1 resource.VersionedSource, result2 error)
- func (fake *FakeFetchSource) InitializeReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
- func (fake *FakeFetchSource) Invocations() map[string][][]interface{}
- 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)
- 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.VersionedSource, 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.VersionedSource, result2 error)
- func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 resource.VersionedSource, 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, string, atc.Source, ...)
- 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 { LockNameStub func() (string, error) FindInitializedStub func() (resource.VersionedSource, bool, error) InitializeStub func(signals <-chan os.Signal, ready chan<- struct{}) (resource.VersionedSource, error) // contains filtered or unexported fields }
func (*FakeFetchSource) FindInitialized ¶
func (fake *FakeFetchSource) FindInitialized() (resource.VersionedSource, bool, error)
func (*FakeFetchSource) FindInitializedCallCount ¶
func (fake *FakeFetchSource) FindInitializedCallCount() int
func (*FakeFetchSource) FindInitializedReturns ¶
func (fake *FakeFetchSource) FindInitializedReturns(result1 resource.VersionedSource, result2 bool, result3 error)
func (*FakeFetchSource) FindInitializedReturnsOnCall ¶
func (fake *FakeFetchSource) FindInitializedReturnsOnCall(i int, result1 resource.VersionedSource, result2 bool, result3 error)
func (*FakeFetchSource) Initialize ¶
func (fake *FakeFetchSource) Initialize(signals <-chan os.Signal, ready chan<- struct{}) (resource.VersionedSource, 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 resource.VersionedSource, result2 error)
func (*FakeFetchSource) InitializeReturnsOnCall ¶
func (fake *FakeFetchSource) InitializeReturnsOnCall(i int, result1 resource.VersionedSource, result2 error)
func (*FakeFetchSource) Invocations ¶
func (fake *FakeFetchSource) Invocations() map[string][][]interface{}
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)
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.VersionedSource, 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.VersionedSource, 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.VersionedSource, result2 error)
func (*FakeFetcher) FetchReturnsOnCall ¶
func (fake *FakeFetcher) FetchReturnsOnCall(i int, result1 resource.VersionedSource, 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, resourceType string, resourceSource atc.Source, metadata dbng.ContainerMetadata, resourceSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate) (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, resourceType string, resourceSource atc.Source, metadata dbng.ContainerMetadata, resourceSpec worker.ContainerSpec, resourceTypes atc.VersionedResourceTypes, imageFetchingDelegate worker.ImageFetchingDelegate) (resource.Resource, error)
func (*FakeResourceFactory) NewCheckResourceArgsForCall ¶
func (fake *FakeResourceFactory) NewCheckResourceArgsForCall(i int) (lager.Logger, <-chan os.Signal, dbng.ResourceUser, string, atc.Source, dbng.ContainerMetadata, worker.ContainerSpec, atc.VersionedResourceTypes, worker.ImageFetchingDelegate)
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.