gen_stage

Computational parallel flows for Elixir

Updated about 3 years ago

Build concurrent and multi-stage data ingestion and data processing pipelines

Updated 6 months ago

Cron-like job scheduler for Elixir.

Updated about 2 years ago

ZenMonitor provides efficient monitoring of remote processes.

Updated about 3 years ago

Event store using PostgreSQL for persistence.

Updated 3 weeks ago

An Apache Pulsar client written in Elixir using the Pulsar websocket API.

Updated about 4 years ago

Robust job queue compatible with Sidekiq Enterprise, powered by GenStage and Redis

Updated about 3 years ago

Elixir client for ElectricSQL

Updated 3 months ago

Powerful workflow graph composition and runtime for Elixir

Updated 1 week ago

The FSM implementation generated from PlantUML textual representation.

Updated 2 months ago

GenStage producer for ServerSentEvent endpoints

Updated 4 days ago

Elixir library to read and write data of Google Spreadsheets.

Updated 3 months ago

Elixir websockets library and utilities for Bitshares/Graphene 2.0 blockchain

Updated about 9 years ago

Verk is a job processing system backed by Redis.

Updated about 5 years ago

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

Updated about 3 years ago

Flow-based Application Layer Framework

Updated about 2 years ago

Runbox is a library for running Altworx scenarios.

Updated 1 month ago

Elixir client for the Shopify GraphQL admin API

Updated about 4 years ago

A small Elm terminal runtime for Elixir and the BEAM

Updated 2 weeks ago

A transactional job queue built with Ecto, PostgreSQL and GenStage.

Updated about 6 years ago

An Off-Broadway producer enabling real-time ingestion of WebSocket data.

Updated 3 months ago

Simple building blocks for building elixir web apps

Updated about 4 years ago

Lightweight Firebase Admin SDK

Updated about 7 years ago

RabbitMQ middleware to plug into exchange chain to transform data. Peluquero is reading all the configured source exchanges, transforms and publishes to all destination exchanges. Transformers mi...

Updated about 5 years ago

PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your business logic to be specified through simple behaviour modules.

Updated about 1 year ago

A Discord wrapper / framework for elixir. This package intends to provide a solid foundation for interacting with the Discord API, as well as a very easy command and event hook system.

Updated about 5 years ago

Typed, supervised dataflow on the BEAM: describe a graph of processing stages as TOML and compile it to a Broadway supervision tree, with schema-checked edges and capability-scoped effects.

Updated 4 months ago

Durable, searchable, replayable consumer-group semantics over storage systems (MongoDB, Redis Streams, PostgreSQL/SQLite via Ecto, Mnesia, ETS): leases, fencing, partitions, frontier, lag, replay, ...

Updated 1 month ago

GenStage/Broadway producers for Extreme

Updated 9 months ago

API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion, and ORES scoring.

Updated 7 months ago