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

A client for sending and receiving messages on NKN

build microservices with Kafka + Avro schemas

A BitTorrent library.

GenStage producer for ServerSentEvent endpoints

Package providing a flexible gateway connection to the Discord API.

GenStage wrapper for simplifying event consumption and production

Hardware Abstraction Layer for Nerves Devices

Flow-based System Orchestration Framework

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

A Logger backend for Telegram

Postgres event store for event_bus

tile38-server wrapper

An ECS (Entity-Component-System) framework in Elixir

Job Queue based on Genstage with retries, deduplication and replies.

Amazon SQS adapter for Conduit.

Queue and Poller behaviours for Elixir Flow

GenStage based interface for RabbitMQ

The Brains of the Farmbot Project

Subscribes GenStage consumers to producers across Elixir Umbrella apps.

Read KML files as a stream of features and attributes

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

Library for sending push notifications. Supports Apple APNS (with either ssl certificate or JWT) and Google FCM services.

Alchemetrics is a wrapper around exometer, that uses GenStage to backpressure the reports.

Elixir GenStage that batches events together so they are not sent one-by-one

An Elixir IRC module providing GenStage/callback based IRC Clients.

Distributed `Agent` implementation, providing multi-node agents on top of Mnesia.

A module that makes a GenStage producer publish to a kafka topic

A module that makes a kafka topic act as a GenState producer

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