package
1.1.1
Repository: https://github.com/winnersoftlab/relay.git
Documentation: pkg.go.dev

# Functions

NewPriorityQueue returns a new priority queue from which a consumer or producer at a given priority can be easily retrieved.

# Variables

The minimum amount of time to wait after receiving a message for a higher priority message to arrive.

# Structs

PriorityQueue is a simple wrapper around a relay.Broker to manage a set of queues with varying priority.