Struct ConsensusConfig

pub struct ConsensusConfig {
    pub db_path: PathBuf,
    pub db_retention_epochs: Option<u64>,
    pub db_pruner_period_secs: Option<u64>,
    pub max_pending_transactions: Option<usize>,
    pub max_submit_position: Option<usize>,
    pub submit_delay_step_override_millis: Option<u64>,
    pub parameters: Option<Parameters>,
    pub starfish_parameters: Option<Parameters>,
}

Fields

db_path: PathBuf

db_retention_epochs: Option<u64>

db_pruner_period_secs: Option<u64>

max_pending_transactions: Option<usize>

Maximum number of pending transactions to submit to consensus, including those in submission wait.

Default to 20_000 inflight limit, assuming 20_000 txn tps * 1 sec consensus latency.

max_submit_position: Option<usize>

When defined caps the calculated submission position to the max_submit_position.

Even if the is elected to submit from a higher position than this, it will “reset” to the max_submit_position.

submit_delay_step_override_millis: Option<u64>

The submit delay step to consensus defined in milliseconds.

When provided it will override the current back off logic otherwise the default backoff logic will be applied based on consensus latency estimates.

parameters: Option<Parameters>

Parameters for Mysticeti consensus

starfish_parameters: Option<Parameters>

Parameters for Starfish consensus

Implementations

impl ConsensusConfig

pub fn db_path(&self) -> &Path

pub fn max_pending_transactions(&self) -> usize

pub fn submit_delay_step_override(&self) -> Option<Duration>

pub fn db_retention_epochs(&self) -> u64

pub fn db_pruner_period(&self) -> Duration

Trait Implementations

impl Clone for ConsensusConfig

fn clone(&self) -> ConsensusConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsensusConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ConsensusConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ConsensusConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.