Struct MeshServerHandler 

pub struct MeshServerHandler {
    pub state: ClusterState,
    pub stores: Arc<StateStores>,
    pub sync_manager: Arc<MeshSyncManager>,
    pub self_name: String,
    /* private fields */
}

MeshServerHandler It is the handler for the mesh server, which is responsible for the node management. Includes some basic node management logic, like shutdown, node discovery(TODO), node status update(TODO), etc.

Fields

state: ClusterState

stores: Arc<StateStores>

sync_manager: Arc<MeshSyncManager>

self_name: String

Implementations

impl MeshServerHandler

pub fn partition_detector(&self) -> Option<&Arc<PartitionDetector>>

Get partition detector

pub fn state_machine(&self) -> Option<&Arc<NodeStateMachine>>

Get state machine

pub fn is_ready(&self) -> bool

Check if node is ready

pub fn should_serve(&self) -> bool

Check if we should serve (have quorum)

pub fn start_rate_limit_task(&self, window_seconds: u64)

Start rate limit window reset task This task will periodically reset the global rate limit counter

pub fn stop_rate_limit_task(&self)

Stop rate limit window reset task

pub fn shutdown(&self)

Shutdown immediately without graceful shutdown

pub async fn graceful_shutdown(&self) -> Result<()>

Graceful shutdown: broadcast LEAVING status to all alive nodes, wait for propagation, then shutdown

pub fn write_data(&self, key: String, value: Vec<u8>) -> Result<()>

pub fn read_data(&self, key: String) -> Option<Vec<u8>>

pub fn get_operation_log(&self) -> OperationLog

Get operation log of the app store for synchronization Returns an operation log that can be merged into other nodes

pub fn sync_app_from_log(&self, log: &OperationLog)

Sync app store data from an operation log (for testing and manual sync) This will be replaced by automatic sync stream in the future