Open source. Open possibilities.

Lexos is an event-driven AI document processing engine combining a Go gateway, Python workers, Redis queues and self-hosted models for offline RAG, summarization and speech transcription.

Watermill is a Go library for building event-driven applications with message streams. It provides a simple interface for pub/sub messaging, supporting Kafka, RabbitMQ, NATS, Redis, SQL, and more.

An opinionated Node.js/TypeScript framework treating AWS Lambda as a first-class citizen, providing DDD domain events, Unit of Work transactions, RFC 7807 problem handling, and SaaS billing/metering via decorators and types.

PAPAI is a proactive personal AI agent for natural language task management across Telegram, Mattermost, Discord, and Kontur Talk, integrating with Kaneo and YouTrack.

Hatchet is an open-source orchestration engine for background tasks, AI agents, and durable workflows. Supports Python, TypeScript, Go, and Ruby via self-hosting or Hatchet Cloud. Features task retries, cron jobs, DAGs, real-time monitoring, and multi-tenancy.

A fully serverless, event-driven clickstream data pipeline on AWS that ingests, transforms, and stores clickstream events in Parquet format using API Gateway, Kinesis, Firehose, Lambda, and Athena, with production-ready IaC via AWS SAM.

AllSource is an AI-native event store built in Rust, featuring high-throughput ingestion, low-latency reads, and native MCP integration for AI agents. It supports durable event sourcing without Postgres, includes an agent memory engine, and offers community and enterprise editions.

Go library offering bounded Apache Kafka producer, consumer, replay, inspection and transactional building blocks that wrap franz-go without hiding delivery outcomes, lifecycle ownership or topic policy.