genstage

antonmi/flowex

Flow-Based Programming framework for Elixir

fredwu/opq

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

dashbitco/broadway_kafka

A Broadway connector for Kafka

dashbitco/broadway_rabbitmq

A Broadway producer for RabbitMQ

dashbitco/broadway_sqs

A Broadway producer for Amazon SQS

nietaki/crawlie

A simple Elixir library for writing decently-performing crawlers with minimum effort.

mtwilliams/bourne

:speedboat: Better streaming for Ecto.

scripbox/flume

A blazing fast job processing system backed by GenStage & Redis.

cloud8421/osteria

Osteria demo app for GenStage in the Kitchen talk. Rough code, beware!

sorentwo/kiq

:postbox: Robust job queue powered by GenStage and Redis

otobus/event_bus_postgres

🐘 Postgres event store for event_bus

akash-akya/off_broadway_redis_stream

A Broadway producer for Redis Stream

TattdCodeMonkey/genstage_sqs_example

Example GenStage producer for AWS Simple Queue Service

sashman/elasticsearch_elixir_bulk_processor

Elasticsearch Elixir Bulk Processor is a configurable manager for efficiently inserting data into Elasticsearch. This processor uses GenStages (data-exchange steps) for handling backpressure, and various settings to control the bulk payloads being uploaded to Elasticsearch.

NFIBrokerage/volley

GenStage producers for EventStoreDB 20+ with Spear

longlene/stage

gen_stage for Erlang

iacobson/umbrella_stage

Subscribes GenStage consumers to producers across Elixir Umbrella apps.

HugoLnx/acai-restaurant

A simple application using GenStage with pretty tracing for studying purposes.

mendrugory/galena

Galena is a topic producer-consumer library built on top of GenStage for Elixir.

ybod/elixir_flow

Some experiments with Elixir Flow module

amokan/broadway_redis

A Broadway producer for Redis lists

kloeckner-i/genstage_importer

Example of data import pipeline using Flow library

thekeele/bitfeels

How are we feeling today Bitcoin?

anmarchenko/genstage_importer

Example of data import pipeline using Flow library

Voronchuk/kraken

REST API wrapper to communicate with Kraken exchange.

hudsonbay/fake_scraper

Fake service that scrapes a number of URLs, and uses a GenStage data pipeline to take care of the workload

yo-artyom/elixir_vk_parser

127labs/shigoto

GenStage based worker queue with multiple backing store adapters

cloud8421/oredev-flow-demo

Elixir Flow demo application for Oredev 2017 conference

mcrumm/off_broadway_imps

In-memory producers for Broadway and Elixir

nirev/gen_stage_example

Elixir's GenStage example

sescobb27/genstage-scraper

aifrak/concurrent-data-processing-in-elixir

Code from the book "Concurrent Data Processing in Elixir".

aifrak/real-time-phoenix-hello-sockets

Code from the book "Real-Time Phoenix" part I

aifrak/real-time-phoenix-sneaker-23

Code from the book "Real-Time Phoenix" since part II