consumer

package
v1.2.11-prerelease7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2024 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultConsumer

type DefaultConsumer struct {
	// contains filtered or unexported fields
}

func New

func New(
	queueID string,
	innerConsumer messaging.Consumer,
	logger log.Logger,
	metricsClient metrics.Client,
	frontendClient frontend.Client,
	options ...Option,
) *DefaultConsumer

func (*DefaultConsumer) Start

func (c *DefaultConsumer) Start() error

func (*DefaultConsumer) Stop

func (c *DefaultConsumer) Stop()

type Option

type Option func(*DefaultConsumer)

func WithConcurrency

func WithConcurrency(concurrency int) Option

type UnsupportedEncoding

type UnsupportedEncoding struct {
	EncodingType string
}

func (*UnsupportedEncoding) Error

func (e *UnsupportedEncoding) Error() string

type UnsupportedRequestType

type UnsupportedRequestType struct {
	Type sqlblobs.AsyncRequestType
}

func (*UnsupportedRequestType) Error

func (e *UnsupportedRequestType) Error() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL