windhooked
Follow
Stream Processing
The open source, end-to-end computer vision platform. Label, build, train, tune, deploy and automate in a unified platform that runs on any cloud and on-premises.
Transactional outbox harvester for Postgres → Kafka, written in Go
Sync data between persistence engines, like ETL only not stodgy
Golang framework for streaming ETL, observability data pipeline, and event processing apps
Fast, efficient, and scalable distributed map/reduce system, DAG execution, in memory or on disk, written in pure Go, runs standalone or distributedly.
Flow-based and dataflow programming library for Go (golang)
Cancellable flow-net (a concurrent pattern) for Go programming language
Cancellable, Efficient and Reliable Distributed Task Queue in Go
🦖 Serverless AI Agent Framework with Geo-distributed Edge AI Infra.
Lightweight data stream processing engine for IoT edge
EdgeX Golang Services Monorepo | Owner: Core/Support WG
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
Memphis.dev is a highly scalable and effortless data streaming platform
JMS style messaging interface for Golang applications connecting to IBM MQ
A reference implementation of an event-sourced system that uses PostgreSQL as an event store built with Spring Boot. Fork the repository and use it as a template for your projects. Or clone the rep…
The most scalable and reliable MQTT broker for AI, IoT, IIoT and connected vehicles
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
A local-first workflow engine built the way it should be: declarative, file-based, self-contained, air-gapped ready. One binary that scales from laptop to distributed cluster.
Event streaming platform for agents, apps, and analytics. Continuously ingest, transform, and serve event data in real time, at scale.
The Durable Task Framework is a lightweight, embeddable engine for writing durable, fault-tolerant business logic (orchestrations) as ordinary code.
Embedded durable workflows for Golang similar to DTFx/Cadence/Temporal
Kafka Streams DSL inspired, Stream processing library abstracting pipelines pattern using generic.
Toolkit for event-centric and reactive patterns leveraging https://nats.io.
Kids Money Manager - Demo application using Rita (https://github.com/bruth/rita)