radar

Documentation

Index

• Variables
• type IntervalRunner
  • func NewIntervalRunner(logger lager.Logger, clock clock.Clock, name string, scanner Scanner) *IntervalRunner
  • func (r *IntervalRunner) RunFunc(signals <-chan os.Signal, ready chan<- struct{}) error
• type RadarDB
• type Runner
  • func NewRunner(logger lager.Logger, noop bool, scanRunnerFactory ScanRunnerFactory, ...) *Runner
  • func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type ScanRunnerFactory
  • func NewScanRunnerFactory(resourceFactory resource.ResourceFactory, defaultInterval time.Duration, ...) ScanRunnerFactory
• type Scanner
  • func NewResourceScanner(clock clock.Clock, resourceFactory resource.ResourceFactory, ...) Scanner
  • func NewResourceTypeScanner(resourceFactory resource.ResourceFactory, defaultInterval time.Duration, ...) Scanner
• type ScannerFactory
  • func NewScannerFactory(resourceFactory resource.ResourceFactory, defaultInterval time.Duration, ...) ScannerFactory

Variables

var ErrFailedToAcquireLock = errors.New("failed-to-acquire-lock")

Types

type IntervalRunner

type IntervalRunner struct {
	// contains filtered or unexported fields
}

func NewIntervalRunner

func NewIntervalRunner(
	logger lager.Logger,
	clock clock.Clock,
	name string,
	scanner Scanner,
) *IntervalRunner

func (*IntervalRunner) RunFunc

func (r *IntervalRunner) RunFunc(signals <-chan os.Signal, ready chan<- struct{}) error

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
	AcquireResourceTypeCheckingLock(logger lager.Logger, resourceType db.SavedResourceType, interval time.Duration, immediate bool) (lock.Lock, bool, error)
}

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(
	logger lager.Logger,
	noop bool,
	scanRunnerFactory ScanRunnerFactory,
	db db.PipelineDB,
	syncInterval time.Duration,
) *Runner

func (*Runner) Run

func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type ScanRunnerFactory

type ScanRunnerFactory interface {
	ScanResourceRunner(lager.Logger, string) ifrit.Runner
	ScanResourceTypeRunner(lager.Logger, string) ifrit.Runner
}

func NewScanRunnerFactory

func NewScanRunnerFactory(
	resourceFactory resource.ResourceFactory,
	defaultInterval time.Duration,
	db RadarDB,
	dbPipeline dbng.Pipeline,
	clock clock.Clock,
	externalURL string,
) 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

func NewResourceScanner(
	clock clock.Clock,
	resourceFactory resource.ResourceFactory,
	defaultInterval time.Duration,
	db RadarDB,
	dbPipeline dbng.Pipeline,
	externalURL string,
) Scanner

func NewResourceTypeScanner

func NewResourceTypeScanner(
	resourceFactory resource.ResourceFactory,
	defaultInterval time.Duration,
	db RadarDB,
	externalURL string,
) Scanner

type ScannerFactory

type ScannerFactory interface {
	NewResourceScanner(db RadarDB, dbPipeline dbng.Pipeline) Scanner
}

func NewScannerFactory

func NewScannerFactory(
	resourceFactory resource.ResourceFactory,
	defaultInterval time.Duration,
	externalURL string,
) ScannerFactory