engine

Documentation

Index

• func AutorunCollector(ctx context.Context) error
• func GarbageCollector(ctx context.Context, completedTaskExpiration string) error
• func Init(ctx context.Context, store *configstore.Store) error
• func InstanceCollector(ctx context.Context) error
• func RetryCollector(ctx context.Context) error
• type Engine
  • func GetEngine() Engine
  • func (e Engine) Resolve(publicID string) error
  • func (e Engine) SyncResolve(publicID string) (*resolution.Resolution, error)

Functions

func AutorunCollector

func AutorunCollector(ctx context.Context) error

AutorunCollector launches a process that looks for existing resolutions with state TO_AUTORUN, and passes them to the engine for execution

func GarbageCollector

func GarbageCollector(ctx context.Context, completedTaskExpiration string) error

GarbageCollector launches a process that cleans up finished tasks (ie are in a final state) older than a given threshold

func Init

func Init(ctx context.Context, store *configstore.Store) error

Init launches the task orchestration engine, providing it with a global context and with a store from which to inherit configuration items needed for task execution

func InstanceCollector

func InstanceCollector(ctx context.Context) error

InstanceCollector launches a process that retrieves resolutions which might have been running on a dead instance and marks them as crashed, for examination

func RetryCollector

func RetryCollector(ctx context.Context) error

RetryCollector launches a process that collects all resolutions elligible for a new run and passes them to the engine for execution

Types

type Engine

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

Engine is the heart of utask: it is the active process that handles the lifecycle of every task resolution. All the logic for resolution state changes is expressed here - the engine determines which steps in a resolution are elligible for execution, and which should be pruned - the engine computes step dependencies - the conditions expressed in a step (skip/check) that impact resolution state are enforced by the engine

func GetEngine

func GetEngine() Engine

GetEngine returns the singleton instance of Engine

func (Engine) Resolve

func (e Engine) Resolve(publicID string) error

Resolve launches the asynchronous execution of a resolution, given its ID

func (Engine) SyncResolve

func (e Engine) SyncResolve(publicID string) (*resolution.Resolution, error)

SyncResolve launches the synchronous execution of a resolution, given its ID