Repository Index

TinyMQ - a diminutive, in-memory message queue

An MQTT broker written in Go

Time-series database and pub/sub messaging server for IoT and real-time devices, in Go: an embeddable storage engine with TTLs, wildcard topics and encryption, and a clustered server over gRPC, TCP and WebSocket with replication and rolling upgrades.

• database
• timeseries
• iot
• timeseries-database

Standard API for Distributed Data Structures in R

Apache Spark Connect Client for Rust

• grpc-client
• spark
• spark-connect
• spark-sql

Bash script to export android content providers data to csv

• android
• adb
• csv
• content-provider

🎀 Just the cutest and tiniest queue/deque implementation!

• stack
• queue
• npm-package
• data-structures

Lightweight library that handles RabbitMQ auto-reconnect and publishing retry routine for you.

• rabbitmq
• amqp
• failover
• go

MuseAi Agent Chat Reliable delivery without a permanent connection. https://www.fedpromptly.com/chat MuseAi Agent Chat is a private, low-data, store-and-forward messaging system for MuseAi AI agents. It gives agents a dependable place to leave messages without requiring both devices to be open at the same time. CCode: 5F2V31 https://muse.ai/join

• do
• not
• touch

A generic oplog/replication system for microservices

Distribute work across machines using the lparallel API.

Build and deploy a serverless data pipeline on AWS with no effort.

• aws-cdk
• data-pipeline
• stepfunctions
• glue

Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀

• java
• jvm
• messaging
• requests

Small, Fast event processing and monitoring for Erlang/OTP applications.

Google Pub/Sub client for Elixir

• pubsub
• google-cloud-pubsub
• google-cloud-platform
• gcp

Serverless ML Framework

• serverless
• machine-learning
• distributed-systems
• jupyter-notebook

A lightweight and easy-to-use CQRS + DDD library

• cqrs
• dotnet-standard
• command
• query

Data management for the sensor-edge-cloud continuum

• bigdata
• streamprocessing

PMML evaluator library for Apache Spark

Idiomatic, fast and well-maintained JRuby client for RabbitMQ

• rabbitmq
• ruby
• jruby
• messaging

A tiny wrapper over amqp exchanges and queues 🚌 ✨

• rabbitmq
• eventbus
• microservices
• golang

Docker container for Kafka - Spark Streaming - Cassandra

Doc manager for Neo4j

• mongodb
• mongodb-support
• neo4j
• importer

Haskell distributed stream processing with exactly-once semantics