Module engine

Engine Module

This module implements the core workflow engine for dataflow-rs. The engine processes messages through workflows composed of tasks, providing a flexible and extensible data processing pipeline.

Key Components

• Engine: The main engine that processes messages through workflows
• Workflow: A collection of tasks with conditions that determine when they should be applied
• Task: An individual processing unit that performs a specific function on a message
• AsyncFunctionHandler: A trait implemented by task handlers to define custom async processing logic
• Message: The data structure that flows through the engine, with data, metadata, and processing results

Re-exports

pub use error::DataflowError;

pub use error::ErrorInfo;

pub use error::Result;

pub use functions::AsyncFunctionHandler;

pub use message::Message;

pub use task::Task;

pub use workflow::Workflow;

pub use datalogic_rs as jsonlogic;

Modules

error

functions

message

task

workflow

Structs

Engine

Engine that processes messages through workflows using non-blocking async IO.

RetryConfig

Configuration for retry behavior