mrmailer

Documentation

Index

• func NewComponentSender(client mrstorage.DBConnManager, messageTable mrsql.DBTableInfo, ...) *produce.MessageSender
• func NewComponentService(client mrstorage.DBConnManager, eventEmitter mrsender.EventEmitter, ...) (mrrun.Process, []mrworker.Task)
• type ServiceOption
  • func WithChangeLimit(value uint32) ServiceOption
  • func WithChangeRetryDelayed(value time.Duration) ServiceOption
  • func WithChangeRetryTimeout(value time.Duration) ServiceOption
  • func WithCleanLimit(value uint32) ServiceOption
  • func WithSendHandlerOpts(value ...handle.Option) ServiceOption
  • func WithSendProcessorOpts(value ...consume.Option) ServiceOption
  • func WithTaskChangeFromToRetryOpts(value ...task.Option) ServiceOption
  • func WithTaskCleanMessagesOpts(value ...task.Option) ServiceOption

Functions

func NewComponentSender

func NewComponentSender(
	client mrstorage.DBConnManager,
	messageTable mrsql.DBTableInfo,
	queueTable mrsql.DBTableInfo,
	eventEmitter mrsender.EventEmitter,
	opts ...produce.Option,
) *produce.MessageSender

NewComponentSender - создаёт отправителя персонализированных уведомлений получателям.

func NewComponentService

func NewComponentService(
	client mrstorage.DBConnManager,
	eventEmitter mrsender.EventEmitter,
	errorHandler mrcore.ErrorHandler,
	messageTable mrsql.DBTableInfo,
	queueTable mrsql.DBTableInfo,
	opts ...ServiceOption,
) (mrrun.Process, []mrworker.Task)

NewComponentService - создаёт сервис для обработки и отправки сообщений и связанных с ним задачи.

Types

type ServiceOption

type ServiceOption func(o *serviceOptions)

ServiceOption - настройка объекта ComponentService.

func WithChangeLimit

func WithChangeLimit(value uint32) ServiceOption

WithChangeLimit - устанавливает опцию changeLimit для ComponentService.

func WithChangeRetryDelayed

func WithChangeRetryDelayed(value time.Duration) ServiceOption

WithChangeRetryDelayed - устанавливает опцию changeRetryDelayed для ComponentService.

func WithChangeRetryTimeout

func WithChangeRetryTimeout(value time.Duration) ServiceOption

WithChangeRetryTimeout - устанавливает опцию changeRetryTimeout для ComponentService.

func WithCleanLimit

func WithCleanLimit(value uint32) ServiceOption

WithCleanLimit - устанавливает опцию cleanLimit для ComponentService.

func WithSendHandlerOpts

func WithSendHandlerOpts(value ...handle.Option) ServiceOption

WithSendHandlerOpts - устанавливает опцию sendHandler для ComponentService.

func WithSendProcessorOpts

func WithSendProcessorOpts(value ...consume.Option) ServiceOption

WithSendProcessorOpts - устанавливает опцию sendProcessor для ComponentService.

func WithTaskChangeFromToRetryOpts

func WithTaskChangeFromToRetryOpts(value ...task.Option) ServiceOption

WithTaskChangeFromToRetryOpts - устанавливает опцию taskChangeFromToRetry для ComponentService.

func WithTaskCleanMessagesOpts

func WithTaskCleanMessagesOpts(value ...task.Option) ServiceOption

WithTaskCleanMessagesOpts - устанавливает опцию taskCleanMessages для ComponentService.