Versions in this module Expand all Collapse all v0 v0.1.4 Jun 16, 2014 Changes in this version + const DEFAULT_PREFIX + const PROCESS_READY + const PROCESS_STARTING + const PROCESS_STOPPING + const VERSION + var DefaultConfig = &ProcessConfig + var EMPTY_BYTES = []byte + var EmptyProcessSet = make(processSet) + func DefaultConf(conf, prefix, name string) string + func DefaultCtl(ctl, prefix, name string) string + func NewRPCServer(m *Manager) *rpc.Server + func Prefix(prefix string) string + type API struct + func (self *API) Info(query *InfoQuery, reply *InfoReply) error + func (self *API) Kill(query *KillQuery, reply *KillReply) (err error) + func (self *API) Ps(query *PsQuery, reply *PsReply) error + func (self *API) Run(query *StartQuery, reply *StartReply) error + type Action interface + type ByteCount int64 + func (b ByteCount) String() string + type Event interface + type Info struct + Build string + NumGoroutine int + Version string + func GetInfo(build string) *Info + func (info *Info) String() string + type InfoAction struct + type InfoQuery struct + type InfoReply struct + Info *Info + type KillAction struct + type KillQuery struct + Signal string + Wait bool + type KillReply struct + type Manager struct + func NewManager(build string, configPath string, socket *os.File) *Manager + func (self *Manager) Reload() + func (self *Manager) Run() + func (self *Manager) SendAction(action Action) + func (self *Manager) Shutdown() + type PrefixReader struct + func NewLinePrefixer(r io.Reader, prefix func() string) *PrefixReader + func (io *PrefixReader) Read(buf []byte) (n int, err error) + type Process struct + func (p *Process) Pid() int + func (p *Process) Shutdown() error + func (p *Process) String() string + type ProcessConfig struct + Command []string + Cwd string + StartTimeout time.Duration + StopTimeout time.Duration + func (self *ProcessConfig) String() string + type ProcessExitEvent struct + type ProcessInfo struct + Cid int + Command []string + Cwd string + Pid int + State string + func (pi *ProcessInfo) String() string + type ProcessQuery struct + Pid int + Ready bool + Starting bool + Stopping bool + type ProcessReadyEvent struct + type ProcessState int + func (ps ProcessState) String() string + type PsAction struct + type PsQuery struct + type PsReply struct + PS []*ProcessInfo + type ShutdownAction bool + type StartAction struct + type StartQuery struct + Command []string + Cwd string + Pid int + StartTimeout int + StopTimeout int + Wait bool + type StartReply struct + Code int + type TimeoutTracker struct + func NewTimeoutTracker() *TimeoutTracker + func (self *TimeoutTracker) Add(p *Process, timeout time.Duration) + func (self *TimeoutTracker) Remove(p *Process) + func (self *TimeoutTracker) Run() + func (self *TimeoutTracker) Stop()