supervisor

type Reaped ¶

type Reaped struct {
	PID    int
	Status syscall.WaitStatus
	Rusage syscall.Rusage
}

Reaped is one zombie collection event.

type Reaper ¶

type Reaper struct {
	// contains filtered or unexported fields
}

Reaper consumes SIGCHLD and Wait4()'s every child the kernel hands us. Exits the goroutine cleanly when ctx is cancelled.

Reaped child PIDs and their status are published on the returned channel so the per-container Supervisor can correlate exits to containers it cares about. The channel is closed when the reaper exits.

func NewReaper(log *slog.Logger) *Reaper

func (r *Reaper) Events() <-chan Reaped

func (r *Reaper) Run(ctx context.Context)

type Supervisor ¶

type Supervisor struct {
	// contains filtered or unexported fields
}

Supervisor drives the lifecycle of one Pod's containers via an OCI runtime. It does NOT prepare the bundles (rootfs unpacking and config.json generation live in the bundler package); it receives ready-to-run bundle directories and a runtime client.

func New(log *slog.Logger, rt runtime.Runtime, reaper *Reaper, spec *pod.Spec, bundles map[string]string) *Supervisor

func (s *Supervisor) Run(ctx context.Context) error

func (s *Supervisor) Stop(ctx context.Context, grace time.Duration)