Struct SystemManager 

pub struct SystemManager<SE, PA>(/* private fields */);

System catalog manager for storing various metadata about the system

• root clock
• valid collections (TODO)
• property definitions (TODO)

Implementations

impl<SE, PA> SystemManager<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

pub fn root(&self) -> Option<Attested<EntityState>>

pub fn items(&self) -> Vec<Entity>

pub async fn collection( &self, id: &CollectionId, ) -> Result<StorageCollectionWrapper, RetrievalError>

get an existing collection if it’s defined in the system catalog, else insert a SysItem::Collection then return collections.get to get the StorageCollectionWrapper

pub fn is_system_ready(&self) -> bool

Returns true if we’ve successfully initialized or joined a system

pub async fn wait_system_ready(&self)

Waits until we’ve successfully initialized or joined a system

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

Creates a new system root. This should only be called once per system by durable nodes The rest of the nodes must “join” this system.

pub async fn join_system( &self, state: Attested<EntityState>, ) -> Result<(), MutationError>

Joins an existing system. This should only be called by ephemeral nodes.

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

Resets all storage by deleting all collections, including the system collection. This is used when an ephemeral node needs to join a system with a different root. This is a destructive operation and should be used with extreme caution.

pub fn is_loaded(&self) -> bool

Returns true if the local system catalog is loaded

pub async fn wait_loaded(&self)

Waits for the local system catalog to be loaded

Trait Implementations

impl<SE, PA> Clone for SystemManager<SE, PA>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.