Struct NodeConfig 

pub struct NodeConfig { /* private fields */ }

Implementations

impl NodeConfig

pub fn new<P>( cluster_id: impl Into<String>, node_id: impl Into<String>, data_dir: PathBuf, epoch: u64, config_id: u64, peers: P, client_token: impl Into<String>, ) -> Result<Self, ConfigError>

where P: Into<Vec<PeerConfig>>,

pub fn new_embedded<I, S>( cluster_id: impl Into<String>, node_id: impl Into<String>, data_dir: PathBuf, epoch: u64, config_id: u64, members: I, ) -> Result<Self, ConfigError>

where I: IntoIterator<Item = S>, S: Into<String>,

pub fn new_with_configuration<P>( cluster_id: impl Into<String>, node_id: impl Into<String>, data_dir: PathBuf, epoch: u64, membership: Membership, configuration_state: ConfigurationState, peers: P, client_token: impl Into<String>, ) -> Result<Self, ConfigError>

where P: Into<Vec<PeerConfig>>,

pub fn with_execution_profile( self, execution_profile: ExecutionProfile, ) -> Result<Self, ConfigError>

pub fn with_read_consistency(self, read_consistency: ReadConsistency) -> Self

pub fn with_sql_write_profiler(self, profiler: SqlWriteProfiler) -> Self

pub fn with_sql_group_commit_queue_capacity( self, capacity: usize, ) -> Result<Self, ConfigError>

pub fn with_ack_mode(self, ack_mode: AckMode) -> Self

pub fn with_writer_batching( self, max: usize, window: Duration, ) -> Result<Self, ConfigError>

pub fn with_log_initial_configuration( self, configuration: ConfigurationState, ) -> Self

pub fn with_predecessor_stop_entry(self, entry: LogEntry) -> Self

pub fn bind_predecessor_stop( self, predecessor_membership: &Membership, entry: LogEntry, ) -> Result<Self, ConfigError>

Binds an unactivated successor draft to the exact predecessor Stop it will adopt.

pub fn with_recovery_generation( self, recovery_generation: u64, ) -> Result<Self, ConfigError>

pub fn cluster_id(&self) -> &str

pub fn logical_cluster_id(&self) -> &str

pub fn node_id(&self) -> &str

pub fn data_dir(&self) -> &PathBuf

pub const fn epoch(&self) -> u64

pub const fn config_id(&self) -> u64

pub const fn recovery_generation(&self) -> u64

pub fn peers(&self) -> &[PeerConfig]

pub const fn membership(&self) -> &Membership

pub const fn configuration_state(&self) -> &ConfigurationState

pub const fn log_initial_configuration(&self) -> &ConfigurationState

pub fn client_token(&self) -> &str

pub const fn read_consistency(&self) -> ReadConsistency

pub const fn ack_mode(&self) -> AckMode

pub const fn writer_batch_max(&self) -> usize

pub const fn writer_batch_window(&self) -> Duration

pub const fn execution_profile(&self) -> ExecutionProfile

pub const fn sql_write_profiler(&self) -> Option<&SqlWriteProfiler>

pub const fn sql_group_commit_queue_capacity(&self) -> usize

Trait Implementations

impl Clone for NodeConfig

fn clone(&self) -> NodeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeConfig

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

Formats the value using the given formatter.

impl Eq for NodeConfig

impl PartialEq for NodeConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for NodeConfig