DataSource provides an infinite stream of data and DataStage provides a GenStage-producer you can subscribe to in order to fetch data/eve...
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
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
REST API wrapper to communicate with Kraken exchange.
A transactional job queue built with Ecto, PostgreSQL and GenStage.
A Logger backend for Telegram
Postgres event store for event_bus
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 ...