consumer

package
v1.2.9 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2024 License: MIT Imports: 18 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.