Struct CellStore 

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

Cell storage manager

Implementations

impl<B: DataSyncBackend> CellStore<B>

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

Create a new cell store with sync subscription for P2P replication

pub async fn store_cell(&self, cell: &CellState) -> Result<String>

Store a cell state (OR-Set + LWW-Register operations)

pub async fn get_cell(&self, cell_id: &str) -> Result<Option<CellState>>

Retrieve a cell by ID

pub async fn get_valid_cells(&self) -> Result<Vec<CellState>>

Get all valid cells (meeting minimum size requirements)

pub async fn get_cells_by_zone( &self, platoon_id: &str, ) -> Result<Vec<CellState>>

Get all cells in a platoon

pub async fn get_cells_with_capability( &self, capability_type: CapabilityType, ) -> Result<Vec<CellState>>

Get cells that have a specific capability type

pub async fn get_available_cells(&self) -> Result<Vec<CellState>>

Get cells that are not full (can accept more members)

pub async fn add_member(&self, cell_id: &str, node_id: String) -> Result<()>

Add a member to a cell (OR-Set add operation)

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

Remove a member from a cell (OR-Set remove operation)

pub async fn set_leader(&self, cell_id: &str, node_id: String) -> Result<()>

Set squad leader (LWW-Register operation)

pub async fn add_capability( &self, cell_id: &str, capability: Capability, ) -> Result<()>

Add a capability to a cell (G-Set operation)

pub async fn delete_cell(&self, cell_id: &str) -> Result<()>

Delete a cell

pub fn backend(&self) -> &B

Get the underlying backend reference