Struct Node

pub struct Node {
    pub node_id: Vec<u8>,
    /* private fields */
}

Protocol node with persistence support

Fields

node_id: Vec<u8>

Node ID

Implementations

impl Node

pub async fn new(config: NodeConfig) -> Result<Self, ProtocolError>

Create new node

pub async fn with_persistence(config: NodeConfig) -> Result<Self, ProtocolError>

Create new node with persistence

pub async fn start(&mut self) -> Result<(), ProtocolError>

Start node

pub async fn stop(&mut self) -> Result<(), ProtocolError>

Stop node

pub async fn handle_message( &mut self, message: Message, ) -> Result<(), MessageError>

Handle incoming message

pub async fn get_state(&self) -> ProtocolState

Get current node state

pub fn has_persistence(&self) -> bool

Check if persistence is enabled

pub async fn save_state(&self) -> Result<(), ProtocolError>

Save current state

pub async fn create_backup( &self, backup_path: PathBuf, ) -> Result<(), ProtocolError>

Create backup

pub async fn restore_backup( &self, backup_path: PathBuf, ) -> Result<(), ProtocolError>

Restore from backup

impl Node

pub async fn get_current_state( &self, ) -> Result<PersistedState, PersistenceError>

Get current state for persistence