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.