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 ...
Elixir GenServer and GenStage runtime metrics.
Extensible Elixir OTP Application for storing files through a unified API. Backends currently exist for the local filesystem, SFTP and t...
A Discord wrapper / framework for elixir. This package intends to provide a solid foundation for interacting with the Discord API, as we...