Categorygithub.com/golang-queue/redisdb-stream
modulepackage
0.0.3
Repository: https://github.com/golang-queue/redisdb-stream.git
Documentation: pkg.go.dev

# README

redisdb-stream

Run Testing codecov Go Report Card

Redis Streams as backend for Queue Package

System Flow

flow

# Functions

BytesToStr converts byte slice to a string without memory allocation.
NewWorker for struc.
StrToBytes converts string to byte slice without a memory allocation.
WithAddr setup the addr of redis.
WithBlockTime setup the block time for publish messages we use the block command to make sure if no entry is found we wait until an entry is found.
WithCluster redis cluster.
WithConnectionString redis connection string.
WithConsumer consumer name.
WithPassword redis password.
WithGroup group name.
WithLogger set custom logger.
WithMaxLength setup the max length for publish messages.
WithPassword redis password.
WithRunFunc setup the run func of queue.
WithStreamName Stream name.

# Structs

Worker for Redis.

# Type aliases

Option for queue system.