Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrFailedToAcquireLease = errors.New("failed-to-acquire-lock")
Functions ¶
This section is empty.
Types ¶
type IntervalRunner ¶
type IntervalRunner struct {
// contains filtered or unexported fields
}
func NewIntervalRunner ¶
type RadarDB ¶
type RadarDB interface { GetPipelineName() string GetPipelineID() int ScopedName(string) string TeamID() int Config() atc.Config IsPaused() (bool, error) Reload() (bool, error) GetLatestVersionedResource(resourceName string) (db.SavedVersionedResource, bool, error) GetResource(resourceName string) (db.SavedResource, bool, error) GetResourceType(resourceTypeName string) (db.SavedResourceType, bool, error) PauseResource(resourceName string) error UnpauseResource(resourceName string) error SaveResourceVersions(atc.ResourceConfig, []atc.Version) error SaveResourceTypeVersion(atc.ResourceType, atc.Version) error SetResourceCheckError(resource db.SavedResource, err error) error AcquireResourceCheckingLock(logger lager.Logger, resource db.SavedResource, interval time.Duration, immediate bool) (db.Lock, bool, error) AcquireResourceTypeCheckingLock(logger lager.Logger, resourceType db.SavedResourceType, interval time.Duration, immediate bool) (db.Lock, bool, error) }
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
type ScanRunnerFactory ¶
type Scanner ¶
type Scanner interface { Run(lager.Logger, string) (time.Duration, error) Scan(lager.Logger, string) error ScanFromVersion(lager.Logger, string, atc.Version) error }
func NewResourceScanner ¶
type ScannerFactory ¶
func NewScannerFactory ¶
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
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 |
Click to show internal directories.
Click to hide internal directories.