reaper

Documentation

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)