GenStage/Broadway producers for Extreme
GenStage producers for EventStoreDB 20+ with Spear
Posthog client for Elixir.
Provides helpers in Elixir to create GenStage, Exq, or AMQP based event queues and handlers
Postgres sync engine. Sync little subsets of your Postgres data into local apps and services.
Elixir client for the Shopify REST API
Queue and Poller behaviours for Elixir Flow
Ex Saga is an NServiceBus Saga implementation in Elixir, while being abstracted away from storage and transport.
Client for the Shopify REST admin API
RabbitMQ middleware to plug into exchange chain to transform data. Peluquero is reading all the configured source exchanges, transforms ...
Flow-based Application Layer Framework
An Off-Broadway producer enabling real-time ingestion of WebSocket data.
Elixir GenStage that batches events together so they are not sent one-by-one
PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your bu...
API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion...
A logger backend for posting errors to Slack.
GenStage based interface for RabbitMQ
Elixir client for singyeong.
Flow-based System Orchestration Framework
Amazon SQS adapter for Conduit.
Twitter client library for Elixir
Subscribes GenStage consumers to producers across Elixir Umbrella apps.
The generator of blazingly fast validator for map input.
An alternative pipe operator for happy path programming.
Extensible Elixir OTP Application for storing files through a unified API. Backends currently exist for the local filesystem, SFTP and t...
Library for sending push notifications. Supports Apple APNS (with either ssl certificate or JWT) and Google FCM services.
Simple building blocks for building elixir web apps
Download RSS/Atom feeds enclosures.
Read KML files as a stream of features and attributes
An OTP application for reading and parsing GPS data written in Elixir. Will attach to an serial port, and provide positions to subscriber...