Categorygithub.com/morilog/redistream
modulepackage
0.0.0-20240830093055-34ce37696c6e
Repository: https://github.com/morilog/redistream.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
9
Dependents
1
Files
266 SLOC

# README

Redistream

Redistream is a wrapper on redis stream processing commands. It provides higher level api to work with streams.

Installation

go get github.com/morilog/redistream

Usage

Visit examples for full example of usage

Features

  • Simple Producer (redis itself it simple too)
  • Handle messages with golang native channels
  • Handle errors asynchronously
  • re-Claim and handle pending messages continuously
  • Preserve message ordering by using single consumer in consumer group

License

MIT

# Packages

No description provided by the author

# Functions

NewConsumerGroup creates a new consumer group It uses DefaultConsumerGroupOptions when not any opts provided.
NewProducer creates a new producer.

# Variables

DefaultConsumerGroupOptions is the default options Topic and GroupID is empty and should be set on usage.
DefaultProducerOptions is the default producer options.

# Structs

ConsumerGroup is a consumer group of redis.
ConsumerGroupOptions contains options for the consumer group.
Message represents each redis stream item.
Producer is a redis stream producer.
ProducerOptions contains options for the producer.