Repository Index

🪓 An orchestration engine for background tasks, AI agents, and durable workflows

• event-driven
• golang
• workflow-engine
• distributed

Python Stream Processing

• kafka-streams
• kafka
• python
• asyncio

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

• asyncio
• kafka
• python
• rabbitmq

A library for event sourcing in Python.

• domain-driven-design
• ddd
• eventsourcing
• cqrs

Stream Processing Made Easy

• machine-learning
• reactive-programming
• kafka
• reactive-systems

Conflict-free merge for DataFrames, JSON, ML models & distributed agents — powered by CRDTs. The first merge library where every operation is mathematically guaranteed to converge.

• collaborative-editing
• conflict-resolution
• crdt
• data-engineering