Elixir GenStage front-end for Redis Streams
Klarna's Brod kafka client wrapped into GenStage.
A library for connecting to HLDS servers and using GenStage to produce structured log entries.
A distributed ECS (Entity-Component-System) framework in Elixir
PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your bu...
The generator of blazingly fast validator for map input.
Event Broadcaster (GenStage + Swarm)
Streamline your (Gen)Stages and Producers
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.