Event Broadcaster (GenStage + Swarm)
Aether is the elixir lib for implementating the AT Protocol in your phoenix app.
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.
The tiny framework to simplify work with events, based on `GenStage`
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...
GenStage producer with back pressure for push model
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...
A high-performance embedded distributed key-value store for Elixir applications with 600K+ ops/sec and REST API
Amazon SQS adapter for Conduit.
A simple Elixir web crawler library powered by GenStage.
Experimental research framework for running AI benchmarks at scale. Provides orchestration, streaming processing with Flow/GenStage, and ...
Package providing a flexible gateway connection to the Discord API.
Dataset management library for ML experiments with support for GSM8K, HumanEval, MMLU loaders and evaluation metrics (BLEU, ROUGE, F1).
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.