produce

Documentation

Index

• type MessageSender
  • func New(txManager mrstorage.DBTxManager, sequenceGenerator mrstorage.SequenceGenerator, ...) *MessageSender
  • func (co *MessageSender) Send(ctx context.Context, messages []dto.Message) error
  • func (co *MessageSender) SendMessage(ctx context.Context, message dto.Message) error
• type Option
  • func WithDelayCorrection(value time.Duration) Option
  • func WithRetryAttempts(value uint32) Option

Types

type MessageSender

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

MessageSender - отправитель сообщений получателям.

func New

func New(
	txManager mrstorage.DBTxManager,
	sequenceGenerator mrstorage.SequenceGenerator,
	storage mrmailer.MessageStorage,
	useCaseQueue mrqueue.Producer,
	errorWrapper mrcore.UseCaseErrorWrapper,
	opts ...Option,
) *MessageSender

New - создаёт объект MessageSender.

func (*MessageSender) Send

func (co *MessageSender) Send(ctx context.Context, messages []dto.Message) error

Send - отправляет указанный список сообщений.

func (*MessageSender) SendMessage

func (co *MessageSender) SendMessage(ctx context.Context, message dto.Message) error

SendMessage - отправляет указанное сообщение.

type Option

type Option func(co *MessageSender)

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

func WithDelayCorrection

func WithDelayCorrection(value time.Duration) Option

WithDelayCorrection - устанавливает поправку на задержку сообщения (чтобы учесть, что какое-то время сообщение будет находиться в очереди).

func WithRetryAttempts

func WithRetryAttempts(value uint32) Option

WithRetryAttempts - устанавливает кол-во попыток отправки одного сообщения.