Event Broadcaster (GenStage + Swarm)
Distributed `Agent` implementation, providing multi-node agents on top of Mnesia.
Alchemetrics is a wrapper around exometer, that uses GenStage to backpressure the reports.
Flow-based Application Layer Framework
Runbox is a library for running Altworx scenarios.
Analysis preparation for data series for machine learning and other analysis.
A Batch elixir client
Elixir GenStage that batches events together so they are not sent one-by-one
a tool for building in-order GenStage topologies for EventStoreDB
Extensible Elixir OTP Application for storing files through a unified API. Backends currently exist for the local filesystem, SFTP and t...
Elixir GenStage front-end for Redis Streams
Build concurrent and multi-stage data ingestion and data processing pipelines
Cashier is an Elixir library that aims to be an easy to use payment gateway, whilst offering the fault tolerance and scalability benefits...
Amazon SQS adapter for Conduit.
A simple Elixir web crawler library powered by GenStage.
Package providing a flexible gateway connection to the Discord API.
DataSource provides an infinite stream of data and DataStage provides a GenStage-producer you can subscribe to in order to fetch data/eve...
A Discord wrapper / framework for elixir. This package intends to provide a solid foundation for interacting with the Discord API, as we...
A distributed ECS (Entity-Component-System) framework in Elixir
A library that pings services and measures the results
An ECS (Entity-Component-System) framework in Elixir
A back-pressured backfill executor for Ecto.
A transactional job queue built with Ecto, PostgreSQL and GenStage.
A BitTorrent library.
Elasticsearch Elixir Bulk Processor is a configurable manager for efficiently inserting data into Elasticsearch. This processor uses gens...
Helper modules to connect an ELEMENT app with ELEMENT IoT
An Elixir IRC module providing GenStage/callback based IRC Clients.
Elixir library to read and write data of Google Spreadsheets.
GenStage wrapper for simplifying event consumption and production
An event_bus data store building with Broadway.