produce

Documentation

Index

• type NoticeSender
  • func New(txManager mrstorage.DBTxManager, sequenceGenerator mrstorage.SequenceGenerator, ...) *NoticeSender
  • func (co *NoticeSender) SendNotice(ctx context.Context, key string, props map[string]any) error
• type Option
  • func WithRetryAttempts(value uint32) Option

Types

type NoticeSender

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

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

func New

func New(
	txManager mrstorage.DBTxManager,
	sequenceGenerator mrstorage.SequenceGenerator,
	storage mrnotifier.NoticeStorage,
	useCaseQueue mrqueue.Producer,
	errorWrapper mrcore.UseCaseErrorWrapper,
	opts ...Option,
) *NoticeSender

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

func (*NoticeSender) SendNotice

func (co *NoticeSender) SendNotice(ctx context.Context, key string, props map[string]any) error

SendNotice - отправляет уведомление, ключ которой должен быть зарегистрирован в БД компонента mrnotifier.template. В props можно указывать следующие служебные поля:

• header.lang (mrnotifier.HeaderLang) - язык уведомления (если не указан, то будет выбран автоматически);
• config.delayTime (mrnotifier.ConfigDelayTime) - абсолютное время (RFC3339), по истечению которого следует отправить уведомление или период, на который необходимо отложить отправку уведомления (в секундах или в формате Duration);
• fromName (mrnotifier.FieldFromName) - адрес отправителя;
• to (mrnotifier.FieldTo) - адрес получателя;
• replyTo (mrnotifier.FieldReplyTo) - адрес для ответа на уведомление;

type Option

type Option func(co *NoticeSender)

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

func WithRetryAttempts

func WithRetryAttempts(value uint32) Option

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