1.nats-io / nats-server
High-Performance server for NATS.io, the cloud and edge native messaging system.
- go
- golang
- messaging
- message-bus
- message-queue
- cloud-native
- +9 more
Ranked by Attention Score: stars gained over the last 180 complete days
79 repositories by Attention Score · May 8, 2026 – Nov 3, 2026 (UTC)
High-Performance server for NATS.io, the cloud and edge native messaging system.
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.
🪓 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.
httpx is a fast and multi-purpose HTTP toolkit that allows running multiple probes using the retryablehttp library.
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.
ingestr is a CLI tool to copy data between any databases with a single command seamlessly.
KEDA is a Kubernetes-based Event Driven Autoscaling component. It provides event driven scale for any container running in Kubernetes
IM Chat OpenClaw
Instant messaging platform. Backend in Go. Clients: Swift iOS, Java Android, JS webapp, scriptable command line; chatbots
Where data access meets operational intelligence
Building event-driven applications the easy way in Go.
Golang client for NATS, the cloud native messaging system.
lakeFS - Data version control for your data lake | Git for data
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Build data pipelines with SQL and Python, ingest data from different sources, add quality checks, and build end-to-end flows.
Zero-ETL, infinite possibilities. Live query APIs, code & more with SQL. No DB required.
Go DDD example application. Complete project to show how to apply DDD, Clean Architecture, and CQRS by practical refactoring.
🚀 gnet is a high-performance, lightweight, non-blocking, event-driven networking framework written in pure Go.
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
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.
Notification library for gophers and their furry friends.
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
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
[Go]Distributed Actor/Grain framework for Golang with goodies
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 🚀
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
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
Fast ring-buffer deque (double-ended queue)
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
A lightweight stream processing library for Go
Home of Quamina, a fast pattern-matching library in Go
state machine which runs code
High performance, distributed and low latency publish-subscribe platform.
A lightweight Snowflake emulator built with Go and DuckDB for local development and testing
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
Embeddable and distributed in-memory alternative to Redis.
GoEventBus — high-performance event bus with a decision layer.
Build powerful pipelines in any programming language.
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
Execution runtime for intelligent agents with event-sourced, recoverable task orchestration.
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
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 💻
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit
RabbitMQ wire tap and swiss army knife
Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)
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.
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 ⏱️.
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 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
Wisp CLI — Interactive trading platform for backtesting and live trading across spot, perpetual futures, options, and prediction markets
Distributed batch data processing framework
A full-stack DevOps on AWS framework
Monad, Functional Programming features for Golang
Go simple async message bus
Machine is a workflow/pipeline library for processing data