stepMapper

Documentation

Index

• func MakeEmptyStep() workflow.StepDefinition
• func ParseWorkflowSteps(parsedWorkflow configParser.ParsedWorkflow) (*workflow.Workflow, error)
• type EmptyStep
  • func (es *EmptyStep) Clean()
  • func (es *EmptyStep) GetDependencies() []string
  • func (es *EmptyStep) GetDescription() string
  • func (es *EmptyStep) GetLabel() string
  • func (es *EmptyStep) GetName() string
  • func (es *EmptyStep) GetOutput() map[string]string
  • func (es *EmptyStep) Init(_ ctx.WorkflowContext, _ map[string]map[string]string) error
  • func (es *EmptyStep) Run(_ ctx.WorkflowContext) error
• type StepDocker
  • func MapDockerStep(template interface{}) (*StepDocker, error)
  • func (ds *StepDocker) Clean()
  • func (ds *StepDocker) GetDependencies() []string
  • func (ds *StepDocker) GetDescription() string
  • func (ds *StepDocker) GetLabel() string
  • func (ds *StepDocker) GetName() string
  • func (ds *StepDocker) GetOutput() map[string]string
  • func (ds *StepDocker) Init(ctx ctx.WorkflowContext, previousStepsOutput map[string]map[string]string) error
  • func (ds *StepDocker) Run(ctx ctx.WorkflowContext) error
• type StepDockerPersistFormat
• type StepWorkflow
  • func MapWorkflowStep(template interface{}) (*StepWorkflow, error)
  • func (ws *StepWorkflow) Clean()
  • func (ws *StepWorkflow) GetDependencies() []string
  • func (ws *StepWorkflow) GetDescription() string
  • func (ws *StepWorkflow) GetLabel() string
  • func (ws *StepWorkflow) GetName() string
  • func (ws *StepWorkflow) GetOutput() map[string]string
  • func (ws *StepWorkflow) Init(ctx ctx.WorkflowContext, previousStepsOutput map[string]map[string]string) error
  • func (ws *StepWorkflow) Run(_ ctx.WorkflowContext) error

Functions

func MakeEmptyStep

func MakeEmptyStep() workflow.StepDefinition

func ParseWorkflowSteps

func ParseWorkflowSteps(parsedWorkflow configParser.ParsedWorkflow) (*workflow.Workflow, error)

Types

type EmptyStep

type EmptyStep struct {
}

func (*EmptyStep) Clean

func (es *EmptyStep) Clean()

func (*EmptyStep) GetDependencies

func (es *EmptyStep) GetDependencies() []string

func (*EmptyStep) GetDescription

func (es *EmptyStep) GetDescription() string

func (*EmptyStep) GetLabel

func (es *EmptyStep) GetLabel() string

func (*EmptyStep) GetName

func (es *EmptyStep) GetName() string

func (*EmptyStep) GetOutput

func (es *EmptyStep) GetOutput() map[string]string

func (*EmptyStep) Init

func (es *EmptyStep) Init(_ ctx.WorkflowContext, _ map[string]map[string]string) error

func (*EmptyStep) Run

func (es *EmptyStep) Run(_ ctx.WorkflowContext) error

type StepDocker

type StepDocker struct {
	Id        string                    `json:"id,omitempty"`
	Name      string                    `json:"name"`
	Image     string                    `json:"image"`
	Workdir   string                    `json:"workdir,omitempty"`
	Commands  string                    `json:"commands"`
	DependsOn []string                  `json:"depends_on,omitempty"`
	Persist   []StepDockerPersistFormat `json:"persist,omitempty"`
	Executor  string                    `json:"executor,omitempty"`
	// contains filtered or unexported fields
}

func MapDockerStep

func MapDockerStep(template interface{}) (*StepDocker, error)

func (*StepDocker) Clean

func (ds *StepDocker) Clean()

func (*StepDocker) GetDependencies

func (ds *StepDocker) GetDependencies() []string

func (*StepDocker) GetDescription

func (ds *StepDocker) GetDescription() string

func (*StepDocker) GetLabel

func (ds *StepDocker) GetLabel() string

func (*StepDocker) GetName

func (ds *StepDocker) GetName() string

func (*StepDocker) GetOutput

func (ds *StepDocker) GetOutput() map[string]string

func (*StepDocker) Init

func (ds *StepDocker) Init(ctx ctx.WorkflowContext, previousStepsOutput map[string]map[string]string) error

func (*StepDocker) Run

func (ds *StepDocker) Run(ctx ctx.WorkflowContext) error

type StepDockerPersistFormat

type StepDockerPersistFormat struct {
	Name   string
	Source string
}

type StepWorkflow

type StepWorkflow struct {
	Id         string            `json:"id,omitempty"`
	Name       string            `json:"name"`
	Workflow   string            `json:"workflow"`
	Parameters map[string]string `json:"parameters,omitempty"`
	DependsOn  []string          `json:"depends_on,omitempty"`
	// contains filtered or unexported fields
}

func MapWorkflowStep

func MapWorkflowStep(template interface{}) (*StepWorkflow, error)

func (*StepWorkflow) Clean

func (ws *StepWorkflow) Clean()

func (*StepWorkflow) GetDependencies

func (ws *StepWorkflow) GetDependencies() []string

func (*StepWorkflow) GetDescription

func (ws *StepWorkflow) GetDescription() string

func (*StepWorkflow) GetLabel

func (ws *StepWorkflow) GetLabel() string

func (*StepWorkflow) GetName

func (ws *StepWorkflow) GetName() string

func (*StepWorkflow) GetOutput

func (ws *StepWorkflow) GetOutput() map[string]string

func (*StepWorkflow) Init

func (ws *StepWorkflow) Init(ctx ctx.WorkflowContext, previousStepsOutput map[string]map[string]string) error

func (*StepWorkflow) Run

func (ws *StepWorkflow) Run(_ ctx.WorkflowContext) error