queue

Documentation

Index

• func NewRedisClient() *redisClient
• type QueueClient

Functions

func NewRedisClient

func NewRedisClient() *redisClient

NewRedisClient initializes a new Redis client with the provided configuration.

Types

type QueueClient

type QueueClient interface {
	PublishMessage(message []byte) error
	SubscribeMessage() (map[string]string, error)
	Close() error
}