radar

package
v0.0.0-...-0e89551 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 23, 2015 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL