executor

Documentation

Overview

Package executor provides the pipeline execution engine.

Index

• type Engine
  • func New(runtimeType string) *Engine
  • func (e *Engine) Close() error
  • func (e *Engine) Run(ctx context.Context, t *types.Task) error
  • func (e *Engine) State() string
• type Limits

Types

type Engine

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

Engine manages the lifecycle of a task runtime, enforcing single-task execution and providing state introspection.

func New

func New(runtimeType string) *Engine

New creates a new Engine for the given runtime type without initializing the underlying runtime. The runtime is lazily initialized on the first Run.

func (*Engine) Close

func (e *Engine) Close() error

Close cleans up the engine's runtime resources and marks the engine as closed. It is safe to call Close multiple times; subsequent calls are no-ops.

func (*Engine) Run

func (e *Engine) Run(ctx context.Context, t *types.Task) error

Run executes the given task, enforcing that only one task runs at a time. It returns an error if the engine is already running or has been closed.

func (*Engine) State

func (e *Engine) State() string

State returns the current engine state as a human-readable string.

type Limits

type Limits struct {
	DefaultCPUsLimit   string
	DefaultMemoryLimit string
}

Limits defines default resource constraints applied to tasks that do not specify their own.