lostandfound

Documentation

Index

• func NewRunner(logger lager.Logger, baggageCollector BaggageCollector, db RunnerDB, ...) ifrit.Runner
• type BaggageCollector
  • func NewBaggageCollector(logger lager.Logger, workerClient worker.Client, db BaggageCollectorDB, ...) BaggageCollector
• type BaggageCollectorDB
• type RunnerDB

Functions

func NewRunner

func NewRunner(
	logger lager.Logger,
	baggageCollector BaggageCollector,
	db RunnerDB,
	clock clock.Clock,
	interval time.Duration,
) ifrit.Runner

Types

type BaggageCollector

type BaggageCollector interface {
	Collect() error
}

func NewBaggageCollector

func NewBaggageCollector(
	logger lager.Logger,
	workerClient worker.Client,
	db BaggageCollectorDB,
	pipelineDBFactory db.PipelineDBFactory,
	oldResourceGracePeriod time.Duration,
	oneOffBuildImageResourceGracePeriod time.Duration,
) BaggageCollector

type BaggageCollectorDB

type BaggageCollectorDB interface {
	ReapVolume(string) error
	GetAllPipelines() ([]db.SavedPipeline, error)
	GetVolumes() ([]db.SavedVolume, error)
	SetVolumeTTL(string, time.Duration) error
	GetImageVolumeIdentifiersByBuildID(buildID int) ([]db.VolumeIdentifier, error)
	GetVolumesForOneOffBuildImageResources() ([]db.SavedVolume, error)
}

type RunnerDB

type RunnerDB interface {
	LeaseCacheInvalidation(interval time.Duration) (db.Lease, bool, error)
}