A realtime distributed messaging platform
Repository Index
47,133 repositories indexed
1–24 of 24 · Most stars
High-Performance server for NATS.io, the cloud and edge native messaging system.
- go
- golang
- messaging
- message-bus
GoDS (Go Data Structures) - Sets, Lists, Stacks, Maps, Trees, Queues, and much more
- go
- golang
- data-structure
- map
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
- etl
- sql
- bigquery
- cloud-native
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
🚀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.
- epoll-tcp-server
- kqueue
- golang
- reactor
Message queue system written in Go and backed by Redis
- go
- golang
- redis
- message-queue
Data structure and algorithm library for go, designed to provide functions similar to C++ STL
Fast ring-buffer deque (double-ended queue)
- deque
- queue
- ring-buffer
- circular-buffer
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
- nanomsg
- message
- queue
- nng
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
- golang
- workflow
- distributed-system
- orchestration
Go concurrent-safe, goroutine-safe, thread-safe queue
- golang
- go
- concurrency
- concurrent
⏪️ Go package providing multiple queue implementations. Developed in a thread-safe generic way.
- generic
- golang
- queue
- thread-safe
Go simple async message bus
- message-bus
- event-sourcing
- ddd
- async
A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program
- concurrency
- go
- goroutine
- priority-queue
A highly optimized double-ended queue
- golang
- array
- double-ended-queue
- list
Type-safe, persistent, embedded task queues and background job runner w/ SQLite. Web monitoring UI included.
- go
- golang
- job-queue
- job-scheduler
A tiny wrapper over amqp exchanges and queues 🚌 ✨
- rabbitmq
- eventbus
- microservices
- golang
Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ.
- amqp
- rabbitmq
- rabbit
- golang
Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries
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.
- concurrent
- golang
- golang-library
- data-science
Abstraction layer for simple rabbitMQ connection, messaging and administration
AsyncJob is an asynchronous queue job manager with light code, clear and speed. I hope so ! 😬
- async
- queue
- simple
- lightweight