Repository Index

A compatibility layer for event-driven abstractions

• stream-processing
• future
• clojure
• async

:lipstick: Durable and asynchronous data imports for consuming data at scale and publishing testable SDKs.

• porter
• data-import
• framework
• data-transformation

Abstraction layer for simple rabbitMQ connection, messaging and administration

• golang
• rabbitmq
• queue

A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.

• go
• kafka
• message-broker
• opentelemetry