reaper

type Reaper ¶

type Reaper struct {
	Reclaim   time.Duration
	Runners   core.RunnerStore
	Runnerz   core.RunnerService
	Scheduler core.Scheduler
}

The reaper monitors and terminates zombie runners that remain stuck in a pending state for an excessive duration. This prevents resource leaks and ensures the system can recover from failed runner initialization attempts.

func New(
	runners core.RunnerStore,
	runnerz core.RunnerService,
	scheduler core.Scheduler,
	reclaim time.Duration) *Reaper

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