Struct Database 

pub struct Database { /* private fields */ }

An offline-first SpaceDB replica.

Implementations

impl Database

pub fn open(node: Identity) -> Self

Open a local replica for node. In-memory and offline by construction; durability via spacedb-store and a real placed quorum are wiring the host supplies.

pub fn node(&self) -> &Identity

This replica’s mID.

pub fn register_identity(&self, identity: &Identity) -> SdkResult<()>

Publish an identity’s key so capabilities it issues can be verified.

pub fn define(&mut self, schema: Schema)

Register a collection’s schema.

pub fn set_clock(&mut self, now_unix: u64)

Set the logical clock used for capability expiry checks.

pub fn write_cost(&self) -> u64

The micro-$MATA cost of one mutating op under the current rate card.

pub fn session(&self, capability: SignedCapability) -> Session

Begin a session for the holder of capability.

pub fn revoke(&mut self, capability_id: [u8; 16])

Revoke a capability by id (mID kill-switch).

pub fn put_register( &mut self, session: &mut Session, collection: &str, field: &str, value: &str, ) -> SdkResult<Outcome>

Set a Register field. Returns the honest Outcome (Local for convergent/causal — durable here, converging outward).

pub fn increment( &mut self, session: &mut Session, collection: &str, field: &str, delta: i64, ) -> SdkResult<Outcome>

Add delta to a Counter field.

pub fn append_text( &mut self, session: &mut Session, collection: &str, field: &str, text: &str, ) -> SdkResult<Outcome>

Append to a Text field.

pub fn add_to_set( &mut self, session: &mut Session, collection: &str, field: &str, element: &str, ) -> SdkResult<Outcome>

Add an element to a Set field.

pub fn claim_unique( &mut self, session: &mut Session, collection: &str, field: &str, value: &str, ) -> SdkResult<StrongResult>

Claim a globally-unique value for a strong-tier field (e.g. a username). Returns the quorum’s honest StrongResult: Committed, Rejected (already taken), or Unavailable (no quorum — fails safe, commits nothing).

pub fn unique_owner( &self, collection: &str, field: &str, value: &str, ) -> Option<String>

Who owns a claimed unique value, if anyone (a quorum read).

pub fn quorum_partition(&mut self, member: &str) -> bool

Partition a strong-tier quorum member (testing / chaos).

pub fn quorum_heal(&mut self, member: &str) -> bool

Heal a strong-tier quorum member.

pub fn read_register( &self, session: &mut Session, collection: &str, field: &str, ) -> SdkResult<(Option<String>, Outcome)>

Read a Register, with the honest consistency Outcome of the read. Requires read authorization.

pub fn counter(&self, collection: &str, field: &str) -> i64

Local (always-available) reads — the convergent view on this replica.

pub fn text(&self, collection: &str, field: &str) -> String

pub fn set_members(&self, collection: &str, field: &str) -> Vec<String>

pub fn watch(&mut self, collection: &str) -> Watcher

A reactive watcher for a collection: drain_changed() returns true after any local or merged change.

pub fn export(&self, collection: &str) -> Vec<u8>

Export this replica’s state for a collection (offline sync).

pub fn import(&mut self, collection: &str, update: &[u8]) -> SdkResult<()>

Merge another replica’s exported state into this one (convergent).