30 Go Priority-queue Libraries

Efficient, general-purpose FIFO queue backed by a ring buffer.

container/ring container/ring provides an efficient queue data structure intended to be used in performance-sensitive contexts with usage patterns tha

01

A Redis based task scheduling module written in Golang.

TimeCapsule TimeCapsule is a Redis based task scheduling module written in Golang. It is designed to be used as a library in your own application. It

02

Memphis is an Open-Source, Real-Time Data Processing Platform

Memphis is an Open-Source, Real-Time Data Processing Platform

Real-Time Data Processing Platform Playground - Sandbox - Docs - Twitter - YouTube Memphis{dev} is an open-source real-time data processing platform t

03

A Priority Queue in Go that uses concurrency to return from Push() and Pop() in linear time, before starting a goroutine to re-heapify the underlying data structure.

CHeap A Priority Queue in Go that uses concurrency to return from Pop() and Push() in linear time, before starting a goroutine to re-heapify the under

05

A Fork of gocelery - Go Client/Server for Celery Distributed Task Queue

A Fork of gocelery - Go Client/Server for Celery Distributed Task Queue

gocelery.v3 A Fork of gocelery Go Client/Server for Celery Distributed Task Queue Why? Having been involved in several projects migrating servers from

06

auto-scaling worker pool (work queue), using Go 1.18 generics

workerpool Worker pool library with auto-scaling, backpressure, and easy composability of pools into pipelines. Uses Go 1.18 generics. Notable differe

07

Cancellable, Efficient and Reliable Distributed Task Queue in Go

Reliable, Efficient and Cancellable Distributed Task Queue in Go NQ ( Nats Queue ) is Go package for queuing and processing jobs in background with wo

08

Job queuing service and async task runner.

Valet Stateless Go server responsible for running tasks asynchronously and concurrently. Overview Job Pipeline Architecture Installation Configuration

09

Многопоточная очередь сообщений

Многопоточная очередь сообщений Работает по принципу FIFO. Первым аргументом принимает порт на котором будет слушать. Положить сообщение в очередь PUT

10

Fancy stream processing made operationally mundane

Fancy stream processing made operationally mundane

Benthos is a high performance and resilient stream processor, able to connect various sources and sinks in a range of brokering patterns and perform h

11

The missing generic container library for go, featuring an extensive iterator API.

The missing generic container library for go, featuring an extensive iterator API.

Dastructures.go (Based on https://github.com/emirpasic/gods) Implementation of various data structures and algorithms in Go. Data Structures Container

12

Simple implement concurrent worker pool & queue in go

Simple concurrent worker pool in GO Simple implement concurrent worker pool & queue in go. You can test it by simple command below. Clone the project

13

A thread-safe queue faster and more resource efficient than golang's native channels

ZenQ A low-latency thread-safe queue in golang implemented using a lock-free ringbuffer Features Much faster than native channels in both SPSC (single

14

Event queue with pub/sub pattern in simple way

Go Event Queue Internal event queue with pub/sub pattern in Go with goroutines and channels Usage Create queue to communicate between publisher and su

15

a small demo using TiDB as a message queue, providing Sub/Pub API at sacle

tipubsub A small library using TiDB providing Sub/Pub API at sacle. Subscriber: type MySubscriber struct {} var _ pubsub.Subscriber = (*MySubscriber)

16

Thread safe, blocking, generic, and infinite dequeue data structure for Go

Blocking Dequeue This package (repo) provides an implementation of a thread-safe, blocking, generic, infinite dequeue that can be used as FIFO or LIFO

17

Lock-free priority queue, using CAS to ensure concurrency security

lock_free_priority_queue Lock-free priority queue, using CAS to ensure concurrency security test func main() { q := lockfreepriorityqueue.NewLKQueue

18

Design a class to find the $k^{th} $ largest element in a stream.

Design a class to find the $k^{th} $ largest element in a stream.

golang_kth_largest_in_a_stream Design a class to find the $k^{th} $ largest element in a stream. Note that it is the $ k^{th} $ largest element in the

19

Thread-safe queues in go.

Thread-safe queues in go.

20

Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis

redis-ordered-queue-go Priority queue with message-group based partitioning and equal attention guarantee for each message group based on Redis What i

21

This is a working prototype of a queuing service, with following components: ● Queue ● Writer (Producer) ● Listener (Consumer)

Queuing Service Components Queue Writer (Producer) Listener (Consumer) Features Enqueue a JSON document into the queue. enqueue() Dequeue a JSON docum

22

Probabilistic priority queue with preselected priority levels.

Probabilistic priority queue The packet implements a priority queue with a high priority return probability: A high-level item has a better chance of

23

Key-value store with external queue

kvq Key-value store that uses external RabbitMQ queue for client-server communication. It makes use of no lock for storing data, instead, it partition

24

CLI tool for generating random messages with rules & publishing to the cloud services (SQS,SNS,PUB/SUB and etc.)

Randomsg A CLI tool to generate random messages and publish to cloud services like (SQS,SNS,PUB/SUB and etc.). TODO Generation of nested objects is no

25

A simple `sync.WaitGroup` like queue and goroutine execution controller that limits goroutine executions.

Queues A simple sync.WaitGroup like queue and goroutine execution controller. Features Limit maximum goroutine execution/count. Wait for all the gorou

26

A simple work-queue manger

I am building a work queue manager bruhhh !!!! What does a work queue manager does??? A work queue manager provides efficient and straightForward Api

27

A high-performance MPSC Queue for Go

A high-performance MPSC Queue for Go

MPSC-Go A high-performance MPSC queue between wait-free and lock-free, that is, a multi-producer but consumer queue Time-consuming test with using go

28

🐁 happy little queue

🐁 happy little queue

happy little queue 97% covered, 80LOC, integration test, auto-cleaning, lightweight When your Go code does not panic When your infra does not fail Whe

29

Queue with NATS Jetstream to remove all the erlangs from cloud

Saf in Persian means Queue. One of the problems, that we face on projects with queues is deploying RabbitMQ on the cloud which brings us many challenges for CPU load, etc. I want to see how NATS with Jetstream can work as the queue to replace RabbitMQ.

30
1