executor

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 14, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PipelineExecutor

type PipelineExecutor struct {

	// Spec contains the specification of the pipeline.
	Spec *v1alpha1.PipelineSpecWithName
	// contains filtered or unexported fields
}

PipelineExecutor is the type for executing pipelines.

func NewPipelineExecutor

func NewPipelineExecutor(name, id string, spec *v1alpha1.PipelineSpecWithName) *PipelineExecutor

NewPipelineExecutor returns a new instance of PipelineExecutor for the provided specification.

func (*PipelineExecutor) GetStatus

GetStatus returns the status of the pipeline run.

func (*PipelineExecutor) Run

Run starts running the pipeline. Make sure that Pipeline status contains dummy information about all the tasks and step in the pipeline it should have a blueprint of the pipeline spec.

func (*PipelineExecutor) WithoutStore

func (p *PipelineExecutor) WithoutStore() *PipelineExecutor

WithoutStore sets the boolean useStore to false which will make the executor not perform any KVStore interactions

type RuntimeExecutor

type RuntimeExecutor interface {
	// Configure sets up the environment for the RuntimeExecutor
	// to execute the tasks.
	Configure() error

	// RunTask runs the task provided in the specification
	RunTask(string, *v1alpha1.TaskSpec) error

	// Shutdown shuts down the RuntimeExecutor instance and environment.
	Shutdown() error

	// Diables store usage in the executor.
	WithoutStore()

	// Executor with pipeline status
	WithStatus(*v1alpha1.PipelineRunStatus)

	// Saves the status in the store.
	SaveStatusToStore() error
}

RuntimeExecutor is the interface implemented by each of the runtime executor provided for xene.

Directories

Path Synopsis
cre
runtime
Package runtime is a derived form of the container runtime api provided by kubernetes removing all the parts related to the Pod sandboxes.
Package runtime is a derived form of the container runtime api provided by kubernetes removing all the parts related to the Pod sandboxes.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL