pm

type Channel interface {
	io.ReadWriteCloser
}

type Command struct {
	ID              string           `json:"id"`
	Command         string           `json:"command"`
	Arguments       *json.RawMessage `json:"arguments"`
	Queue           string           `json:"queue"`
	StatsInterval   int              `json:"stats_interval,omitempty"`
	MaxTime         int              `json:"max_time,omitempty"`
	MaxRestart      int              `json:"max_restart,omitempty"`
	RecurringPeriod int              `json:"recurring_period,omitempty"`
	Stream          bool             `json:"stream"`
	LogLevels       []int            `json:"log_levels,omitempty"`
	Tags            Tags             `json:"tags"`

	Flags JobFlags `json:"-"`
}

type ContainerCommandArguments struct {
	Name        string            `json:"name"`
	Dir         string            `json:"dir"`
	Args        []string          `json:"args"`
	Env         map[string]string `json:"env"`
	HostNetwork bool              `json:"host_network"`
	Chroot      string            `json:"chroot"`
	Log         string            `json:"log"`
}

type ContainerProcess interface {
	Process
	Channel() Channel
}

type Context struct {
	Command *Command
	// contains filtered or unexported fields
}

type DelayHook struct {
	NOOPHook

	Delay  time.Duration
	Action func()
	// contains filtered or unexported fields
}

type ExitHook struct {
	NOOPHook

	Action func(bool)
	// contains filtered or unexported fields
}

type GetPID func() (int, error)

type Handler interface{}

type Job interface {
	Command() *Command
	Signal(sig syscall.Signal) error
	Process() Process
	Wait() *JobResult
	StartTime() int64
	Subscribe(stream.MessageHandler)
	// contains filtered or unexported methods
}

type JobFlags struct {
	Protected bool
	NoOutput  bool
	NoSetPGID bool //set new process group id for job
}

type JobResult struct {
	ID        string   `json:"id"`
	Command   string   `json:"command"`
	Data      string   `json:"data"`
	Streams   Streams  `json:"streams,omitempty"`
	Critical  string   `json:"critical,omitempty"`
	Level     uint16   `json:"level"`
	State     JobState `json:"state"`
	Code      uint32   `json:"code"`
	StartTime int64    `json:"starttime"`
	Time      int64    `json:"time"`
	Tags      Tags     `json:"tags"`
	Container uint64   `json:"container"`
}

type JobState string

type M map[string]interface{}

type MatchHook struct {
	NOOPHook
	Match  string
	Action func(msg *stream.Message)
	// contains filtered or unexported fields
}

type MessageHandler interface {
	Message(*Command, *stream.Message)
}

type NOOPHook struct {
}

type PIDHook struct {
	NOOPHook

	Action func(pid int)
	// contains filtered or unexported fields
}

type PIDTable interface {
	//PIDTable atomic registration of PID. MUST grantee that that no wait4 will happen
	//on any of the child process until the register operation is done.
	RegisterPID(g GetPID) error
	WaitPID(pid int) syscall.WaitStatus
}

type PreHandler interface {
	Pre(cmd *Command)
}

type Process interface {
	Command() *Command
	Run() (<-chan *stream.Message, error)
}

type ProcessFactory func(PIDTable, *Command) Process

type ProcessStats struct {
	CPU   float64 `json:"cpu"`
	RSS   uint64  `json:"rss"`
	VMS   uint64  `json:"vms"`
	Swap  uint64  `json:"swap"`
	Debug string  `json:"debug,ommitempty"`
}

type Queue struct {
	// contains filtered or unexported fields
}

type ResultHandler interface {
	Result(cmd *Command, result *JobResult)
}

type RunError interface {
	Code() uint32
	Cause() interface{}
}

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

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

type RunnerHook interface {
	Tick(delay time.Duration)
	Message(msg *stream.Message)
	Exit(state JobState)
	PID(pid int)
}

type Signaler interface {
	Process
	Signal(sig syscall.Signal) error
}

type Stater interface {
	Process
	Stats() *ProcessStats
}

type StatsHandler interface {
	Stats(operation string, key string, value float64, id string, tags ...Tag)
}

type StreamHook struct {
	NOOPHook
	Stdout bytes.Buffer
	Stderr bytes.Buffer
}

type Streams []string

type SystemCommandArguments struct {
	Name  string            `json:"name"`
	Dir   string            `json:"dir"`
	Args  []string          `json:"args"`
	Env   map[string]string `json:"env"`
	StdIn string            `json:"stdin"`
}

type Tag struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type Tags []string