# Functions
NewPollingProcessor constructs a new PollingProcessor.
WithPollingProcessorLogger sets the log.Logger for PollingProcessor.
WithPollingProcessorMessagesPerPolling sets the number of messages to fetch for PollingProcessor.
WithPollingProcessorPollingInterval sets the interval between attempts to fetch new messages for PollingProcessor.
WithPollingProcessorPurgeInterval sets the interval between attempts to purge published messages for PollingProcessor.
WithPollingProcessorPurgeOlderThan sets the max age of published messages to purge for PollingProcessor.
WithPollingProcessorRetryer sets the retry strategy for failed calls for PollingProcessor.
# Constants
Package defaults.
Package defaults.
Package defaults.
Package defaults.
Package defaults.
Package defaults.
Package defaults.
# Variables
DefaultRetryer with exponential backoff strategy.
# Structs
Message struct for the temporary form of a Producers msg.Message.
PollingProcessor implements MessageProcessor.
# Type aliases
PollingProcessorOption options for PollingProcessor.