http4k-postbox/org.http4k.postbox.processing

Package-level declarations

Types

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

class DefaultExecutionContext(shutdownGracePeriod: Duration = Duration.ofSeconds(30)) : ExecutionContext

A ExecutionContext that runs its polling cycle on a background (virtual) thread and which, on stop, waits for in-flight work to finish for up to shutdownGracePeriod before giving up.

ExecutionContext

interface ExecutionContext

PostboxProcessing

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

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

ProcessingEvent

sealed class ProcessingEvent : Event

RandomSource

typealias RandomSource = (Int) -> Int

RequestProcessingError

data class RequestProcessingError(val reason: String)

RequestProcessingFailureReason

enum RequestProcessingFailureReason : Enum<RequestProcessingFailureReason>