mrmailer

Documentation

Index

• Constants
• Variables
• type MessageProducer
• type MessageProvider
• type MessageStorage

Constants

const (
	HeaderLang          = "lang"                 // HeaderLang - название переменной языка сообщения
	HeaderCorrelationID = mrapp.KeyCorrelationID // HeaderCorrelationID - название переменной заголовка, содержащего CorrelationID
)

Variables

var (
	// ErrCheckMessageHasNotData - message data is not specified.
	ErrCheckMessageHasNotData = mrerr.NewProto(
		"mrmailer.errCheckMessageHasNotData", mrerr.ErrorKindInternal, "data is not specified for message {{ .name }}")

	// ErrCheckMessageHasAFewData - only one message data is expected.
	ErrCheckMessageHasAFewData = mrerr.NewProto(
		"mrmailer.errCheckMessageHasAFewData", mrerr.ErrorKindInternal, "only one data is expected for message {{ .name }}")

	// ErrProviderClientNotSpecified - there is no provider client to send this message of type.
	ErrProviderClientNotSpecified = mrerr.NewProto(
		"mrmailer.errProviderClientNotSpecified", mrerr.ErrorKindInternal, "there is no provider client to send this message of type {{ .type }}")
)

Types

type MessageProducer

type MessageProducer interface {
	SendMessage(ctx context.Context, message dto.Message) error
	Send(ctx context.Context, messages []dto.Message) error
}

MessageProducer - размещает сообщение в очереди для дальнейшей отправки.

type MessageProvider

type MessageProvider interface {
	Send(ctx context.Context, message entity.Message) error
}

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

type MessageStorage

type MessageStorage interface {
	FetchByIDs(ctx context.Context, rowsIDs []uint64) ([]entity.Message, error)
	Insert(ctx context.Context, rows []entity.Message) error
	DeleteByIDs(ctx context.Context, rowsIDs []uint64) error
}

MessageStorage - предоставляет доступ к хранилищу сообщений.