worker

Documentation

Index

• type Result
  • func (r *Result) AfterResult() models.ScriptResult
  • func (r *Result) BeforeResult() models.ScriptResult
  • func (r *Result) Error() error
  • func (r *Result) ScriptResult() models.ScriptResult
  • func (r *Result) String() string
• type ScriptResult
  • func NewScriptResult(result models.ScriptResult) *ScriptResult
  • func (sr *ScriptResult) EndTime() time.Time
  • func (sr *ScriptResult) ExitCode() int
  • func (sr *ScriptResult) Host() string
  • func (sr *ScriptResult) Output() []byte
  • func (sr *ScriptResult) StartTime() time.Time
  • func (sr *ScriptResult) String() string
• type Worker
  • func (w *Worker) Serve(ctx context.Context) error

Types

type Result

type Result struct {
	ErrorMsg string
	Before   *ScriptResult
	Main     *ScriptResult
	After    *ScriptResult
}

func (*Result) AfterResult

func (r *Result) AfterResult() models.ScriptResult

func (*Result) BeforeResult

func (r *Result) BeforeResult() models.ScriptResult

func (*Result) Error

func (r *Result) Error() error

func (*Result) ScriptResult

func (r *Result) ScriptResult() models.ScriptResult

func (*Result) String

func (r *Result) String() string

type ScriptResult

type ScriptResult struct {
	Start    time.Time
	End      time.Time
	Hostname string
	Out      []byte
	Exit     int
}

func NewScriptResult

func NewScriptResult(result models.ScriptResult) *ScriptResult

func (*ScriptResult) EndTime

func (sr *ScriptResult) EndTime() time.Time

func (*ScriptResult) ExitCode

func (sr *ScriptResult) ExitCode() int

func (*ScriptResult) Host

func (sr *ScriptResult) Host() string

func (*ScriptResult) Output

func (sr *ScriptResult) Output() []byte

func (*ScriptResult) StartTime

func (sr *ScriptResult) StartTime() time.Time

func (*ScriptResult) String

func (sr *ScriptResult) String() string

type Worker

type Worker struct {
	Queue models.TaskQueue
}

func (*Worker) Serve

func (w *Worker) Serve(ctx context.Context) error