consumer

Documentation

Index

• type DefaultConsumer
  • func New(queueID string, innerConsumer messaging.Consumer, logger log.Logger, ...) *DefaultConsumer
  • func (c *DefaultConsumer) Start() error
  • func (c *DefaultConsumer) Stop()
• type Option
  • func WithConcurrency(concurrency int) Option
• type UnsupportedEncoding
  • func (e *UnsupportedEncoding) Error() string
• type UnsupportedRequestType
  • func (e *UnsupportedRequestType) Error() string

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