A Logger backend for Telegram
GenStage/Broadway producers for Extreme
GenStage producer with back pressure for push model
Provides helpers in Elixir to create GenStage, Exq, or AMQP based event queues and handlers
a tool for building in-order GenStage topologies for EventStoreDB
GenStage producers for EventStoreDB 20+ with Spear
Elixir client for the Shopify REST API
Posthog client for Elixir.
Client for the Shopify REST admin API
Elixir GenStage that batches events together so they are not sent one-by-one
Flow-based Application Layer Framework
The tiny framework to simplify work with events, based on `GenStage`
Hemdal Alarms/Alerts System
Read KML files as a stream of features and attributes
Amazon SQS adapter for Conduit.
PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your bu...
RabbitMQ middleware to plug into exchange chain to transform data. Peluquero is reading all the configured source exchanges, transforms ...
API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion...
Library for sending push notifications. Supports Apple APNS (with either ssl certificate or JWT) and Google FCM services.
The partitioned dynamic supervision of FSM-backed workers.
Ex Saga is an NServiceBus Saga implementation in Elixir, while being abstracted away from storage and transport.
An alternative pipe operator for happy path programming.
A Discord wrapper / framework for elixir. This package intends to provide a solid foundation for interacting with the Discord API, as we...
Extensible Elixir OTP Application for storing files through a unified API. Backends currently exist for the local filesystem, SFTP and t...
Postgres event store for event_bus
Simple building blocks for building elixir web apps
GenStage based interface for RabbitMQ
A logger backend for posting errors to Slack.
A simple Elixir web crawler library powered by GenStage.
Alchemetrics is a wrapper around exometer, that uses GenStage to backpressure the reports.