Struct SharedState 

pub struct SharedState<I: SyncIOListener, D: DeterministicState> { /* private fields */ }

A running shared-state node. Dropping it stops the background tasks.

Implementations

impl<I, D> SharedState<I, D>

where I: SyncIOListener, D: DeterministicState + MessageEncoding, D::Action: MessageEncoding, D::AuthorityAction: MessageEncoding,

pub fn start(config: SharedStateConfig<I, D>) -> Result<Self, SettingsError>

pub fn my_address(&self) -> I::Address

pub fn leader_address(&self) -> I::Address

pub fn set_leader_address(&self, leader_address: I::Address)

pub fn set_available_peers(&self, available_peers: Vec<I::Address>)

pub fn leader_address_sender(&self) -> Sender<I::Address>

pub fn available_peers_sender(&self) -> Sender<Vec<I::Address>>

pub fn is_leader(&self) -> bool

pub fn is_connected_to_leader(&self) -> bool

pub fn debug_info(&self) -> DebugInfo<I::Address>

pub fn node(&self) -> &Arc<NodeState<I::Address, D>>

pub fn metrics(&self) -> &Arc<SharedStateMetrics>

pub fn state_handle(&self) -> StateHandle<D>

pub async fn submit_action( &self, action: D::Action, ) -> Result<(), SendError<D::Action>>

pub fn actions_sender(&self) -> Sender<D::Action>

Trait Implementations

impl<I: SyncIOListener, D: DeterministicState> Drop for SharedState<I, D>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.