execution

Documentation

Index

• type ExecutionContext
  • func NewExecutionContext(jobID string, pipeline *pipeline.Pipeline, tracker tracking.JobTracker) *ExecutionContext
  • func (e *ExecutionContext) Run() error
  • func (e *ExecutionContext) TaskHandler(handler func(*pipeline.Task, map[string]string) (*ExecutionResult, error)) *ExecutionContext
  • func (e *ExecutionContext) Variables(variables map[string]interface{}) *ExecutionContext
• type ExecutionResult

Types

type ExecutionContext

type ExecutionContext struct {
	JobID    string
	Pipeline *pipeline.Pipeline
	Tracker  tracking.JobTracker
	// contains filtered or unexported fields
}

ExecutionContext - context for a execution

func NewExecutionContext

func NewExecutionContext(jobID string, pipeline *pipeline.Pipeline, tracker tracking.JobTracker) *ExecutionContext

func (*ExecutionContext) Run

func (e *ExecutionContext) Run() error

Run - runs the execution

func (*ExecutionContext) TaskHandler

func (e *ExecutionContext) TaskHandler(handler func(*pipeline.Task, map[string]string) (*ExecutionResult, error)) *ExecutionContext

Handler - Sets the handler for this worker

func (*ExecutionContext) Variables

func (e *ExecutionContext) Variables(variables map[string]interface{}) *ExecutionContext

type ExecutionResult

type ExecutionResult struct {
	Success bool                   `json:"success" bson:"success"`
	Error   *string                `json:"error" bson:"error"`
	Output  map[string]interface{} `json:"output" bson:"output"`
}