Categorygithub.com/webbytes/redimq
modulepackage
0.4.0
Repository: https://github.com/webbytes/redimq.git
Documentation: pkg.go.dev

# README

RediMQ

RediMQ is a library to enable and simplfy using REDIS (v6) as a Message Queue. The library is built on the [go-redis/redis] module (v8 and above) for working with the REDIS backend. RediMQ Supports two types of queues:

  1. Ungrouped Message Topic (umts) - Unordered queue having multiple consumer groups and each consumer group with multiple consumers. This can be done using the [Topic] struct.
  2. Grouped Message Topic (gmts) - Queue which maintains order at a message group level. The Queue allows multiple consumer groups each having multiple competing consumers. This can be done using the [GroupedMessageTopic] struct.

The library leverages the REDIS Streams internally to provide the message queue features.

pkg.go.dev documentation

https://pkg.go.dev/github.com/webbytes/redimq

# Functions

NewMQClient is used to get an instance of the MQClient object that can be used to work with the queues.

# Constants

No description provided by the author
No description provided by the author

# Variables

Default "5m" - (5 minutes).

# Structs

Consumer can be used for consuming messages from a queue.
GroupedMessageTopic is used for interacting with Grouped Message Topics.
No description provided by the author
MQClient is the struct used for interacting with the queues that are created and managed by RediMQ.
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author