taskmanager

type Command struct {
	Type         string                 `json:"type"`
	TaskName     string                 `json:"taskname,omitempty"`
	Params       map[string]interface{} `json:"params,omitempty"`
	Timeout      int64                  `json:"timeout"`
	ReplyChannel chan CommandReply
}

type CommandReply struct {
	Reply  string
	Params map[string]interface{}
	Error  error
}

type HTTPHandler struct {
	Host           string
	Port           int
	CommandChannel chan Command
	Logger         *log.Logger
}

type JobqueueKeepAliveHandler struct {
	Host   string
	Port   int
	Topic  string
	Logger *log.Logger
}

type KeepAlive struct {
	Pid      int
	TaskName string
}

type KeepAliveConf struct {
	InboundPort  int    `json:"inbound_port,omitempty"`
	InternalPort int    `json:"internal_port,omitempty"`
	Host         string `json:"host,omitempty"`
	StallTimeout int64  `json:"stall_timeout,omitempty"`
	GracePeriod  int64  `json:"grace_period,omitempty"`
}

type Runner struct {
	Conf TaskManagerConf
	// contains filtered or unexported fields
}

type SignalHandler struct {
	CommandChannel chan Command
	Logger         *log.Logger
	ForceTimeout   int64
}

type TaskManager struct {
	Name          string   `json:"name,omitempty"`           // task name
	Cmd           string   `json:"cmd,omitempty"`            // cli command
	Args          []string `json:"args,omitempty"`           // cli args
	Cardinality   int      `json:"cardinality,omitempty"`    // number of workers
	StallTimeout  int64    `json:"stall_timeout,omitempty"`  // consider the worker dead if no keep-alives are received for this period (ms)
	GracePeriod   int64    `json:"grace_period,omitempty"`   // grace period (ms) before killing a worker after being asked to stop
	AutoStart     bool     `json:"autostart,omitempty"`      // whether to start the task automatically
	CaptureOutput bool     `json:"capture_output,omitempty"` // whether to capture the output and send it to stdout
	Active        bool
	// contains filtered or unexported fields
}

type TaskManagerConf struct {
	Path         string                 `json:"path,omitempty"`
	FileSuffix   string                 `json:"filesuffix,omitempty"`
	Port         int                    `json:"port,omitempty"`
	Autotasks    map[string]TaskManager `json:"autotasks,omitempty"`
	Keepalives   KeepAliveConf          `json:"keepalives,omitempty"`
	ForceTimeout int64                  `json:"force_timeout"`
	Profiler     profiler.Config        `json:"profiler"`
}

type Worker struct {
	Taskname            string         `json:"taskname"`
	Command             string         `json:"command,omitempty"`
	Args                []string       `json:"args,omitempty"`
	CaptureOutput       bool           `json:"capture_output,omitempty"`
	StallTimeout        int64          `json:"stall_timeout,omitempty"`
	GracePeriod         int64          `json:"grace_period,omitempty"` // grace period (ms) before killing a worker after being asked to stop
	Pid                 int            `json:"pid,omitempty"`
	StartedAt           time.Time      `json:"started_at,omitempty"`
	LastAliveAt         time.Time      `json:"last_alive_at,omitempty"`
	Logger              *log.Logger    `json:"-"` // don't export
	TaskFeedbackChannel chan<- Command `json:"-"` // don't export
	CommandsChannel     chan Command   `json:"-"` // don't export
	// contains filtered or unexported fields
}

type WorkerInfo struct {
	Pid              int
	KeepAliveChannel chan KeepAlive
	CommandChannel   chan Command
}