GitHub topics: genstage
dashbitco/broadway
Concurrent and multi-stage data ingestion and data processing with Elixir
Language: Elixir - Size: 718 KB - Last synced at: 1 day ago - Pushed at: 29 days ago - Stars: 2,528 - Forks: 167
dashbitco/broadway_rabbitmq
A Broadway producer for RabbitMQ
Language: Elixir - Size: 209 KB - Last synced at: 7 days ago - Pushed at: 7 months ago - Stars: 194 - Forks: 45
dashbitco/broadway_kafka
A Broadway connector for Kafka
Language: Elixir - Size: 177 KB - Last synced at: 8 days ago - Pushed at: 2 months ago - Stars: 240 - Forks: 53
NFIBrokerage/volley
GenStage producers for EventStoreDB 20+ with Spear
Language: Elixir - Size: 91.8 KB - Last synced at: 10 days ago - Pushed at: 11 months ago - Stars: 15 - Forks: 2
fredwu/opq
Elixir queue! A simple, in-memory queue with worker pooling and rate limiting in Elixir.
Language: Elixir - Size: 92.8 KB - Last synced at: 6 days ago - Pushed at: over 1 year ago - Stars: 269 - Forks: 8
cloud8421/osteria
Osteria demo app for GenStage in the Kitchen talk. Rough code, beware!
Language: JavaScript - Size: 132 KB - Last synced at: 24 days ago - Pushed at: almost 8 years ago - Stars: 70 - Forks: 4
antonmi/flowex
Flow-Based Programming framework for Elixir
Language: Elixir - Size: 389 KB - Last synced at: 6 days ago - Pushed at: over 3 years ago - Stars: 422 - Forks: 15
NFIBrokerage/kelvin
GenStage/Broadway producers for Extreme
Language: Elixir - Size: 58.6 KB - Last synced at: 10 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0
nietaki/crawlie
A simple Elixir library for writing decently-performing crawlers with minimum effort.
Language: Elixir - Size: 196 KB - Last synced at: about 17 hours ago - Pushed at: over 3 years ago - Stars: 90 - Forks: 11
iacobson/umbrella_stage
Subscribes GenStage consumers to producers across Elixir Umbrella apps.
Language: Elixir - Size: 8.79 KB - Last synced at: 8 days ago - Pushed at: over 7 years ago - Stars: 6 - Forks: 1
sorentwo/kiq 📦
:postbox: Robust job queue powered by GenStage and Redis
Language: Elixir - Size: 355 KB - Last synced at: 5 days ago - Pushed at: 3 months ago - Stars: 74 - Forks: 6
dashbitco/broadway_sqs
A Broadway producer for Amazon SQS
Language: Elixir - Size: 163 KB - Last synced at: 6 days ago - Pushed at: 11 months ago - Stars: 93 - Forks: 32
aifrak/concurrent-data-processing-in-elixir
Code from the book "Concurrent Data Processing in Elixir".
Language: Elixir - Size: 3.06 MB - Last synced at: 3 months ago - Pushed at: about 3 years ago - Stars: 2 - Forks: 2
akash-akya/off_broadway_redis_stream
A Broadway producer for Redis Stream
Language: Elixir - Size: 122 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 20 - Forks: 7
aifrak/real-time-phoenix-hello-sockets
Code from the book "Real-Time Phoenix" part I
Language: Elixir - Size: 92.8 KB - Last synced at: 3 months ago - Pushed at: 8 months ago - Stars: 1 - Forks: 0
mtwilliams/bourne
:speedboat: Better streaming for Ecto.
Language: Elixir - Size: 19.5 KB - Last synced at: 5 days ago - Pushed at: over 5 years ago - Stars: 75 - Forks: 12
scripbox/flume
A blazing fast job processing system backed by GenStage & Redis.
Language: Elixir - Size: 376 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 78 - Forks: 7
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.
Language: Elixir - Size: 207 KB - Last synced at: about 17 hours ago - Pushed at: about 4 years ago - Stars: 14 - Forks: 1
longlene/stage
gen_stage for Erlang
Language: Erlang - Size: 102 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 8 - Forks: 2
mendrugory/galena
Galena is a topic producer-consumer library built on top of GenStage for Elixir.
Language: Elixir - Size: 26.4 KB - Last synced at: 11 days ago - Pushed at: almost 8 years ago - Stars: 6 - Forks: 0
TattdCodeMonkey/genstage_sqs_example
Example GenStage producer for AWS Simple Queue Service
Language: Elixir - Size: 8.79 KB - Last synced at: about 2 months ago - Pushed at: over 7 years ago - Stars: 18 - Forks: 2
rcoproc/world_temp_elixir
Language: Elixir - Size: 4.12 MB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0
Voronchuk/kraken
REST API wrapper to communicate with Kraken exchange.
Language: Elixir - Size: 15.6 KB - Last synced at: about 2 months ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 6
127labs/shigoto
GenStage based worker queue with multiple backing store adapters
Size: 1.95 KB - Last synced at: almost 2 years ago - Pushed at: about 8 years ago - Stars: 1 - Forks: 0
kloeckner-i/genstage_importer
Example of data import pipeline using Flow library
Language: Elixir - Size: 122 KB - Last synced at: about 2 months ago - Pushed at: almost 7 years ago - Stars: 5 - Forks: 2
anmarchenko/genstage_importer Fork of kloeckner-i/genstage_importer
Example of data import pipeline using Flow library
Size: 122 KB - Last synced at: almost 2 years ago - Pushed at: almost 7 years ago - Stars: 3 - Forks: 0
otobus/event_bus_postgres 📦
🐘 Postgres event store for event_bus
Language: Elixir - Size: 117 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 47 - Forks: 11
aifrak/real-time-phoenix-sneaker-23
Code from the book "Real-Time Phoenix" since part II
Language: Elixir - Size: 752 KB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0
ybod/elixir_flow
Some experiments with Elixir Flow module
Language: Elixir - Size: 37.1 MB - Last synced at: 9 days ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 1
mcrumm/off_broadway_imps
In-memory producers for Broadway and Elixir
Language: Elixir - Size: 16.6 KB - Last synced at: 3 months ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 0
lukyanov/broadway_ecto_job
A Broadway producer for EctoJob
Language: Elixir - Size: 19.5 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0
cloud8421/oredev-flow-demo
Elixir Flow demo application for Oredev 2017 conference
Language: Elixir - Size: 24.4 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 1 - Forks: 0
hudsonbay/fake_scraper
Fake service that scrapes a number of URLs, and uses a GenStage data pipeline to take care of the workload
Language: Elixir - Size: 9.77 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
HugoLnx/acai-restaurant
A simple application using GenStage with pretty tracing for studying purposes.
Language: Elixir - Size: 124 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 6 - Forks: 1
amokan/broadway_redis
A Broadway producer for Redis lists
Language: Elixir - Size: 16.6 KB - Last synced at: 1 day ago - Pushed at: over 5 years ago - Stars: 5 - Forks: 0
iacobson/blog_stockr
Demo app for GenStage under Umbrella blog article
Language: Elixir - Size: 22.5 KB - Last synced at: 8 days ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0
thekeele/bitfeels
How are we feeling today Bitcoin?
Language: Elixir - Size: 51 MB - Last synced at: about 1 year ago - Pushed at: almost 5 years ago - Stars: 4 - Forks: 0
nirev/gen_stage_example
Elixir's GenStage example
Language: Elixir - Size: 8.79 KB - Last synced at: 4 days ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 0
sescobb27/genstage-scraper
Language: Elixir - Size: 211 KB - Last synced at: 2 months ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0
YuriiZdyrko/elixir_concurrency_cheatsheet
Shorter version of Elixir docs, less redundant and logically ordered.
Language: Elixir - Size: 1.72 MB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 1
ryanyogan/world_temp
Playing with Broadway, it's fun :)
Language: Elixir - Size: 8.79 KB - Last synced at: 6 days ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
marcdel/world_temp
Uses Broadway to fetch temp data and find the coldest city in the world
Language: Elixir - Size: 8.79 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0
sneako/queue_consumer
Small and simple Elixir lib to process messages from a queue via GenStage ConsumerSupervisor
Language: Elixir - Size: 23.4 KB - Last synced at: 3 months ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 1
yo-artyom/elixir_vk_parser
Language: Elixir - Size: 35.2 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0
cloud8421/oredev-genstage-demo
Elixir GenStage demo application for Oredev 2017 conference
Language: Elixir - Size: 41 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0