radar

Documentation

Index

• type Locker
• type Radar
  • func NewRadar(tracker resource.Tracker, interval time.Duration, locker Locker, db RadarDB) *Radar
  • func (radar *Radar) Scan(logger lager.Logger, resourceName string) error
  • func (radar *Radar) Scanner(logger lager.Logger, resourceName string) ifrit.Runner
• type RadarDB
• type Runner
  • func NewRunner(logger lager.Logger, noop bool, locker Locker, scannerFactory ScannerFactory, ...) *Runner
  • func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type ScannerFactory

Types

type Locker

type Locker interface {
	AcquireWriteLockImmediately(lock []db.NamedLock) (db.Lock, error)
	AcquireReadLock(lock []db.NamedLock) (db.Lock, error)
	AcquireWriteLock(lock []db.NamedLock) (db.Lock, error)
}

type Radar

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

func NewRadar

func NewRadar(
	tracker resource.Tracker,
	interval time.Duration,
	locker Locker,
	db RadarDB,
) *Radar

func (*Radar) Scan

func (radar *Radar) Scan(logger lager.Logger, resourceName string) error

func (*Radar) Scanner

func (radar *Radar) Scanner(logger lager.Logger, resourceName string) ifrit.Runner

type RadarDB

type RadarDB interface {
	GetPipelineName() string
	ScopedName(string) string

	IsPaused() (bool, error)

	GetConfig() (atc.Config, db.ConfigVersion, error)

	GetLatestVersionedResource(resource db.SavedResource) (db.SavedVersionedResource, error)
	GetResource(resourceName string) (db.SavedResource, error)
	PauseResource(resourceName string) error
	UnpauseResource(resourceName string) error

	SaveResourceVersions(atc.ResourceConfig, []atc.Version) error
	SetResourceCheckError(resource db.SavedResource, err error) error
}

type Runner

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

func NewRunner

func NewRunner(
	logger lager.Logger,
	noop bool,
	locker Locker,
	scannerFactory ScannerFactory,
	db db.PipelineDB,
	syncInterval time.Duration,
) *Runner

func (*Runner) Run

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

type ScannerFactory

type ScannerFactory interface {
	Scanner(lager.Logger, string) ifrit.Runner
}