Genstage

broadwayElixir

Build concurrent, multi-stage data ingestion and processing pipelines with Elixir, supporting back-pressure, batching, and fault tolerance.

flowElixir

A computational parallel flow library for Elixir built on top of GenStage for parallel processing of collections.

ecto_jobElixir

Transactional job queue library for Elixir using Ecto, PostgreSQL/MySQL, and GenStage for reliable background processing.

opqElixir

A simple, in-memory FIFO queue for Elixir with worker pooling and rate limiting.

alfElixir

A flow-based application layer framework for Elixir that implements Flow-Based Programming (FBP) to structure business logic.