Crate operon 

Operon

Workflow engine for parallel and incremental scheduling of DAG-defined multiplex tasks.

Modules

error

Error types from the Operon engine.

options

Options to build the pipeline.

Macros

define_operon

Define the pipeline in the Operon DSL.

Structs

DateTime

ISO 8601 combined date and time with time zone.

Entity

MemMetaStorage

The in-memory implementation of the metadata backend.

Operon

Operon

PsqlMetaStorage

The Postgres implementation of the metadata backend.

RunFootprint

The trace a run leaves behind, used to check that a restart picks up consistent data.

RunMetadata

The identity of a run and how far it got.

Utc

The UTC time zone. This is the most efficient time zone when you don’t need the local time. It is also used as an offset (which is also a dummy type).

Uuid

A Universally Unique Identifier (UUID).

Enums

AnyBackend

A metadata backend selected at runtime from MetaBackendOptions.

Direction

Ordering direction for a priority dimension.

RunState

How far a run got. Decides whether a restart resumes it or starts over.

Traits

OperonService

A type-carrier trait for validating the service type. This trait should not be implemented manually; the derive macro #[derive(OperonService)] is the only correct way to implement it. The derive takes #[operon(error = MyError)], #[operon(defined_at = "path")], and #[operon(crate = "path")].

OperonStorage

The pipeline-independent half of an entity storage backend.

Derive Macros

OperonService

Derives OperonService for a pipeline service type.