Struct CalvinTuning 

pub struct CalvinTuning {
    pub channel_capacity: usize,
    pub txn_deadline_multiplier: u32,
    pub dependent_read_passive_timeout_ms: u64,
    pub verdict_stall_warn_ms: u64,
    pub max_inflight_backlog: usize,
    pub catch_up_window: u64,
    pub max_redo_entry_bytes: usize,
    pub max_open_redo_bytes: u64,
    pub restage_attempts: u32,
    pub restage_backoff_ms: u64,
}

Tuning knobs for the Calvin scheduler that runs per hosted vShard.

Fields

channel_capacity: usize

Capacity of each scheduler’s bounded input, completion, and verdict channels.

txn_deadline_multiplier: u32

Transaction deadline, in sequencer epochs.

dependent_read_passive_timeout_ms: u64

Wait in milliseconds of an active vShard’s dependent-read barrier for the read results of its passive vShards. Past it, the vShard’s data-group leader proposes the barrier’s timeout entry, and every replica aborts a barrier that entry finds incomplete.

verdict_stall_warn_ms: u64

Interval in milliseconds between stall warnings for a transaction parked on its global verdict. The transaction keeps waiting and never aborts. The idle sweep runs at a quarter of this interval.

max_inflight_backlog: usize

In-flight backlog at which a scheduler stops taking new sequenced input. The backlog counts pending, blocked, and dependent-barrier transactions. It also bounds the dependent-read barrier entries a vShard holds in memory for transactions its scheduler has not taken yet. Entries past it wait in the system catalog alone.

catch_up_window: u64

Most sequencer log entries one catch-up drain reads and replays.

max_redo_entry_bytes: usize

Largest encoded redo entry a proposer puts in a data-group log. A committed redo past it travels as chunk entries and a final entry.

max_open_redo_bytes: u64

Most bytes of chunked redo streams a node holds open. A group leader refuses a new stream that would pass it on the leader’s node. A node holds at most this much per data group it hosts.

restage_attempts: u32

Most times a leader stages a committed transaction again after its own stage failed. An earlier leader’s COMMIT vote decided the transaction, so it cannot drop. The scheduler halts once the stages run out.

restage_backoff_ms: u64

Wait in milliseconds before the first restage of a committed transaction. Each later restage waits twice as long as the one before, at most 60 seconds.

Trait Implementations

impl Clone for CalvinTuning

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CalvinTuning

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CalvinTuning

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CalvinTuning

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CalvinTuning

impl PartialEq for CalvinTuning

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for CalvinTuning

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CalvinTuning