reaper

Documentation

Index

• type Reaper
  • func New(repos core.RepositoryStore, builds core.BuildStore, stages core.StageStore, ...) *Reaper
  • func (r *Reaper) Start(ctx context.Context, dur time.Duration) error

Types

type Reaper

type Reaper struct {
	Repos    core.RepositoryStore
	Builds   core.BuildStore
	Stages   core.StageStore
	Canceler core.Canceler
	Pending  time.Duration // Pending is the pending pipeline deadline
	Running  time.Duration // Running is the running pipeline deadline
}

Reaper finds and kills zombie jobs that are permanently stuck in a pending or running state.

func New

func New(
	repos core.RepositoryStore,
	builds core.BuildStore,
	stages core.StageStore,
	canceler core.Canceler,
	running time.Duration,
	pending time.Duration,
) *Reaper

New returns a new Reaper.

func (*Reaper) Start

func (r *Reaper) Start(ctx context.Context, dur time.Duration) error

Start starts the reaper.