Struct NodeStore 

pub struct NodeStore<B: DataSyncBackend> { /* private fields */ }

Node storage manager

Implementations

impl<B: DataSyncBackend> NodeStore<B>

pub async fn new(backend: Arc<B>) -> Result<Self>

Create a new node store with sync subscriptions for P2P replication

pub async fn store_config(&self, config: &NodeConfig) -> Result<String>

Store a node configuration (G-Set operation)

pub async fn get_config(&self, node_id: &str) -> Result<Option<NodeConfig>>

Retrieve a node configuration by ID

pub async fn store_state( &self, node_id: &str, state: &NodeState, ) -> Result<String>

Store node state (LWW-Register operation)

pub async fn get_state(&self, node_id: &str) -> Result<Option<NodeState>>

Retrieve node state by ID

pub async fn get_nodes_by_phase(&self, phase: Phase) -> Result<Vec<NodeState>>

Get all nodes in a specific phase

pub async fn get_nodes_by_cell(&self, squad_id: &str) -> Result<Vec<NodeState>>

Get all nodes in a specific squad

pub async fn get_operational_nodes(&self) -> Result<Vec<NodeState>>

Get all operational nodes (health != Failed && fuel > 0)

pub async fn delete_config(&self, node_id: &str) -> Result<()>

Delete a node configuration

pub async fn delete_state(&self, node_id: &str) -> Result<()>

Delete a node state

pub fn backend(&self) -> &B

Get the underlying backend reference