radar

Documentation

Index

• type Radar
  • func NewRadar(tracker resource.Tracker, defaultInterval time.Duration, 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 ResourceNotConfiguredError
  • func (err ResourceNotConfiguredError) Error() string
• type Runner
  • func NewRunner(logger lager.Logger, noop bool, scannerFactory ScannerFactory, ...) *Runner
  • func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type ScannerFactory

Types

type Radar

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

func NewRadar

func NewRadar(
	tracker resource.Tracker,
	defaultInterval time.Duration,
	db RadarDB,
	clock clock.Clock,
	externalURL string,
) *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, bool, error)

	GetLatestVersionedResource(resource db.SavedResource) (db.SavedVersionedResource, bool, 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
	LeaseResourceChecking(resource string, interval time.Duration, immediate bool) (db.Lease, bool, error)
}

type ResourceNotConfiguredError

type ResourceNotConfiguredError struct {
	ResourceName string
}

func (ResourceNotConfiguredError) Error

func (err ResourceNotConfiguredError) Error() string

type Runner

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

func NewRunner

func NewRunner(
	logger lager.Logger,
	noop bool,
	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
}