pm

package

Go to main page

Versions in this module

v1

v1.4.1

Jun 28, 2018

v1.4.0

Jun 25, 2018

v1.3.0

Jun 4, 2018

v1.2.2

May 4, 2018

Changes in this version

type ProcessFactory

+ func NewInternalProcess(runnable Runnable) ProcessFactory

+ func NewInternalProcessWithCtx(runnable RunnableWithCtx) ProcessFactory

+ type TestingPIDTable struct

+ func (t *TestingPIDTable) RegisterPID(g GetPID) (int, error)

+ func (t *TestingPIDTable) WaitPID(pid int) syscall.WaitStatus

v1.2.1

Apr 11, 2018

v1.2.0

Apr 11, 2018

Changes in this version

+ const CommandSystem

+ const GenericStreamBufferSize

+ const StandardStreamBufferSize

+ var MaxJobs int

+ func AddHandle(handler Handler)

+ func Aggregate(op, key string, value float64, id string, tags ...Tag)

+ func BadRequestError(cause interface{}) error

+ func Error(code uint32, cause interface{}) error

+ func InternalError(cause interface{}) error

+ func Jobs() map[string]Job

+ func Kill(cmdID string) error

+ func Killall()

+ func MustArguments(args interface{}) *json.RawMessage

+ func New()

+ func NotAcceptableError(cause interface{}) error

+ func NotFoundError(cause interface{}) error

+ func PreconditionFailedError(cause interface{}) error

+ func Register(name string, factory ProcessFactory)

+ func RegisterBuiltIn(name string, runnable Runnable)

+ func RegisterBuiltInWithCtx(name string, runnable RunnableWithCtx)

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

+ func RunSlice(slice settings.StartupSlice)

+ func ServiceUnavailableError(cause interface{}) error

+ func SetUnprivileged()

+ func Start()

+ type Channel interface

+ type Command struct

+ Arguments *json.RawMessage

+ Command string

+ Flags JobFlags

+ ID string

+ LogLevels []int

+ MaxRestart int

+ MaxTime int

+ Queue string

+ RecurringPeriod int

+ StatsInterval int

+ Stream bool

+ Tags Tags

+ func LoadCmd(str []byte) (*Command, error)

+ func (cmd *Command) String() string

+ type ContainerCommandArguments struct

+ Args []string

+ Chroot string

+ Dir string

+ Env map[string]string

+ HostNetwork bool

+ Log string

+ Name string

+ func (c *ContainerCommandArguments) String() string

+ type ContainerProcess interface

+ Channel func() Channel

+ type Context struct

+ Command *Command

+ func (c *Context) Log(text string, level ...uint16)

+ func (c *Context) Message(msg *stream.Message)

+ type GetPID func() (int, error)

+ type Handler interface

+ type Job interface

+ Command func() *Command

+ Process func() Process

+ Signal func(sig syscall.Signal) error

+ StartTime func() int64

+ Subscribe func(stream.MessageHandler)

+ Wait func() *JobResult

+ func JobOf(id string) (Job, bool)

+ func Run(cmd *Command, hooks ...RunnerHook) (Job, error)

+ func RunFactory(cmd *Command, factory ProcessFactory, hooks ...RunnerHook) (Job, error)

+ type JobFlags struct

+ NoOutput bool

+ NoSetPGID bool

+ Protected bool

+ type JobResult struct

+ Code uint32

+ Command string

+ Container uint64

+ Critical string

+ Data string

+ ID string

+ Level uint16

+ StartTime int64

+ State JobState

+ Streams Streams

+ Tags Tags

+ Time int64

+ func NewJobResult(cmd *Command) *JobResult

+ func System(bin string, args ...string) (*JobResult, error)

+ type JobState string

+ const StateDuplicateID

+ const StateError

+ const StateKilled

+ const StateSuccess

+ const StateTimeout

+ const StateUnknownCmd

+ type M map[string]interface

type MessageHandler

+ Message func(*Command, *stream.Message)

+ type PIDTable interface

+ RegisterPID func(g GetPID) error

+ WaitPID func(pid int) syscall.WaitStatus

+ type PreHandler interface

+ Pre func(cmd *Command)

+ type Process interface

+ Command func() *Command

+ Run func() (<-chan *stream.Message, error)

+ func NewContainerProcess(table PIDTable, cmd *Command) Process

+ func NewSystemProcess(table PIDTable, cmd *Command) Process

+ type ProcessFactory func(PIDTable, *Command) Process

+ type ProcessStats struct

+ CPU float64

+ Debug string

+ RSS uint64

+ Swap uint64

+ VMS uint64

+ type Queue struct

+ func (q *Queue) Channel() <-chan Job

+ func (q *Queue) Init()

+ func (q *Queue) Notify(job Job)

+ func (q *Queue) Push(job Job)

type ResultHandler

+ Result func(cmd *Command, result *JobResult)

+ type RunError interface

+ Cause func() interface{}

+ Code func() uint32

+ type Runnable func(*Command) (interface{}, error)

+ type RunnableWithCtx func(*Context) (interface{}, error)

+ type Signaler interface

+ Signal func(sig syscall.Signal) error

+ type Stater interface

+ Stats func() *ProcessStats

type StatsHandler

+ Stats func(operation string, key string, value float64, id string, tags ...Tag)

+ type StreamHook struct

+ Stderr bytes.Buffer

+ Stdout bytes.Buffer

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

+ type Streams []string

+ func (s Streams) Stderr() string

+ func (s Streams) Stdout() string

+ type SystemCommandArguments struct

+ Args []string

+ Dir string

+ Env map[string]string

+ Name string

+ StdIn string

+ func (s *SystemCommandArguments) String() string

+ type Tag struct

+ Key string

+ Value string

+ type Tags []string

v1.1.0-alpha-7

Aug 17, 2017

v1.1.0-alpha-5

Jul 17, 2017

v1.1.0-alpha-4

Jun 21, 2017

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL