clean

Documentation

Index

• type NoticeCleaner
  • func New(txManager mrstorage.DBTxManager, storage mrnotifier.NoticeStorage, ...) *NoticeCleaner
  • func (co *NoticeCleaner) RemoveBrokenNotices(ctx context.Context, limit uint32) error
  • func (co *NoticeCleaner) RemoveCompletedNotices(ctx context.Context, limit uint32) error
  • func (co *NoticeCleaner) RemoveNoticesWithoutAttempts(ctx context.Context, limit uint32) error

Types

type NoticeCleaner

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

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

func New

func New(
	txManager mrstorage.DBTxManager,
	storage mrnotifier.NoticeStorage,
	useCaseQueue mrqueue.Cleaner,
	errorWrapper mrcore.UseCaseErrorWrapper,
) *NoticeCleaner

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

func (*NoticeCleaner) RemoveBrokenNotices

func (co *NoticeCleaner) RemoveBrokenNotices(ctx context.Context, limit uint32) error

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

func (*NoticeCleaner) RemoveCompletedNotices

func (co *NoticeCleaner) RemoveCompletedNotices(ctx context.Context, limit uint32) error

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

func (*NoticeCleaner) RemoveNoticesWithoutAttempts

func (co *NoticeCleaner) RemoveNoticesWithoutAttempts(ctx context.Context, limit uint32) error

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