package
0.0.0-20241118155721-4355fa86052b
Repository: https://github.com/jamestait-jt/goflow.git
Documentation: pkg.go.dev

# Functions

NewChannelBroker creates a new ChannelBroker with a buffered channel of the specified size.
NewRedisBroker creates a new RedisBroker instance with the specified Redis client, queue key, and Encoder.
WithLogger allows you to set logger that will report on basic warnings when interacting with redis.

# Structs

ChannelBroker is a task broker implementation that wraps a buffered Go channel.
RedisBroker is a Redis-backed message broker that supports submitting and asynchronously retrieving tasks of type T.

# Interfaces

Encoder defines methods for serializing and deserializing tasks of type T, where T satisfies task.TaskOrResult.
A RedisBrokerOption sets options such as logger.