Ranked by Attention Score: stars gained over the last 7 complete days
55 repositories by Attention Score · Oct 28, 2026 – Nov 3, 2026 (UTC)
Self-hostable workflow orchestrator for teams whose main work isn't orchestration. Declarative YAML over your scripts, SSH commands, containers, etc; keep workflows separate from business logic. One binary, no database, runs on limited H/W resources. Alternative to Airflow / Cron / Job Scheduler.
High-Performance server for NATS.io, the cloud and edge native messaging system.
JuiceFS is a distributed POSIX file system built on top of Redis and S3.
httpx is a fast and multi-purpose HTTP toolkit that allows running multiple probes using the retryablehttp library.
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
The polyglot queue: Fast and reliable background jobs in Go, Java, JS, Ruby, and Rust on Postgres/SQLite.
IM Chat OpenClaw
Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably, socket.io, Phoenix.PubSub, SignalR. Set up once and forever.
The leading workflow orchestration platform. Run stateful step functions and AI workflows on serverless, servers, or the edge.
KEDA is a Kubernetes-based Event Driven Autoscaling component. It provides event driven scale for any container running in Kubernetes
Building event-driven applications the easy way in Go.
ingestr is a CLI tool to copy data between any databases with a single command seamlessly.
Build data pipelines with SQL and Python, ingest data from different sources, add quality checks, and build end-to-end flows.
Instant messaging platform. Backend in Go. Clients: Swift iOS, Java Android, JS webapp, scriptable command line; chatbots
🚀 gnet is a high-performance, lightweight, non-blocking, event-driven networking framework written in pure Go.
Privacy and Security focused Segment-alternative, in Golang and React
An actor-based Framework with network transparency for creating event-driven architecture in Golang. Inspired by Erlang. Zero dependencies.
KubeBlocks is a Kubernetes Operator designed to manage a variety of databases and streaming systems, including MySQL, PostgreSQL, MongoDB, Redis, RabbitMQ, RocketMQ, and more, within Kubernetes environments.
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
Where data access meets operational intelligence
Notification library for gophers and their furry friends.
Machinery is an asynchronous task queue/job queue based on distributed message passing.
Golang client for NATS, the cloud native messaging system.
Data pipelines for cloud config and security data. Build cloud asset inventory, CSPM, FinOps, and vulnerability management solutions. Extract from AWS, Azure, GCP, and 70+ cloud and SaaS sources.
Go DDD example application. Complete project to show how to apply DDD, Clean Architecture, and CQRS by practical refactoring.
KrakenD Community Edition: High-performance, stateless, declarative, API Gateway written in Go.
Lightweight data stream processing engine for IoT edge
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
Fancy stream processing made operationally mundane
lakeFS - Data version control for your data lake | Git for data
High performance, distributed and low latency publish-subscribe platform.
IoT Platform Framework
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
A realtime distributed messaging platform
Zero-ETL, infinite possibilities. Live query APIs, code & more with SQL. No DB required.
A lightweight stream processing library for Go
🚀Gev is a lightweight, fast non-blocking TCP network library / websocket server based on Reactor mode. Support custom protocols to quickly and easily build high-performance servers.
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
Fast ring-buffer deque (double-ended queue)
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
Simple but powerful DAG scheduler and dashboard
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.
A highly optimized double-ended queue
state machine which runs code
go-etl is a toolset for data extraction, transformation and loading.
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
Lightweight SQL-based stream processing engine for IoT edge.
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
hypermatch is a high-performance ⚡ Go library designed for rapid matching of a large number of rules to events. It processes thousands of events per second 🚀 against extensive rule sets in-memory with minimal latency ⏱️.
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
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.