A simple Elixir web crawler library powered by GenStage.
Read KML files as a stream of features and attributes
An Off-Broadway producer enabling real-time ingestion of WebSocket data.
Twitter client library for Elixir
Hemdal Alarms/Alerts System
Elasticsearch Elixir Bulk Processor is a configurable manager for efficiently inserting data into Elasticsearch. This processor uses gens...
An Entity Component System (ECS) for Elixir focused on ease of use and ergonomics.
An Airtable API interface that optionally provides a rate-limiting server and a local cache.
Flow-based System Orchestration Framework
Hivent is a messaging platform that makes it easy to build Reactive Microservice systems.
Flow-Based Programming with Elixir GenStage.
A back-pressured backfill executor for Ecto.
Webhook magic in Elixir
Elixir GenStage that batches events together so they are not sent one-by-one
Klarna's Brod kafka client wrapped into GenStage.
Crawl and subscribe to Bitcoin transaction events using Bitbus, Bitsocket and BitFS.
Helper modules to connect an ELEMENT app with ELEMENT IoT
Production adapters and pipelines for PortfolioCore. Vector stores, graph stores, embedders, Broadway pipelines, and advanced RAG strateg...
An OTP application for reading and parsing GPS data written in Elixir. Will attach to an serial port, and provide positions to subscriber...
Client library for the Particle Cloud API.
Posthog client for Elixir.
HttpStage is a GenStage producer for data available via an HTTP GET request.
Experimental research framework for running AI benchmarks at scale. Provides orchestration, streaming processing with Flow/GenStage, and ...
GenStage producer with back pressure for push model
An alternative pipe operator for happy path programming.
GenStage wrapper for simplifying event consumption and production
Discord Library in Elixir.
Marketo REST api client
River is an http/2 (HTTP2) client for Elixir (a work in progress, though!)
API client library for any MediaWiki-based site, such as Wikipedia or Wikimedia Commons. Provides the Action API, realtime feed ingestion...