machine

Uses Monad and Filter types for transformations and branching, enabling clear, maintainable pipeline logic as described in the philosophy of composable design.

Supports cycles (While), recursion (Recurse, Memoize), and conditional splits (If, Or, And), allowing for retry mechanisms and complex data flows as highlighted in the features.

Integrates OpenTelemetry via a slog wrapper, providing metrics and traces out-of-the-box for monitoring data processing, as shown in the telemetry integration section.

Offers options like FIFO order, buffer sizing, and graceful flushing via Option helpers, giving fine-grained control over processing behavior.

Includes Distribute method with Edge interface for pub/sub or parallel processing patterns, enabling scalable data distribution as mentioned in the fan-out feature.