clean

Documentation

Index

• type MessageCleaner
  • func New(txManager mrstorage.DBTxManager, storage mrmailer.MessageStorage, ...) *MessageCleaner
  • func (co *MessageCleaner) RemoveBrokenMessages(ctx context.Context, limit uint32) error
  • func (co *MessageCleaner) RemoveCompletedMessages(ctx context.Context, limit uint32) error
  • func (co *MessageCleaner) RemoveMessagesWithoutAttempts(ctx context.Context, limit uint32) error

Types

type MessageCleaner

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

MessageCleaner - объект очищающий очередь от обработанных/сломанных сообщений.

func New

func New(
	txManager mrstorage.DBTxManager,
	storage mrmailer.MessageStorage,
	useCaseQueue mrqueue.Cleaner,
	errorWrapper mrcore.UseCaseErrorWrapper,
) *MessageCleaner

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

func (*MessageCleaner) RemoveBrokenMessages

func (co *MessageCleaner) RemoveBrokenMessages(ctx context.Context, limit uint32) error

RemoveBrokenMessages - удаляет ограниченный список сообщений из журнала ошибок.

func (*MessageCleaner) RemoveCompletedMessages

func (co *MessageCleaner) RemoveCompletedMessages(ctx context.Context, limit uint32) error

RemoveCompletedMessages - удаляет ограниченный список сообщений из успешно обработанных.

func (*MessageCleaner) RemoveMessagesWithoutAttempts

func (co *MessageCleaner) RemoveMessagesWithoutAttempts(ctx context.Context, limit uint32) error

RemoveMessagesWithoutAttempts - удаляет из очереди ограниченный список сообщений находящихся в статусе RETRY и с нулевым кол-вом попыток в целях разгрузки очереди.