Ranked by Attention Score: stars gained over the last 90 complete days
92 repositories by Attention Score · Aug 6, 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.
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
JuiceFS is a distributed POSIX file system built on top of Redis and S3.
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.
httpx is a fast and multi-purpose HTTP toolkit that allows running multiple probes using the retryablehttp library.
The polyglot queue: Fast and reliable background jobs in Go, Java, JS, Ruby, and Rust on Postgres/SQLite.
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
IM Chat OpenClaw
Workflow Engine for Kubernetes
ingestr is a CLI tool to copy data between any databases with a single command seamlessly.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Instant messaging platform. Backend in Go. Clients: Swift iOS, Java Android, JS webapp, scriptable command line; chatbots
Build data pipelines with SQL and Python, ingest data from different sources, add quality checks, and build end-to-end flows.
Building event-driven applications the easy way in Go.
Where data access meets operational intelligence
Golang client for NATS, the cloud native messaging system.
lakeFS - Data version control for your data lake | Git for data
Go DDD example application. Complete project to show how to apply DDD, Clean Architecture, and CQRS by practical refactoring.
Zero-ETL, infinite possibilities. Live query APIs, code & more with SQL. No DB required.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
An actor-based Framework with network transparency for creating event-driven architecture in Golang. Inspired by Erlang. Zero dependencies.
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.
Fancy stream processing made operationally mundane
Notification library for gophers and their furry friends.
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.
🚀 gnet is a high-performance, lightweight, non-blocking, event-driven networking framework written in pure Go.
A realtime distributed messaging platform
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
Privacy and Security focused Segment-alternative, in Golang and React
KrakenD Community Edition: High-performance, stateless, declarative, API Gateway written in Go.
IoT Platform Framework
Lightweight data stream processing engine for IoT edge
[Go]Distributed Actor/Grain framework for Golang with goodies
Machinery is an asynchronous task queue/job queue based on distributed message passing.
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time safety, automatic retries, and horizontal scaling out of the box. Integrate with your existing tech stack using adapters 🚀
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
A lightweight stream processing library for Go
Home of Quamina, a fast pattern-matching library in Go
High performance, distributed and low latency publish-subscribe platform.
iWF is a Workflow-As-Code microservice orchestration platform offering an orchestration coding framework and service for building resilient, fault-tolerant, scalable long-running processes
state machine which runs code
Fast ring-buffer deque (double-ended queue)
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
Embeddable and distributed in-memory alternative to Redis.
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
Execution runtime for intelligent agents with event-sourced, recoverable task orchestration.
🚀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.
GoEventBus — high-performance event bus with a decision layer.
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
Build powerful pipelines in any programming language.
A crazy fast analytical database, built on bitmaps. Perfect for ML applications. Learn more at: http://docs.featurebase.com/. Start a Docker instance: https://hub.docker.com/r/featurebasedb/featurebase
💨 A real time messaging system to build a scalable in-app notifications, multiplayer games, chat apps in web and mobile apps.
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
🚃 A library for handling mediator patterns and simplified CQRS patterns within an event-driven architecture, inspired by csharp MediatR library.
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
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 ⏱️.
Test your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻
Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Simple but powerful DAG scheduler and dashboard
go-etl is a toolset for data extraction, transformation and loading.
Lightweight SQL-based stream processing engine for IoT edge.
RabbitMQ wire tap and swiss army knife
A Go port of the Java Streams API. Type-safe and functional Go Streams processing
Ordered-concurrently a library for concurrent processing with ordered output in Go. Process work concurrently and returns output in a channel in the order of input. It is useful in concurrently processing items in a queue, and get output in the order provided by the queue.
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.
A full-stack DevOps on AWS framework
An n:m message multiplexer written in Go
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit
Monad, Functional Programming features for Golang
A CLI tool for Kafka
Go simple async message bus
A highly optimized double-ended queue
A Kafka log inspired in-memory and append-only data structure
Distributed batch data processing framework
🐇 CLI tool for websockets and Go package
Production-grade Server-Sent Events (SSE) for Fiber v3. Event coalescing, priority lanes, topic wildcards, adaptive throttling, built-in auth, Prometheus metrics, graceful drain.