sorentwo/kiq

:postbox: Robust job queue powered by GenStage and Redis

Language: Elixir - Size: 378 KB - Last synced: 5 days ago - Pushed: 5 days ago - Stars: 70 - Forks: 7

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: 9 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 1

dashbitco/broadway

Concurrent and multi-stage data ingestion and data processing with Elixir

Language: Elixir - Size: 744 KB - Last synced: 9 days ago - Pushed: 2 months ago - Stars: 2,310 - Forks: 151

dashbitco/broadway_rabbitmq

A Broadway producer for RabbitMQ

Language: Elixir - Size: 197 KB - Last synced: 9 days ago - Pushed: 7 months ago - Stars: 191 - Forks: 41

scripbox/flume

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

Language: Elixir - Size: 376 KB - Last synced: 10 days ago - Pushed: 11 days ago - Stars: 74 - Forks: 7

dashbitco/broadway_kafka

A Broadway connector for Kafka

Language: Elixir - Size: 172 KB - Last synced: 9 days ago - Pushed: 17 days ago - Stars: 222 - Forks: 50

mcrumm/off_broadway_imps

In-memory producers for Broadway and Elixir

Language: Elixir - Size: 16.6 KB - Last synced: 16 days ago - Pushed: over 4 years ago - Stars: 1 - Forks: 0

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: 16 days ago - Pushed: about 3 years ago - Stars: 14 - Forks: 1

akash-akya/off_broadway_redis_stream

A Broadway producer for Redis Stream

Language: Elixir - Size: 124 KB - Last synced: 15 days ago - Pushed: 5 months ago - Stars: 20 - Forks: 5

iacobson/umbrella_stage

Subscribes GenStage consumers to producers across Elixir Umbrella apps.

Language: Elixir - Size: 8.79 KB - Last synced: 30 days ago - Pushed: over 6 years ago - Stars: 7 - Forks: 1

longlene/stage

gen_stage for Erlang

Language: Erlang - Size: 102 KB - Last synced: 23 days ago - Pushed: 2 months 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: 16 days ago - Pushed: almost 7 years ago - Stars: 6 - Forks: 0

antonmi/flowex

Flow-Based Programming framework for Elixir

Language: Elixir - Size: 389 KB - Last synced: 8 days ago - Pushed: over 2 years ago - Stars: 418 - Forks: 15

kloeckner-i/genstage_importer

Example of data import pipeline using Flow library

Language: Elixir - Size: 122 KB - Last synced: about 2 months ago - Pushed: almost 6 years ago - Stars: 5 - 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: 16 days ago - Pushed: 8 months ago - Stars: 255 - Forks: 8

dashbitco/broadway_sqs

A Broadway producer for Amazon SQS

Language: Elixir - Size: 154 KB - Last synced: 9 days ago - Pushed: 3 months ago - Stars: 91 - Forks: 31

TattdCodeMonkey/genstage_sqs_example

Example GenStage producer for AWS Simple Queue Service

Language: Elixir - Size: 8.79 KB - Last synced: 5 months ago - Pushed: over 6 years ago - Stars: 19 - Forks: 2

cloud8421/osteria

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

Language: JavaScript - Size: 132 KB - Last synced: about 1 month ago - Pushed: almost 7 years ago - Stars: 70 - Forks: 4

rcoproc/world_temp_elixir

Language: Elixir - Size: 4.12 MB - Last synced: 7 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

127labs/shigoto

GenStage based worker queue with multiple backing store adapters

Size: 1.95 KB - Last synced: 9 months ago - Pushed: about 7 years ago - Stars: 1 - Forks: 0

anmarchenko/genstage_importer Fork of kloeckner-i/genstage_importer

Example of data import pipeline using Flow library

Size: 122 KB - Last synced: 11 months ago - Pushed: almost 6 years ago - Stars: 3 - Forks: 0

nietaki/crawlie

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

Language: Elixir - Size: 196 KB - Last synced: 29 days ago - Pushed: over 2 years ago - Stars: 87 - Forks: 11

mtwilliams/bourne

:speedboat: Better streaming for Ecto.

Language: Elixir - Size: 19.5 KB - Last synced: 2 months ago - Pushed: over 4 years ago - Stars: 75 - Forks: 12

NFIBrokerage/volley

GenStage producers for EventStoreDB 20+ with Spear

Language: Elixir - Size: 87.9 KB - Last synced: 29 days ago - Pushed: 2 months ago - Stars: 11 - Forks: 2

otobus/event_bus_postgres 📦

🐘 Postgres event store for event_bus

Language: Elixir - Size: 117 KB - Last synced: 16 days ago - Pushed: over 2 years ago - Stars: 47 - Forks: 11

aifrak/real-time-phoenix-hello-sockets

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

Language: Elixir - Size: 88.9 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

aifrak/real-time-phoenix-sneaker-23

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

Language: Elixir - Size: 752 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

aifrak/concurrent-data-processing-in-elixir

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

Language: Elixir - Size: 3.06 MB - Last synced: about 1 year ago - Pushed: about 2 years ago - Stars: 0 - Forks: 0

ybod/elixir_flow

Some experiments with Elixir Flow module

Language: Elixir - Size: 37.1 MB - Last synced: 9 months ago - Pushed: over 5 years ago - Stars: 6 - Forks: 1

jaeyson/concurrent-data-processing-in-elixir-P1

Applied examples from Concurrent Data Processing in Elixir

Language: Elixir - Size: 6.84 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

lukyanov/broadway_ecto_job

A Broadway producer for EctoJob

Language: Elixir - Size: 19.5 KB - Last synced: about 1 year ago - Pushed: almost 2 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: about 1 month ago - Pushed: over 6 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: about 1 year ago - Pushed: over 2 years ago - Stars: 2 - Forks: 0

NFIBrokerage/kelvin

GenStage/Broadway producers for Extreme

Language: Elixir - Size: 64.5 KB - Last synced: 29 days ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

HugoLnx/acai-restaurant

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

Language: Elixir - Size: 124 KB - Last synced: about 1 month ago - Pushed: about 6 years ago - Stars: 6 - Forks: 1

amokan/broadway_redis

A Broadway producer for Redis lists

Language: Elixir - Size: 16.6 KB - Last synced: 27 days ago - Pushed: over 4 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: about 1 year ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

thekeele/bitfeels

How are we feeling today Bitcoin?

Language: Elixir - Size: 51 MB - Last synced: about 1 month ago - Pushed: over 3 years ago - Stars: 4 - Forks: 0

nirev/gen_stage_example

Elixir's GenStage example

Language: Elixir - Size: 8.79 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 1 - Forks: 0

sescobb27/genstage-scraper

Language: Elixir - Size: 211 KB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 1 - Forks: 0

charlieroth/scraper

A project to learn about GenStage

Language: Elixir - Size: 13.7 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

YuriiZdyrko/elixir_concurrency_cheatsheet

Shorter version of Elixir docs, less redundant and logically ordered.

Language: Elixir - Size: 1.72 MB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 1

Voronchuk/kraken

REST API wrapper to communicate with Kraken exchange.

Language: Elixir - Size: 15.6 KB - Last synced: 12 months ago - Pushed: over 5 years ago - Stars: 2 - Forks: 6

ryanyogan/world_temp

Playing with Broadway, it's fun :)

Language: Elixir - Size: 8.79 KB - Last synced: about 1 month ago - Pushed: 5 months 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: about 1 year ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

yo-artyom/elixir_vk_parser

Language: Elixir - Size: 35.2 KB - Last synced: about 1 year ago - Pushed: over 5 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: about 1 month ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0