benchmark-server/me.ahoo.wow.benchmark.transfer/WalkStore

WalkStore

sealed interface WalkStore : AutoCloseable

The account's log and its walk record, read and written with the store's own driver, as an operator reads the registry (Rebuild and Replay, "Watching it"): the log collection or table wow_log__transfer__account, the registry wow_log_aggregate.

Inheritors

Postgres

Mongo

Types

Companion

object Companion

Mongo

class Mongo(uri: String, database: String) : WalkStore

Postgres

class Postgres(url: String, user: String?, password: String?) : WalkStore

Functions

inWalkOrder

abstract fun inWalkOrder(count: Int, last: Boolean): List<String>

The ids of the first count accounts in the walk's order, or the last ones: those it reaches last.

settle

abstract fun settle()

Flushes what the seeding and unstamp left to do: the measured window pays for neither.

unstamp

abstract fun unstamp(except: List<String>, walkRecord: Boolean)

Removes the access attributes from the history of every account but except, as an import writes a log. The account's walk record goes too, unless walkRecord keeps it: a run with nothing to walk.

waits

abstract fun waits(): Map<String, Int>

What the store's sessions of the log are doing now, by what they wait on: one sample.

walk

abstract fun walk(): WalkRecord?

The account's walk record; null when none is recorded.