task

Documentation

Index

• Constants
• func NewCmdCfg() *cmd.Cfg
• type BaseStep
  • func (b *BaseStep) GetCfg() interface{}
  • func (b *BaseStep) GetTask() *Task
  • func (b *BaseStep) SetTask(t *Task)
  • func (b *BaseStep) Store(k string, v any)
  • func (b *BaseStep) Type() interface{}
• type Cfg
  • func NewCfg() *Cfg
  • func (c *Cfg) Add(typ StepType, cfg interface{}) *Cfg
  • func (c *Cfg) Defer(typ StepType, cfg interface{}) *Cfg
  • func (c *Cfg) SetID(id string) *Cfg
  • func (c *Cfg) SetType(t Type) *Cfg
• type Cmd
  • func NewCmdStep() *Cmd
  • func (c *Cmd) GetCfg() interface{}
  • func (c *Cmd) Init() error
  • func (c *Cmd) Start() error
  • func (c *Cmd) Stop() error
  • func (c *Cmd) Type() interface{}
• type Collector
• type Snapshot
• type Step
  • func NewBase(name string) Step
• type StepCfg
• type StepDoneHook
• type StepType
• type Task
  • func New() *Task
  • func (t *Task) CurDeferStep() Step
  • func (t *Task) CurStep() Step
  • func (t *Task) DeferSteps() []Step
  • func (t *Task) GetCfg() interface{}
  • func (t *Task) Init() error
  • func (t *Task) RegisterCollector(c Collector)
  • func (t *Task) RegisterDeferStepDoneHook(hook ...StepDoneHook)
  • func (t *Task) RegisterStepDoneHook(hook ...StepDoneHook)
  • func (t *Task) Result() interface{}
  • func (t *Task) Snapshot() *Snapshot
  • func (t *Task) Start() error
  • func (t *Task) Steps() []Step
  • func (t *Task) Stop() error
  • func (t *Task) Store(k string, v any)
  • func (t *Task) Type() interface{}
• type Type

Constants

const PluginTypeTask plugin.Type = "task"

Functions

func NewCmdCfg

func NewCmdCfg() *cmd.Cfg

Types

type BaseStep

type BaseStep struct {
	runner.Runner
	// contains filtered or unexported fields
}

func (*BaseStep) GetCfg

func (b *BaseStep) GetCfg() interface{}

func (*BaseStep) GetTask

func (b *BaseStep) GetTask() *Task

func (*BaseStep) SetTask

func (b *BaseStep) SetTask(t *Task)

func (*BaseStep) Store

func (b *BaseStep) Store(k string, v any)

func (*BaseStep) Type

func (b *BaseStep) Type() interface{}

type Cfg

type Cfg struct {
	ID              string     `json:"id"              validate:"required,min=1" yaml:"id"`
	Type            Type       `json:"type"            validate:"required"       yaml:"type"`
	Steps           []*StepCfg `json:"steps"           validate:"required,min=1" yaml:"steps"`
	DeferSteps      []*StepCfg `json:"deferSteps"      yaml:"deferSteps"`
	CurStepIdx      int        `json:"curStepIdx"      yaml:"curStepIdx"`
	CurDeferStepIdx int        `json:"curDeferStepIdx" yaml:"curDeferStepIdx"`
}

func NewCfg

func NewCfg() *Cfg

func (*Cfg) Add

func (c *Cfg) Add(typ StepType, cfg interface{}) *Cfg

func (*Cfg) Defer

func (c *Cfg) Defer(typ StepType, cfg interface{}) *Cfg

func (*Cfg) SetID

func (c *Cfg) SetID(id string) *Cfg

func (*Cfg) SetType

func (c *Cfg) SetType(t Type) *Cfg

type Cmd

type Cmd struct {
	Step
	*cmd.Cfg
}

func NewCmdStep

func NewCmdStep() *Cmd

func (*Cmd) GetCfg

func (c *Cmd) GetCfg() interface{}

func (*Cmd) Init

func (c *Cmd) Init() error

func (*Cmd) Start

func (c *Cmd) Start() error

func (*Cmd) Stop

func (c *Cmd) Stop() error

func (*Cmd) Type

func (c *Cmd) Type() interface{}

type Collector

type Collector func(*Task) interface{}

type Snapshot

type Snapshot struct {
	Cfg              *Cfg                `json:"cfg"              yaml:"cfg"`
	StepsResult      []map[string]string `json:"stepsResult"      yaml:"stepsResult"`
	DeferStepsResult []map[string]string `json:"deferStepsResult" yaml:"deferStepsResult"`
}

type Step

type Step interface {
	runner.Runner
	plugin.Plugin
	GetTask() *Task
	SetTask(*Task)
	CollectAsString() map[string]string
}

func NewBase

func NewBase(name string) Step

type StepCfg

type StepCfg struct {
	Type StepType    `json:"type" validate:"required" yaml:"type"`
	Cfg  interface{} `json:"cfg"  validate:"required" yaml:"cfg"`
}

type StepDoneHook

type StepDoneHook func(*Task, int, Step)

type StepType

type StepType string

const StepTypeCmd StepType = "cmd"

type Task

type Task struct {
	runner.Runner
	plugin.Plugin
	*Cfg
	// contains filtered or unexported fields
}

func New

func New() *Task

func (*Task) CurDeferStep

func (t *Task) CurDeferStep() Step

func (*Task) CurStep

func (t *Task) CurStep() Step

func (*Task) DeferSteps

func (t *Task) DeferSteps() []Step

func (*Task) GetCfg

func (t *Task) GetCfg() interface{}

func (*Task) Init

func (t *Task) Init() error

func (*Task) RegisterCollector

func (t *Task) RegisterCollector(c Collector)

func (*Task) RegisterDeferStepDoneHook

func (t *Task) RegisterDeferStepDoneHook(hook ...StepDoneHook)

func (*Task) RegisterStepDoneHook

func (t *Task) RegisterStepDoneHook(hook ...StepDoneHook)

func (*Task) Result

func (t *Task) Result() interface{}

func (*Task) Snapshot

func (t *Task) Snapshot() *Snapshot

func (*Task) Start

func (t *Task) Start() error

func (*Task) Steps

func (t *Task) Steps() []Step

func (*Task) Stop

func (t *Task) Stop() error

func (*Task) Store

func (t *Task) Store(k string, v any)

func (*Task) Type

func (t *Task) Type() interface{}

type Type

type Type string