http4k-incubator-db/org.http4k.postbox.processing

Package-level declarations

Types

typealias BackoffStrategy = (failures: Int, random: RandomSource) -> Duration

class PostboxProcessing(transactor: PostboxTransactor, target: HttpHandler, batchSize: Int = 10, maxFailures: Int = 3, maxPollingTime: Duration = Duration.ofSeconds(5), events: Events = { }, context: ExecutionContext = DefaultExecutionContext, backoffStrategy: BackoffStrategy = ::defaultBackoffStrategy, successCriteria: (Response) -> Boolean = { it.status.successful })

PostboxProcessing is a background process that polls the Postbox for pending requests and processes them.

typealias RandomSource = (Int) -> Int