sweeper

Documentation

Index

• func NewSweeperRunner(logger lager.Logger, atcWorker atc.Worker, config beacon.Config) ifrit.Runner
• type Command
  • func (cmd *Command) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Functions

func NewSweeperRunner

func NewSweeperRunner(logger lager.Logger,
	atcWorker atc.Worker,
	config beacon.Config,
) ifrit.Runner

NewSweeperRunner provides the ifrit runner that marks and sweeps the containers

Types

type Command

type Command struct {
	Logger       lager.Logger
	BeaconClient beacon.BeaconClient
	GCInterval   time.Duration
	GardenClient garden.Client
}

Command is the struct that holds the properties for the mark and sweep command

func (*Command) Run

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

Run invokes the process of marking and sweeping containers First worker will call atc to collect list of containers to be removed and then worker will report its state of current containers for atc to remove containers in DB. This cycle is triggered every GCInterval sec