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
67 repositories by Attention Score · May 8, 2026 – Nov 3, 2026 (UTC)
High-Performance server for NATS.io, the cloud and edge native messaging system.
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.
ingestr is a CLI tool to copy data between any databases with a single command seamlessly.
IM Chat OpenClaw
Instant messaging platform. Backend in Go. Clients: Swift iOS, Java Android, JS webapp, scriptable command line; chatbots
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.
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
A realtime distributed messaging platform
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
🪽 An open, easy, fast, reliable and battery-efficient solution for real-time communications
Privacy and Security focused Segment-alternative, in Golang and React
The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub
The Cloud Native Webhooks Gateway
IoT Platform Framework
Lightweight data stream processing engine for IoT edge
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
[Go]Distributed Actor/Grain framework for Golang with goodies
A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
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
Fast, efficient, and scalable distributed map/reduce system, DAG execution, in memory or on disk, written in pure Go, runs standalone or distributedly.
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.
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)
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit
RabbitMQ wire tap and swiss army knife
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 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
Glow is an easy-to-use distributed computation system written in Go, similar to Hadoop Map Reduce, Spark, Flink, Storm, etc. I am also working on another similar pure Go system, https://github.com/chrislusf/gleam , which is more flexible and more performant.
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