Postbox

Postbox is the storage mechanism for requests that are to be processed asynchronously.

Types

data class PendingRequest(val requestId: RequestId, val request: Request, val processingTime: Instant, val failures: Int)

abstract fun markDead(requestId: RequestId, response: Response? = null): Result<Unit, PostboxError>

Mark a request as permanently failed (dead) with an optional response.

abstract fun markFailed(requestId: RequestId, delayReprocessing: Duration, response: Response?): Result<Unit, PostboxError>

Mark a request as failed with the given delay for reprocessing and an optional response.

abstract fun markProcessed(requestId: RequestId, response: Response): Result<Unit, PostboxError>

Mark a request as processed with the given response.

Retrieve all pending requests. Those are the ones that have not been marked as processed or dead yet.

Retrieve the status of a request.

Store a request in the Postbox for later processing.