package reaper

import "github.com/containerd/containerd/reaper"

Index ¶

• Variables
• func Reap() error
• type Cmd
• type Monitor
• func (m *Monitor) CombinedOutput(c *exec.Cmd) ([]byte, error)
• func (m *Monitor) Command(pid int) *Cmd
• func (m *Monitor) Delete(pid int)
• func (m *Monitor) Output(c *exec.Cmd) ([]byte, error)
• func (m *Monitor) Register(pid int, c *Cmd)
• func (m *Monitor) RegisterNL(pid int, c *Cmd)
• func (m *Monitor) Run(c *exec.Cmd) error
• func (m *Monitor) Start(c *exec.Cmd) error
• func (m *Monitor) Wait(c *exec.Cmd) (int, error)
• func (m *Monitor) WaitPid(pid int) (int, error)

Variables ¶

var Default = &Monitor{
	cmds:    make(map[int]*Cmd),
	unknown: make(map[int]int),
}

Functions ¶

func Reap ¶

func Reap() error

Reap should be called when the process receives an SIGCHLD. Reap will reap all exited processes and close their wait channels

Types ¶

type Cmd ¶

type Cmd struct {
	ExitCh chan int
	// contains filtered or unexported fields
}

type Monitor ¶

type Monitor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Monitor) CombinedOutput ¶

func (m *Monitor) CombinedOutput(c *exec.Cmd) ([]byte, error)

func (*Monitor) Command ¶

func (m *Monitor) Command(pid int) *Cmd

Command returns the registered pid for the command created

func (*Monitor) Delete ¶

func (m *Monitor) Delete(pid int)

func (*Monitor) Output ¶

func (m *Monitor) Output(c *exec.Cmd) ([]byte, error)

func (*Monitor) Register ¶

func (m *Monitor) Register(pid int, c *Cmd)

func (*Monitor) RegisterNL ¶

func (m *Monitor) RegisterNL(pid int, c *Cmd)

RegisterNL does not grab the lock internally the caller is responsible for locking the monitor

func (*Monitor) Run ¶

func (m *Monitor) Run(c *exec.Cmd) error

Run runs and waits for the command to finish

func (*Monitor) Start ¶

func (m *Monitor) Start(c *exec.Cmd) error

Start starts the command a registers the process with the reaper

func (*Monitor) Wait ¶

func (m *Monitor) Wait(c *exec.Cmd) (int, error)

func (*Monitor) WaitPid ¶

func (m *Monitor) WaitPid(pid int) (int, error)

Source Files ¶

reaper.go