Computational parallel flows on top of GenStage

flow

Generic Task behavior that helps encapsulate errors and recover from them in classic GenStage workers.

MIT License

gen_task

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

flume

Transactional job queue with Ecto, PostgreSQL and GenStage

ecto_job

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.

flow

gen_task

flume

ecto_job

elasticsearch_elixir_bulk_processor