Watermill — это библиотека Go для создания событийно-ориентированных приложений с потоками сообщений. Она предоставляет простой интерфейс для pub/sub-обмена, поддерживая Kafka, RabbitMQ, NATS, Redis, SQL и другие системы.
Открытый код. Новые возможности.
Находите качественные проекты с открытым исходным кодом, отправляйте проекты анонимно, заявляйте права на свои проекты и редактируйте их.
Немного любопытства. Мир открытого кода.
THE FIRST COLLECTIONOpinionated фреймворк на базе Node.js и TypeScript, рассматривающий AWS Lambda как первоклассный гражданин. Предоставляет DDD-события, транзакции Unit of Work, обработку RFC 7807, повторы, OpenTelemetry и SaaS-биллинг через декораторы и типы.
PAPAI — это проактивный персональный ИИ-агент для управления задачами на естественном языке через Telegram, Mattermost, Discord и Kontur Talk, интегрируемый с Kaneo и YouTrack.
Hatchet — это движок оркестрации с открытым исходным кодом для фоновых задач, AI-агентов и устойчивых рабочих процессов. Поддерживает Python, TypeScript, Go и Ruby через саморазмещение или Hatchet Cloud. Функции: повторные попытки задач, cron-задания, DAG, мониторинг в реальном времени и мультитенантность.
Серверлесс-конвейер кликстрим-данных на AWS: ингестия через API Gateway, Kinesis, обработка и сохранение в Parquet через Firehose и S3, каталогизация Glue, запросы через Athena. IaC на AWS SAM.
AllSource — это AI-native хранилище событий, построенное на Rust, которое обеспечивает высокопроизводительную запись, низкозадержковое чтение и нативную интеграцию с MCP для AI-агентов. Оно поддерживает устойчивое хранение событий без использования PostgreSQL, включает в себя движок памяти для агентов и доступно в версиях для сообщества и предприятия.
Библиотека Go, предоставляющая ограниченные строительные блоки для Apache Kafka (producer, consumer, replay, inspection и транзакции), которые оборачивают franz-go, не скрывая результаты доставки и жизненный цикл.
Lexos — это управляемый событиями движок обработки документов на базе ИИ, объединяющий шлюз на Go, Python-воркеры, очереди Redis и локально размещенные модели для офлайн-RAG, суммаризации и транскрипции речи.