core

Documentation

Index

• type Pipeline
  • func (p Pipeline) Execute(goContext context.Context, serviceName string, ...)
  • func (p Pipeline) Size() int
• type PipelineBuilder
  • func NewPipelineBuilder() *PipelineBuilder
  • func (pb *PipelineBuilder) Build() Pipeline
  • func (pb *PipelineBuilder) Register(step Step) *PipelineBuilder
• type Step
• type StepExecResult
• type StepResult

Types

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func (Pipeline) Execute

func (p Pipeline) Execute(
	goContext context.Context,
	serviceName string,
	workspaceDescription workspace.Description,
	outChan chan StepExecResult)

Each step can be returned as completed several times, because of possible pipeline rerun Step with seq_no = -1 means some error inside pipeline, not step

func (Pipeline) Size

func (p Pipeline) Size() int

type PipelineBuilder

type PipelineBuilder struct {
	// contains filtered or unexported fields
}

func NewPipelineBuilder

func NewPipelineBuilder() *PipelineBuilder

func (*PipelineBuilder) Build

func (pb *PipelineBuilder) Build() Pipeline

func (*PipelineBuilder) Register

func (pb *PipelineBuilder) Register(step Step) *PipelineBuilder

type Step

type Step interface {
	Name() string
	Execute(*gencontext.GenContext) (StepResult, error)
}

type StepExecResult

type StepExecResult struct {
	SeqNo int
	Step  *Step
	Error error
}

type StepResult

type StepResult int

const (
	Done      StepResult = 0
	RepeatAll StepResult = 1
)