exec

type Cmd struct {
	// run at dir
	Dir string
	// target executable name
	Name string
	// arguments of cmd
	Args []string
	// exec started
	Started bool
	// exec canceled
	Canceled bool
	// exec timedout
	TimedOut bool
	// exec failed by error
	Failed bool
	// exec done
	Done bool
	// exec timeout
	Timeout time.Duration
	// exec duration
	Duration time.Duration
	// EventHandler pointer
	EventHandler *EventHandler
	// native exec.Cmd target
	Cmd *exec.Cmd
	// contains filtered or unexported fields
}

type CmdEvent func(cmd *Cmd)

type Cron struct {
	Stopped bool
	// contains filtered or unexported fields
}

type EventHandler struct {
	// trigger when cmd successfully started
	CmdStarted CmdEvent
	// trigger when cmd get any output ( error will trigger CmdFailed )
	CmdRead CmdEvent
	// trigger when cmd be canceled
	CmdCanceled CmdEvent
	// trigger when cmd failed which means process throw error
	CmdFailed CmdEvent
	// trigger when cmd done without any error
	CmdDone CmdEvent

	// trigger when pipeline successfully started
	PipelineStarted PipelineEvent
	// trigger when pipeline be canceled
	PipelineCanceled PipelineEvent
	// trigger when pipeline failed
	PipelineFailed PipelineEvent
	// trigger when pipeline done without any error
	PipelineDone PipelineEvent
}

type HandleFunc func(output string, err error) (success bool, msg string)

type Job struct {
	ID      uint32
	Stopped bool
	// contains filtered or unexported fields
}

type PipeCmd struct {
	Cmd        *Cmd
	HandleFunc HandleFunc
	HandleMsg  string
	DelayDur   time.Duration
	// contains filtered or unexported fields
}

type Pipeline struct {
	// pipeline started
	Started bool
	// pipeline done
	Done bool
	// pipeline failed
	Failed bool
	// pipeline canceld
	Canceled bool
	// pipline Timedout
	Timedout bool
	// Cmd pointer slice
	PipeCmds []*PipeCmd
	// current index of PipeCmd
	CurrentIndex int
	// EventHandler
	EventHandler *EventHandler
	// TimeoutDur duration
	TimeoutDur time.Duration
	// FailureMsg custom error message when failed at handler
	FailureMsg string
	// contains filtered or unexported fields
}

type PipelineEvent func(pipe *Pipeline)