Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pm

package

Go to main page

Versions in this module

v1

v1.1.0-alpha-3

Jun 8, 2017

v1.1.0-alpha-2

May 14, 2017

v1.0.0

Apr 5, 2017

Changes in this version

type Runner

+ StartTime func() int64

+ Terminate func()

v0

v0.11.0

Feb 3, 2017

Changes in this version

+ const AggreagteAverage

+ const AggreagteDifference

type PM

+ func (pm *PM) AddStatsHandler(handler StatsHandler)

+ func (pm *PM) Aggregate(op, key string, value float64, tags string)

+ type StatsHandler func(operation string, key string, value float64, tags string)

v0.10.0

Dec 20, 2016

v0.9.0

Dec 7, 2016

Changes in this version

+ const StreamBufferSize

+ var CmdMap = map[string]process.ProcessFactory

+ var DuplicateIDErr = errors.New("duplicate job id")

+ var UnknownCommandErr = errors.New("unkonw command")

+ func GetProcessFactory(cmd *core.Command) process.ProcessFactory

+ func RegisterCmd(cmd string, exe string, workdir string, cmdargs []string, ...)

+ func UnregisterCmd(cmd string)

+ type DelayHook struct

+ Action func()

+ Delay time.Duration

+ func (h *DelayHook) Tick(delay time.Duration)

+ type ExitHook struct

+ Action func(bool)

+ func (h *ExitHook) Exit(state string)

+ type MatchHook struct

+ Action func(msg *stream.Message)

+ Match string

+ func (h *MatchHook) Message(msg *stream.Message)

+ type MessageHandler func(*core.Command, *stream.Message)

+ type MeterHandler func(cmd *core.Command, p *psutil.Process)

+ type NOOPHook struct

+ func (h *NOOPHook) Exit(state string)

+ func (h *NOOPHook) Message(msg *stream.Message)

+ func (h *NOOPHook) PID(pid int)

+ func (h *NOOPHook) Tick(delay time.Duration)

+ type PIDHook struct

+ Action func(pid int)

+ func (h *PIDHook) PID(pid int)

+ type PM struct

+ func GetManager() *PM

+ func InitProcessManager(maxJobs int) *PM

+ func (pm *PM) AddMessageHandler(handler MessageHandler)

+ func (pm *PM) AddResultHandler(handler ResultHandler)

+ func (pm *PM) AddRouteResultHandler(route core.Route, handler ResultHandler)

+ func (pm *PM) AddStatsFlushHandler(handler StatsFlushHandler)

+ func (pm *PM) Kill(cmdID string)

+ func (pm *PM) Killall()

+ func (pm *PM) NewRunner(cmd *core.Command, factory process.ProcessFactory, hooks ...RunnerHook) (Runner, error)

+ func (pm *PM) PushCmd(cmd *core.Command)

+ func (pm *PM) PushCmdToQueue(cmd *core.Command)

+ func (pm *PM) Register(g process.GetPID) error

+ func (pm *PM) Run()

+ func (pm *PM) RunCmd(cmd *core.Command, hooks ...RunnerHook) (Runner, error)

+ func (pm *PM) RunSlice(slice settings.StartupSlice)

+ func (pm *PM) Runners() map[string]Runner

+ func (pm *PM) WaitPID(pid int) *syscall.WaitStatus

+ type ResultHandler func(cmd *core.Command, result *core.JobResult)

+ type Runner interface

+ Command func() *core.Command

+ Kill func()

+ Process func() process.Process

+ Run func()

+ Wait func() *core.JobResult

+ func NewRunner(manager *PM, command *core.Command, factory process.ProcessFactory, ...) Runner

+ type RunnerHook interface

+ Exit func(state string)

+ Message func(msg *stream.Message)

+ PID func(pid int)

+ Tick func(delay time.Duration)

+ type StateMachine interface

+ Release func(ket string, state bool) error

+ Wait func(key ...string) bool

+ WaitAll func()

+ func NewStateMachine(keys ...string) StateMachine

+ type StatsFlushHandler func(stats *stats.Stats)

+ type StatsdMeterHandler func(statsd *stats.Statsd, cmd *core.Command, p *psutil.Process)