actuator

Documentation

Index

• func RunPipeline(ctx context.Context, pipeline *models.Pipeline, resChan chan *models.Result)
• func RunStep(ctx context.Context, pivot *models.PipelineTaskPivot) *models.TaskRecords
• type Contract
• type Hook
  • func (actuator *Hook) Exec(ctx context.Context) *models.TaskRecords
• type Http
  • func (actuator *Http) Exec(ctx context.Context) *models.TaskRecords
• type Mail
  • func (actuator *Mail) Exec(ctx context.Context) *models.TaskRecords
• type Shell
  • func (actuator *Shell) Exec(ctx context.Context) *models.TaskRecords

Functions

func RunPipeline

func RunPipeline(ctx context.Context, pipeline *models.Pipeline, resChan chan *models.Result)

执行流水线

func RunStep

func RunStep(ctx context.Context, pivot *models.PipelineTaskPivot) *models.TaskRecords

运行任务

Types

type Contract

type Contract interface {
	Exec(ctx context.Context) *models.TaskRecords
}

type Hook

type Hook struct {
	Url     string
	Method  string
	Content string
}

func (*Hook) Exec

func (actuator *Hook) Exec(ctx context.Context) *models.TaskRecords

type Http

type Http struct {
	Url     string
	Method  string
	Content string
}

func (*Http) Exec

func (actuator *Http) Exec(ctx context.Context) *models.TaskRecords

type Mail

type Mail struct {
	Mail *notify.Mail
}

func (*Mail) Exec

func (actuator *Mail) Exec(ctx context.Context) *models.TaskRecords

type Shell

type Shell struct {
	User    string
	Env     []string
	Dir     string
	Command string
}

func (*Shell) Exec

func (actuator *Shell) Exec(ctx context.Context) *models.TaskRecords

Exec Execute shell tasks