Documentation ¶
Overview ¶
This file was generated by counterfeiter
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter ¶
This file was generated by counterfeiter
Index ¶
- type FakeArtifactDestination
- func (fake *FakeArtifactDestination) Invocations() map[string][][]interface{}
- func (fake *FakeArtifactDestination) StreamIn(arg1 string, arg2 io.Reader) error
- func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (string, io.Reader)
- func (fake *FakeArtifactDestination) StreamInCallCount() int
- func (fake *FakeArtifactDestination) StreamInReturns(result1 error)
- type FakeArtifactSource
- func (fake *FakeArtifactSource) Invocations() map[string][][]interface{}
- func (fake *FakeArtifactSource) StreamTo(arg1 resource.ArtifactDestination) error
- func (fake *FakeArtifactSource) StreamToArgsForCall(i int) resource.ArtifactDestination
- func (fake *FakeArtifactSource) StreamToCallCount() int
- func (fake *FakeArtifactSource) StreamToReturns(result1 error)
- func (fake *FakeArtifactSource) VolumeOn(arg1 worker.Worker) (worker.Volume, bool, error)
- func (fake *FakeArtifactSource) VolumeOnArgsForCall(i int) worker.Worker
- func (fake *FakeArtifactSource) VolumeOnCallCount() int
- func (fake *FakeArtifactSource) VolumeOnReturns(result1 worker.Volume, result2 bool, result3 error)
- type FakeCache
- func (fake *FakeCache) Initialize() error
- func (fake *FakeCache) InitializeCallCount() int
- func (fake *FakeCache) InitializeReturns(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) Volume() worker.Volume
- func (fake *FakeCache) VolumeCallCount() int
- func (fake *FakeCache) VolumeReturns(result1 worker.Volume)
- type FakeCacheIdentifier
- func (fake *FakeCacheIdentifier) CreateOn(arg1 lager.Logger, arg2 worker.Client) (worker.Volume, error)
- func (fake *FakeCacheIdentifier) CreateOnArgsForCall(i int) (lager.Logger, worker.Client)
- func (fake *FakeCacheIdentifier) CreateOnCallCount() int
- func (fake *FakeCacheIdentifier) CreateOnReturns(result1 worker.Volume, result2 error)
- func (fake *FakeCacheIdentifier) FindOn(arg1 lager.Logger, arg2 worker.Client) (worker.Volume, bool, error)
- func (fake *FakeCacheIdentifier) FindOnArgsForCall(i int) (lager.Logger, worker.Client)
- func (fake *FakeCacheIdentifier) FindOnCallCount() int
- func (fake *FakeCacheIdentifier) FindOnReturns(result1 worker.Volume, result2 bool, result3 error)
- func (fake *FakeCacheIdentifier) Invocations() map[string][][]interface{}
- func (fake *FakeCacheIdentifier) VolumeIdentifier() worker.VolumeIdentifier
- func (fake *FakeCacheIdentifier) VolumeIdentifierCallCount() int
- func (fake *FakeCacheIdentifier) VolumeIdentifierReturns(result1 worker.VolumeIdentifier)
- type FakeFetchContainerCreator
- func (fake *FakeFetchContainerCreator) CreateWithVolume(arg1 string, arg2 worker.Volume, arg3 worker.Worker) (worker.Container, error)
- func (fake *FakeFetchContainerCreator) CreateWithVolumeArgsForCall(i int) (string, worker.Volume, worker.Worker)
- func (fake *FakeFetchContainerCreator) CreateWithVolumeCallCount() int
- func (fake *FakeFetchContainerCreator) CreateWithVolumeReturns(result1 worker.Container, result2 error)
- func (fake *FakeFetchContainerCreator) Invocations() map[string][][]interface{}
- type FakeFetchContainerCreatorFactory
- func (fake *FakeFetchContainerCreatorFactory) Invocations() map[string][][]interface{}
- func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreator(logger lager.Logger, resourceTypes atc.ResourceTypes, tags atc.Tags, ...) resource.FetchContainerCreator
- func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorArgsForCall(i int) (lager.Logger, atc.ResourceTypes, atc.Tags, int, resource.Session, ...)
- func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorCallCount() int
- func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorReturns(result1 resource.FetchContainerCreator)
- 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) 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) LockName() (string, error)
- func (fake *FakeFetchSource) LockNameCallCount() int
- func (fake *FakeFetchSource) LockNameReturns(result1 string, result2 error)
- func (fake *FakeFetchSource) Release(arg1 *time.Duration)
- func (fake *FakeFetchSource) ReleaseArgsForCall(i int) *time.Duration
- func (fake *FakeFetchSource) ReleaseCallCount() int
- func (fake *FakeFetchSource) VersionedSource() resource.VersionedSource
- func (fake *FakeFetchSource) VersionedSourceCallCount() int
- func (fake *FakeFetchSource) VersionedSourceReturns(result1 resource.VersionedSource)
- type FakeFetchSourceProvider
- type FakeFetchSourceProviderFactory
- func (fake *FakeFetchSourceProviderFactory) Invocations() map[string][][]interface{}
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProvider(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, ...) resource.FetchSourceProvider
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall(i int) (lager.Logger, resource.Session, atc.Tags, int, atc.ResourceTypes, ...)
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount() int
- func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns(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.ResourceTypes, ...)
- func (fake *FakeFetcher) FetchCallCount() int
- func (fake *FakeFetcher) FetchReturns(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) Invocations() map[string][][]interface{}
- type FakeLockDB
- func (fake *FakeLockDB) GetTaskLock(logger lager.Logger, lockName string) (db.Lock, bool, error)
- func (fake *FakeLockDB) GetTaskLockArgsForCall(i int) (lager.Logger, string)
- func (fake *FakeLockDB) GetTaskLockCallCount() int
- func (fake *FakeLockDB) GetTaskLockReturns(result1 db.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) 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) 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, resource.ArtifactSource, ...)
- func (fake *FakeResource) PutCallCount() int
- func (fake *FakeResource) PutReturns(result1 resource.VersionedSource, result2 error)
- func (fake *FakeResource) Release(arg1 *time.Duration)
- func (fake *FakeResource) ReleaseArgsForCall(i int) *time.Duration
- func (fake *FakeResource) ReleaseCallCount() int
- type FakeResourceOptions
- func (fake *FakeResourceOptions) IOConfig() resource.IOConfig
- func (fake *FakeResourceOptions) IOConfigCallCount() int
- func (fake *FakeResourceOptions) IOConfigReturns(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) Params() atc.Params
- func (fake *FakeResourceOptions) ParamsCallCount() int
- func (fake *FakeResourceOptions) ParamsReturns(result1 atc.Params)
- func (fake *FakeResourceOptions) ResourceType() resource.ResourceType
- func (fake *FakeResourceOptions) ResourceTypeCallCount() int
- func (fake *FakeResourceOptions) ResourceTypeReturns(result1 resource.ResourceType)
- func (fake *FakeResourceOptions) Source() atc.Source
- func (fake *FakeResourceOptions) SourceCallCount() int
- func (fake *FakeResourceOptions) SourceReturns(result1 atc.Source)
- func (fake *FakeResourceOptions) Version() atc.Version
- func (fake *FakeResourceOptions) VersionCallCount() int
- func (fake *FakeResourceOptions) VersionReturns(result1 atc.Version)
- type FakeTracker
- func (fake *FakeTracker) Init(arg1 lager.Logger, arg2 resource.Metadata, arg3 resource.Session, ...) (resource.Resource, error)
- func (fake *FakeTracker) InitArgsForCall(i int) (lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, ...)
- func (fake *FakeTracker) InitCallCount() int
- func (fake *FakeTracker) InitReturns(result1 resource.Resource, result2 error)
- func (fake *FakeTracker) InitWithSources(arg1 lager.Logger, arg2 resource.Metadata, arg3 resource.Session, ...) (resource.Resource, []string, error)
- func (fake *FakeTracker) InitWithSourcesArgsForCall(i int) (lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, ...)
- func (fake *FakeTracker) InitWithSourcesCallCount() int
- func (fake *FakeTracker) InitWithSourcesReturns(result1 resource.Resource, result2 []string, result3 error)
- func (fake *FakeTracker) Invocations() map[string][][]interface{}
- type FakeTrackerFactory
- func (fake *FakeTrackerFactory) Invocations() map[string][][]interface{}
- func (fake *FakeTrackerFactory) TrackerFor(client worker.Client) resource.Tracker
- func (fake *FakeTrackerFactory) TrackerForArgsForCall(i int) worker.Client
- func (fake *FakeTrackerFactory) TrackerForCallCount() int
- func (fake *FakeTrackerFactory) TrackerForReturns(result1 resource.Tracker)
- 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) 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) 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) Version() atc.Version
- func (fake *FakeVersionedSource) VersionCallCount() int
- func (fake *FakeVersionedSource) VersionReturns(result1 atc.Version)
- func (fake *FakeVersionedSource) Volume() worker.Volume
- func (fake *FakeVersionedSource) VolumeCallCount() int
- func (fake *FakeVersionedSource) VolumeReturns(result1 worker.Volume)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeArtifactDestination ¶
type FakeArtifactDestination struct { StreamInStub func(string, io.Reader) error // contains filtered or unexported fields }
func (*FakeArtifactDestination) Invocations ¶
func (fake *FakeArtifactDestination) Invocations() map[string][][]interface{}
func (*FakeArtifactDestination) StreamIn ¶
func (fake *FakeArtifactDestination) StreamIn(arg1 string, arg2 io.Reader) error
func (*FakeArtifactDestination) StreamInArgsForCall ¶
func (fake *FakeArtifactDestination) StreamInArgsForCall(i int) (string, io.Reader)
func (*FakeArtifactDestination) StreamInCallCount ¶
func (fake *FakeArtifactDestination) StreamInCallCount() int
func (*FakeArtifactDestination) StreamInReturns ¶
func (fake *FakeArtifactDestination) StreamInReturns(result1 error)
type FakeArtifactSource ¶
type FakeArtifactSource struct { StreamToStub func(resource.ArtifactDestination) error VolumeOnStub func(worker.Worker) (worker.Volume, bool, error) // contains filtered or unexported fields }
func (*FakeArtifactSource) Invocations ¶
func (fake *FakeArtifactSource) Invocations() map[string][][]interface{}
func (*FakeArtifactSource) StreamTo ¶
func (fake *FakeArtifactSource) StreamTo(arg1 resource.ArtifactDestination) error
func (*FakeArtifactSource) StreamToArgsForCall ¶
func (fake *FakeArtifactSource) StreamToArgsForCall(i int) resource.ArtifactDestination
func (*FakeArtifactSource) StreamToCallCount ¶
func (fake *FakeArtifactSource) StreamToCallCount() int
func (*FakeArtifactSource) StreamToReturns ¶
func (fake *FakeArtifactSource) StreamToReturns(result1 error)
func (*FakeArtifactSource) VolumeOnArgsForCall ¶
func (fake *FakeArtifactSource) VolumeOnArgsForCall(i int) worker.Worker
func (*FakeArtifactSource) VolumeOnCallCount ¶
func (fake *FakeArtifactSource) VolumeOnCallCount() int
func (*FakeArtifactSource) VolumeOnReturns ¶
func (fake *FakeArtifactSource) VolumeOnReturns(result1 worker.Volume, result2 bool, result3 error)
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) Invocations ¶
func (*FakeCache) IsInitialized ¶
func (*FakeCache) IsInitializedCallCount ¶
func (*FakeCache) IsInitializedReturns ¶
func (*FakeCache) VolumeCallCount ¶
func (*FakeCache) VolumeReturns ¶
type FakeCacheIdentifier ¶
type FakeCacheIdentifier struct { FindOnStub func(lager.Logger, worker.Client) (worker.Volume, bool, error) CreateOnStub func(lager.Logger, worker.Client) (worker.Volume, error) VolumeIdentifierStub func() worker.VolumeIdentifier // contains filtered or unexported fields }
func (*FakeCacheIdentifier) CreateOnArgsForCall ¶
func (*FakeCacheIdentifier) CreateOnCallCount ¶
func (fake *FakeCacheIdentifier) CreateOnCallCount() int
func (*FakeCacheIdentifier) CreateOnReturns ¶
func (fake *FakeCacheIdentifier) CreateOnReturns(result1 worker.Volume, result2 error)
func (*FakeCacheIdentifier) FindOnArgsForCall ¶
func (*FakeCacheIdentifier) FindOnCallCount ¶
func (fake *FakeCacheIdentifier) FindOnCallCount() int
func (*FakeCacheIdentifier) FindOnReturns ¶
func (fake *FakeCacheIdentifier) FindOnReturns(result1 worker.Volume, result2 bool, result3 error)
func (*FakeCacheIdentifier) Invocations ¶
func (fake *FakeCacheIdentifier) Invocations() map[string][][]interface{}
func (*FakeCacheIdentifier) VolumeIdentifier ¶
func (fake *FakeCacheIdentifier) VolumeIdentifier() worker.VolumeIdentifier
func (*FakeCacheIdentifier) VolumeIdentifierCallCount ¶
func (fake *FakeCacheIdentifier) VolumeIdentifierCallCount() int
func (*FakeCacheIdentifier) VolumeIdentifierReturns ¶
func (fake *FakeCacheIdentifier) VolumeIdentifierReturns(result1 worker.VolumeIdentifier)
type FakeFetchContainerCreator ¶
type FakeFetchContainerCreator struct { CreateWithVolumeStub func(string, worker.Volume, worker.Worker) (worker.Container, error) // contains filtered or unexported fields }
func (*FakeFetchContainerCreator) CreateWithVolume ¶
func (*FakeFetchContainerCreator) CreateWithVolumeArgsForCall ¶
func (*FakeFetchContainerCreator) CreateWithVolumeCallCount ¶
func (fake *FakeFetchContainerCreator) CreateWithVolumeCallCount() int
func (*FakeFetchContainerCreator) CreateWithVolumeReturns ¶
func (fake *FakeFetchContainerCreator) CreateWithVolumeReturns(result1 worker.Container, result2 error)
func (*FakeFetchContainerCreator) Invocations ¶
func (fake *FakeFetchContainerCreator) Invocations() map[string][][]interface{}
type FakeFetchContainerCreatorFactory ¶
type FakeFetchContainerCreatorFactory struct { NewFetchContainerCreatorStub func(logger lager.Logger, resourceTypes atc.ResourceTypes, tags atc.Tags, teamID int, session resource.Session, metadata resource.Metadata, imageFetchingDelegate worker.ImageFetchingDelegate) resource.FetchContainerCreator // contains filtered or unexported fields }
func (*FakeFetchContainerCreatorFactory) Invocations ¶
func (fake *FakeFetchContainerCreatorFactory) Invocations() map[string][][]interface{}
func (*FakeFetchContainerCreatorFactory) NewFetchContainerCreator ¶
func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreator(logger lager.Logger, resourceTypes atc.ResourceTypes, tags atc.Tags, teamID int, session resource.Session, metadata resource.Metadata, imageFetchingDelegate worker.ImageFetchingDelegate) resource.FetchContainerCreator
func (*FakeFetchContainerCreatorFactory) NewFetchContainerCreatorArgsForCall ¶
func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorArgsForCall(i int) (lager.Logger, atc.ResourceTypes, atc.Tags, int, resource.Session, resource.Metadata, worker.ImageFetchingDelegate)
func (*FakeFetchContainerCreatorFactory) NewFetchContainerCreatorCallCount ¶
func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorCallCount() int
func (*FakeFetchContainerCreatorFactory) NewFetchContainerCreatorReturns ¶
func (fake *FakeFetchContainerCreatorFactory) NewFetchContainerCreatorReturns(result1 resource.FetchContainerCreator)
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 ReleaseStub func(*time.Duration) // 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) 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) 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) Release ¶
func (fake *FakeFetchSource) Release(arg1 *time.Duration)
func (*FakeFetchSource) ReleaseArgsForCall ¶
func (fake *FakeFetchSource) ReleaseArgsForCall(i int) *time.Duration
func (*FakeFetchSource) ReleaseCallCount ¶
func (fake *FakeFetchSource) ReleaseCallCount() int
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)
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) Invocations ¶
func (fake *FakeFetchSourceProvider) Invocations() map[string][][]interface{}
type FakeFetchSourceProviderFactory ¶
type FakeFetchSourceProviderFactory struct { NewFetchSourceProviderStub func(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, resourceTypes atc.ResourceTypes, cacheIdentifier resource.CacheIdentifier, resourceOptions resource.ResourceOptions, containerCreator resource.FetchContainerCreator) 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, tags atc.Tags, teamID int, resourceTypes atc.ResourceTypes, cacheIdentifier resource.CacheIdentifier, resourceOptions resource.ResourceOptions, containerCreator resource.FetchContainerCreator) resource.FetchSourceProvider
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderArgsForCall(i int) (lager.Logger, resource.Session, atc.Tags, int, atc.ResourceTypes, resource.CacheIdentifier, resource.ResourceOptions, resource.FetchContainerCreator)
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderCallCount() int
func (*FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns ¶
func (fake *FakeFetchSourceProviderFactory) NewFetchSourceProviderReturns(result1 resource.FetchSourceProvider)
type FakeFetcher ¶
type FakeFetcher struct { FetchStub func(logger lager.Logger, session resource.Session, tags atc.Tags, teamID int, resourceTypes atc.ResourceTypes, cacheIdentifier resource.CacheIdentifier, 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.ResourceTypes, cacheIdentifier resource.CacheIdentifier, 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.ResourceTypes, resource.CacheIdentifier, 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) 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) Invocations ¶
func (fake *FakeFetcherFactory) Invocations() map[string][][]interface{}
type FakeLockDB ¶
type FakeLockDB struct { GetTaskLockStub func(logger lager.Logger, lockName string) (db.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 db.Lock, result2 bool, result3 error)
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, resource.ArtifactSource, <-chan os.Signal, chan<- struct{}) (resource.VersionedSource, error) CheckStub func(atc.Source, atc.Version) ([]atc.Version, error) ReleaseStub func(*time.Duration) // 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) GetArgsForCall ¶
func (*FakeResource) GetCallCount ¶
func (fake *FakeResource) GetCallCount() int
func (*FakeResource) GetReturns ¶
func (fake *FakeResource) GetReturns(result1 resource.VersionedSource, result2 error)
func (*FakeResource) Invocations ¶
func (fake *FakeResource) Invocations() map[string][][]interface{}
func (*FakeResource) Put ¶
func (fake *FakeResource) Put(arg1 resource.IOConfig, arg2 atc.Source, arg3 atc.Params, arg4 resource.ArtifactSource, arg5 <-chan os.Signal, arg6 chan<- struct{}) (resource.VersionedSource, error)
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) Release ¶
func (fake *FakeResource) Release(arg1 *time.Duration)
func (*FakeResource) ReleaseArgsForCall ¶
func (fake *FakeResource) ReleaseArgsForCall(i int) *time.Duration
func (*FakeResource) ReleaseCallCount ¶
func (fake *FakeResource) ReleaseCallCount() int
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) 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) 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) 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) 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) 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)
type FakeTracker ¶
type FakeTracker struct { InitStub func(lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, atc.Tags, int, atc.ResourceTypes, worker.ImageFetchingDelegate) (resource.Resource, error) InitWithSourcesStub func(lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, atc.Tags, int, map[string]resource.ArtifactSource, atc.ResourceTypes, worker.ImageFetchingDelegate) (resource.Resource, []string, error) // contains filtered or unexported fields }
func (*FakeTracker) Init ¶
func (fake *FakeTracker) Init(arg1 lager.Logger, arg2 resource.Metadata, arg3 resource.Session, arg4 resource.ResourceType, arg5 atc.Tags, arg6 int, arg7 atc.ResourceTypes, arg8 worker.ImageFetchingDelegate) (resource.Resource, error)
func (*FakeTracker) InitArgsForCall ¶
func (fake *FakeTracker) InitArgsForCall(i int) (lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, atc.Tags, int, atc.ResourceTypes, worker.ImageFetchingDelegate)
func (*FakeTracker) InitCallCount ¶
func (fake *FakeTracker) InitCallCount() int
func (*FakeTracker) InitReturns ¶
func (fake *FakeTracker) InitReturns(result1 resource.Resource, result2 error)
func (*FakeTracker) InitWithSources ¶
func (fake *FakeTracker) InitWithSources(arg1 lager.Logger, arg2 resource.Metadata, arg3 resource.Session, arg4 resource.ResourceType, arg5 atc.Tags, arg6 int, arg7 map[string]resource.ArtifactSource, arg8 atc.ResourceTypes, arg9 worker.ImageFetchingDelegate) (resource.Resource, []string, error)
func (*FakeTracker) InitWithSourcesArgsForCall ¶
func (fake *FakeTracker) InitWithSourcesArgsForCall(i int) (lager.Logger, resource.Metadata, resource.Session, resource.ResourceType, atc.Tags, int, map[string]resource.ArtifactSource, atc.ResourceTypes, worker.ImageFetchingDelegate)
func (*FakeTracker) InitWithSourcesCallCount ¶
func (fake *FakeTracker) InitWithSourcesCallCount() int
func (*FakeTracker) InitWithSourcesReturns ¶
func (fake *FakeTracker) InitWithSourcesReturns(result1 resource.Resource, result2 []string, result3 error)
func (*FakeTracker) Invocations ¶
func (fake *FakeTracker) Invocations() map[string][][]interface{}
type FakeTrackerFactory ¶
type FakeTrackerFactory struct { TrackerForStub func(client worker.Client) resource.Tracker // contains filtered or unexported fields }
func (*FakeTrackerFactory) Invocations ¶
func (fake *FakeTrackerFactory) Invocations() map[string][][]interface{}
func (*FakeTrackerFactory) TrackerFor ¶
func (fake *FakeTrackerFactory) TrackerFor(client worker.Client) resource.Tracker
func (*FakeTrackerFactory) TrackerForArgsForCall ¶
func (fake *FakeTrackerFactory) TrackerForArgsForCall(i int) worker.Client
func (*FakeTrackerFactory) TrackerForCallCount ¶
func (fake *FakeTrackerFactory) TrackerForCallCount() int
func (*FakeTrackerFactory) TrackerForReturns ¶
func (fake *FakeTrackerFactory) TrackerForReturns(result1 resource.Tracker)
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) 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) 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) 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) 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)
Source Files ¶
- fake_artifact_destination.go
- fake_artifact_source.go
- fake_cache.go
- fake_cache_identifier.go
- fake_fetch_container_creator.go
- fake_fetch_container_creator_factory.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_options.go
- fake_tracker.go
- fake_tracker_factory.go
- fake_versioned_source.go
Click to show internal directories.
Click to hide internal directories.