The highest tagged major version is
Documentation
¶
Index ¶
- Variables
- type Config
- type Consumer
- func New[T Message](h Handler[T], queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
- func NewFunc[T Message](h HandlerFunc[T], queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
- func NewRaw[T Message](handler RawHandler, queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
- func NewRawFunc[T Message](h RawHandlerFunc, queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
- type ExchangeBinding
- type Handler
- type HandlerFunc
- type Message
- type Option
- func WithConnectionOptions[T any](connectionOptions connection.Config) Option[T]
- func WithContext[T any](ctx context.Context) Option[T]
- func WithLogger[T any](logger logging.Logger) Option[T]
- func WithMessageDeserializer[T any](serializer serializer.Serializer[T]) Option[T]
- func WithOnErrorFunc[T any](onError connection.OnErrorFunc) Option[T]
- func WithOnListenerExit[T any](onListenerExit func(context.Context, int)) Option[T]
- func WithOnListenerStart[T any](onListenerStart func(context.Context, int)) Option[T]
- func WithOnMessageError[T any](onMessageError func(context.Context, *amqp091.Delivery, error)) Option[T]
- func WithQueueConfig[T any](cfg QueueConfig) Option[T]
- func WithRetryMessageCountCount[T any](count uint32) Option[T]
- type QueueConfig
- type QueueDeclare
- type RawHandler
- type RawHandlerFunc
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoRetry = errors.New("no retry")
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer[T Message] struct { // contains filtered or unexported fields }
func New ¶
func New[T Message](h Handler[T], queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
func NewFunc ¶
func NewFunc[T Message](h HandlerFunc[T], queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
func NewRaw ¶
func NewRaw[T Message](handler RawHandler, queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
func NewRawFunc ¶
func NewRawFunc[T Message](h RawHandlerFunc, queueDeclare QueueDeclare, options ...Option[T]) (Consumer[T], error)
type ExchangeBinding ¶
type HandlerFunc ¶
type Option ¶
func WithConnectionOptions ¶
func WithConnectionOptions[T any](connectionOptions connection.Config) Option[T]
func WithMessageDeserializer ¶
func WithMessageDeserializer[T any](serializer serializer.Serializer[T]) Option[T]
func WithOnErrorFunc ¶
func WithOnErrorFunc[T any](onError connection.OnErrorFunc) Option[T]
func WithOnListenerExit ¶
func WithOnListenerStart ¶
func WithOnMessageError ¶
func WithQueueConfig ¶
func WithQueueConfig[T any](cfg QueueConfig) Option[T]
type QueueConfig ¶
type QueueDeclare ¶
type RawHandler ¶
Source Files
Click to show internal directories.
Click to hide internal directories.