benchmark-load/me.ahoo.wow.benchmark.load/TransferApi

TransferApi

object TransferApi

The benchmark server's routes and wait headers (wow-http): /transfer/account/{id}/<command>, Wow-Wait plans.

Properties

CONTEXT

const val CONTEXT: String

const val OK: Int = 200

REQUEST_TIMEOUT

val REQUEST_TIMEOUT: Duration

The client's own bound on a request: beyond the servers' wait timeout, so the server answers first.

Functions

annotate

fun annotate(base: URI, id: String, notes: String): HttpRequest

The request that attaches notes to account id, one event each, answered once stored: the large-payload variant (note ⑥).

commandAggregate

fun commandAggregate(body: String): String?

The aggregate a command's answer names: for E3, the target of the transfer.

commandError

fun commandError(status: Int, body: String): String?

Whether a command's answer says the command reached its wait point; null when it did, else why not.

commandVersion

fun commandVersion(body: String): Long?

The aggregate version a command's answer reports.

deposit

fun deposit(base: URI, id: String, amount: Long, wait: Wait): HttpRequest

The request that deposits amount on account id, answered at wait.

list

fun list(base: URI, limit: Int): HttpRequest

The request that lists limit accounts from the snapshots.

openAccount

fun openAccount(base: URI, id: String, owner: String, balance: Long): HttpRequest

The request that opens account id with balance, answered once its snapshot holds it.

prepare

fun prepare(base: URI, id: String, to: String, amount: Long): HttpRequest

The request that transfers amount from account id to to, answered once the target entered it.

readError

fun readError(status: Int, body: String): String?

Whether a read was answered; null when it was, else why not, with the problem's code when it has one: read-http-429-wow.query.busy is a query its store's bulkhead refused.

state

fun state(base: URI, id: String): HttpRequest

The request that reads account id's state from the snapshots.

stateVersion

fun stateVersion(body: String): Long?

The aggregate version a state read's answer reports.