change

Documentation

Index

• type Option
  • func WithRetryDelayed(value time.Duration) Option
  • func WithRetryTimeout(value time.Duration) Option
  • func WithStorageBroken(value mrqueue.BrokenStorage) Option
• type StatusChanger
  • func New(txManager mrstorage.DBTxManager, storage mrqueue.Storage, ...) *StatusChanger
  • func (co *StatusChanger) ChangeProcessingToRetryByTimeout(ctx context.Context, limit uint32) (itemsIDs []uint64, err error)
  • func (co *StatusChanger) ChangeRetryToReady(ctx context.Context, limit uint32) (itemsIDs []uint64, err error)

Types

type Option

type Option func(co *StatusChanger)

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

func WithRetryDelayed

func WithRetryDelayed(value time.Duration) Option

WithRetryDelayed - устанавливает опцию retryDelayed для StatusChanger.

func WithRetryTimeout

func WithRetryTimeout(value time.Duration) Option

WithRetryTimeout - устанавливает опцию retryTimeout для StatusChanger.

func WithStorageBroken

func WithStorageBroken(value mrqueue.BrokenStorage) Option

WithStorageBroken - устанавливает опцию storageBroken для StatusChanger.

type StatusChanger

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

StatusChanger - объект изменяющий статусы сломавшихся элементов, находящихся в очереди.

func New

func New(
	txManager mrstorage.DBTxManager,
	storage mrqueue.Storage,
	eventEmitter mrsender.EventEmitter,
	errorWrapper mrcore.UseCaseErrorWrapper,
	opts ...Option,
) *StatusChanger

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

func (*StatusChanger) ChangeProcessingToRetryByTimeout

func (co *StatusChanger) ChangeProcessingToRetryByTimeout(ctx context.Context, limit uint32) (itemsIDs []uint64, err error)

ChangeProcessingToRetryByTimeout - переводит ограниченный список элементов из статуса PROCESSING в статус RETRY по таймауту (например, в случае если обработка элемента подвисла) с занесением события в журнал ошибок.

func (*StatusChanger) ChangeRetryToReady

func (co *StatusChanger) ChangeRetryToReady(ctx context.Context, limit uint32) (itemsIDs []uint64, err error)

ChangeRetryToReady - переводит ограниченный список элементов из статуса RETRY в статус READY учитывая указанную задержку нахождения элемента в этом статусе и положительное кол-во попыток.