consume

Documentation

Index

• type MessageProcessor
  • func NewMessageProcessor(consumer mrworker.MessageConsumer, handler mrworker.MessageHandler, ...) *MessageProcessor
  • func (p *MessageProcessor) Caption() string
  • func (p *MessageProcessor) Shutdown(_ context.Context) error
  • func (p *MessageProcessor) Start(ctx context.Context, ready func()) error
• type Option
  • func WithCaption(value string) Option
  • func WithPeriod(value time.Duration) Option
  • func WithQueueSize(value uint32) Option
  • func WithTimeout(value time.Duration) Option
  • func WithWorkersCount(value uint16) Option

Types

type MessageProcessor

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

MessageProcessor - многопоточный сервис обработки сообщений на основе консьюмера и обработчика.

func NewMessageProcessor

func NewMessageProcessor(
	consumer mrworker.MessageConsumer,
	handler mrworker.MessageHandler,
	errorHandler mrcore.ErrorHandler,
	opts ...Option,
) *MessageProcessor

NewMessageProcessor - создаёт объект MessageProcessor.

func (*MessageProcessor) Caption

func (p *MessageProcessor) Caption() string

Caption - возвращает название сервиса обработки сообщений.

func (*MessageProcessor) Shutdown

func (p *MessageProcessor) Shutdown(_ context.Context) error

Shutdown - корректная остановка сервиса обработки сообщений.

func (*MessageProcessor) Start

func (p *MessageProcessor) Start(ctx context.Context, ready func()) error

Start - запуск сервиса обработки сообщений.

type Option

type Option func(p *MessageProcessor)

Option - настройка объекта MessageProcessor.

func WithCaption

func WithCaption(value string) Option

WithCaption - устанавливает опцию caption для MessageProcessor.

func WithPeriod

func WithPeriod(value time.Duration) Option

WithPeriod - устанавливает опцию периода обращения к консьюмеру для MessageProcessor.

func WithQueueSize

func WithQueueSize(value uint32) Option

WithQueueSize - устанавливает опцию размера очереди обработки сообщений для MessageProcessor.

func WithTimeout

func WithTimeout(value time.Duration) Option

WithTimeout - устанавливает опцию timeout выполнения обработчика сообщения для MessageProcessor.

func WithWorkersCount

func WithWorkersCount(value uint16) Option

WithWorkersCount - устанавливает опцию количества воркеров обрабатывающих сообщения для MessageProcessor.