Method Detail

• insert

   abstract Long insert(CachedRequestEntity entity)

• countAll

   abstract Long countAll()

• countPendingOrProcessing

   abstract Long countPendingOrProcessing(Integer pending, Integer processing)

• selectOldestPendingIds

   abstract List<Long> selectOldestPendingIds(Integer pending, Integer limit)

• getByIds

   abstract List<CachedRequestEntity> getByIds(List<Long> ids)

• markProcessing

   abstract Integer markProcessing(List<Long> ids, Integer pending, Integer processing, Long lockedAtMs)

• releaseToPending

   abstract Integer releaseToPending(List<Long> ids, Integer pending, Integer processing)

• deleteByIds

   abstract Integer deleteByIds(List<Long> ids)

• markRetryableFailure

   abstract Integer markRetryableFailure(Long id, Integer pending, Integer retryCount)

• recoverStaleProcessing

   abstract Integer recoverStaleProcessing(Integer pending, Integer processing, Long olderThanMs)

• deleteOlderThan

   abstract Integer deleteOlderThan(Long olderThanMs)

• deleteOldest

   abstract Integer deleteOldest(Integer count)

• claimOldestPendingBatch

   List<CachedRequestEntity> claimOldestPendingBatch(Integer limit, Long nowMs)