Flow-based System Orchestration Framework

Transactional outbox for kafka

Elixir websockets library and utilities for GOLOS JSONRPC websocket interface

An OTP application for reading and parsing GPS data written in Elixir. Will attach to an serial port, and provide positions to subscriber...

Elasticsearch Elixir Bulk Processor is a configurable manager for efficiently inserting data into Elasticsearch. This processor uses gens...

API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion...

Webhook magic in Elixir

Flow-Based Programming with Elixir GenStage.

Txbox is a Bitcoin transaction storage schema

Klarna's Brod kafka client wrapped into GenStage.

Discord Library in Elixir.

Client library for the Particle Cloud API.

Hivent is a messaging platform that makes it easy to build Reactive Microservice systems.

Fawkes is a system for building chatbots.

A back-pressured backfill executor for Ecto.

River is an http/2 (HTTP2) client for Elixir (a work in progress, though!)

Marketo REST api client

Cashier is an Elixir library that aims to be an easy to use payment gateway, whilst offering the fault tolerance and scalability benefits...

A client for sending and receiving messages on NKN

Event Broadcaster (GenStage + Swarm)

Library to validate and exchange messages

GenStage wrapper for simplifying event consumption and production

Socket framework for elixir.

Elixir GenStage front-end for Redis Streams

Distributed `Agent` implementation, providing multi-node agents on top of Mnesia.

Elixir websockets library and utilities for Bitshares/Graphene 2.0 blockchain

Analysis preparation for data series for machine learning and other analysis.

An application you can use for benchmarking, read terms from a file (or other Producer) and execute them against an anonymous function of...

An ECS (Entity-Component-System) framework in Elixir

DataSource provides an infinite stream of data and DataStage provides a GenStage-producer you can subscribe to in order to fetch data/eve...