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.

flumeElixir

A job processing system for Elixir applications built on GenStage and Redis, offering durability, back-pressure, and rate limiting.

gen_taskElixir

A generic Task behavior for Elixir that encapsulates errors and enables recovery in GenStage workers.

elasticsearch_elixir_bulk_processorElixir

A configurable GenStage-based bulk processor for efficiently inserting data into Elasticsearch from Elixir applications.

BSONMapElixir

An Elixir package for low-memory consumption iteration over large BSON files by applying a function to each document.

particleElixir

An Elixir client library for interacting with the Particle IoT platform's HTTP API.