Struct RuntimeDataStore 

pub struct RuntimeDataStore<A> { /* private fields */ }

Implementations

impl<A: DataStore> RuntimeDataStore<A>

pub fn new(adapter: A, writer_id: impl Into<String>) -> Self

pub fn with_clock(adapter: A, clock: LamportClock) -> Self

pub fn read( &self, contract: &CapabilityContract, key: &str, ) -> Result<Option<Value>, DataStoreError>

Reads and validates a state value by key.

Errors

Returns DataStoreError when the key is invalid, the adapter cannot read the key, or the stored value violates the contract state schema.

pub fn write( &mut self, contract: &CapabilityContract, key: &str, value: Value, ) -> Result<StateRecord, DataStoreError>

Validates, stamps, and writes a state value for a capability contract.

Errors

Returns DataStoreError when the key is invalid, no state schema is declared, schema validation fails, the Lamport clock overflows, or the adapter cannot persist the stamped record.

pub fn delete(&mut self, key: &str) -> Result<(), DataStoreError>

Deletes a state value by key.

Errors

Returns DataStoreError when the adapter cannot delete the key.

pub fn list_keys(&self) -> Result<Vec<String>, DataStoreError>

Lists state keys.

Errors

Returns DataStoreError when the adapter cannot enumerate keys.

pub fn sync_on_reconnect( &mut self, remote: &mut dyn DataStore, ) -> Result<SyncReport, DataStoreError>

Triggers explicit sync after a reconnect event.

Errors

Returns DataStoreError when either adapter cannot read, write, list, or restore state during sync.

pub fn into_inner(self) -> A