change

Documentation

Index

• type StatusChanger
  • func New(queueChanger mrqueue.Changer) *StatusChanger
  • func (co *StatusChanger) ChangeProcessingToRetryByTimeout(ctx context.Context, limit uint32) error
  • func (co *StatusChanger) ChangeRetryToReady(ctx context.Context, limit uint32) error

Types

type StatusChanger

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

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

func New

func New(
	queueChanger mrqueue.Changer,
) *StatusChanger

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

func (*StatusChanger) ChangeProcessingToRetryByTimeout

func (co *StatusChanger) ChangeProcessingToRetryByTimeout(ctx context.Context, limit uint32) error

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

func (*StatusChanger) ChangeRetryToReady

func (co *StatusChanger) ChangeRetryToReady(ctx context.Context, limit uint32) error

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