ExecutorOptions

class ExecutorOptions @InternalWowApi constructor(val laneCapacity: Int = Executor.DEFAULT_LANE_CAPACITY, val maxBatch: Int = Executor.DEFAULT_MAX_BATCH, val maxInFlight: Int = InFlightLimit.DEFAULT_MAX)

How a node's executors take commands.

  • laneCapacity: the commands one aggregate may have waiting in the executor.

  • maxBatch: the most of one aggregate's queued commands the executor commits with one append; 1 runs each alone.

  • maxInFlight: the commands the node may have in flight in its executors, all contexts together (InFlightLimit); beyond it a command is refused as busy. Each partition append queue holds at most as many.

Fields may be added: Wow builds it from the host's configuration, so the constructor is internal to Wow.

Constructors

Link copied to clipboard
constructor(laneCapacity: Int = Executor.DEFAULT_LANE_CAPACITY, maxBatch: Int = Executor.DEFAULT_MAX_BATCH, maxInFlight: Int = InFlightLimit.DEFAULT_MAX)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun copyWith(laneCapacity: Int = this.laneCapacity, maxBatch: Int = this.maxBatch, maxInFlight: Int = this.maxInFlight): ExecutorOptions

This ExecutorOptions with the given fields replaced: Wow's own copy, left out of the ABI.

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String