elixir-lang/gen_stage

Health v2 · maintenance only

Flags: no_releases no_license

Adoption not part of the score

1590 stars · 199 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

GenStage is an Elixir specification and behaviour for exchanging events between producer and consumer stages with built-in back-pressure. It also provides ConsumerSupervisor for starting a child process per event, and underpins the Flow and Broadway data-processing libraries.

Use cases

• build back-pressured event pipelines in Elixir
• consume events from queues like SQS or RabbitMQ concurrently
• implement rate limiting in a processing pipeline
• replace GenEvent with a concurrent, buffered event manager
• run multi-stage producer-consumer data processing

When to choose

• you need demand-driven event flow with back-pressure in Elixir
• you're building pipelines on top of Flow or Broadway
• you want per-event supervised consumption

When to avoid

• you're not working in Elixir/Erlang
• you need a full data-ingestion framework rather than a low-level behaviour (consider Broadway)
• you need map-reduce/windowed computation (consider Flow)

Facets

library · maturity stable

concurrency message-queue streaming rate-limiting workflow-automation microservices backend elixir jvm windows back-pressure producer-consumer event-pipeline genstage consumer-supervisor data-engineering real-time linux macos

Member repositories

For agents

markdown · JSON · MCP: product_card(name="elixir-lang/gen_stage")