Struct RemoteConnection 

pub struct RemoteConnection { /* private fields */ }

A connection to a remote Eidetica service server over a Unix domain socket.

RemoteConnection backs the RemoteBackend implementation of the Backend seam. It provides the storage operations as inherent methods, plus additional coordination methods like notify_entry_written.

Cloning is cheap (Arc-backed).

Teardown. The reader task holds a strong Arc<RemoteConnectionInner> and inner owns the socket’s WriteHalf, so neither half of the split stream can drop on its own: the reader parks in read_frame until the daemon EOFs, and the daemon only EOFs once our socket closes. The live token breaks that cycle — when the last user-facing handle drops it calls RemoteConnectionInner::mark_dead, aborting the reader so its Arc is released, inner drops, and the WriteHalf closes. The daemon then sees EOF and scrubs the connection’s subscriptions via its ConnectionGuard.

Implementations

impl RemoteConnection

pub async fn connect(path: impl AsRef<Path>) -> Result<Self>

Connect to a service server at the given socket path.

Performs the protocol handshake, then spawns a background reader task that demuxes ServerFrames: Response frames pop the next pending oneshot in FIFO order, Notification frames dispatch into the attached Instance’s callback registry (after Self::attach_instance has been called).

pub fn session_identity(&self) -> Option<SigKey>

Build a SigKey from the session pubkey, when logged in.

pub async fn get_instance_metadata(&self) -> Result<Option<InstanceMetadata>>

pub async fn set_instance_metadata( &self, metadata: &InstanceMetadata, ) -> Result<()>

pub async fn begin_transaction( &self, root_id: ID, identity: SigKey, stores: Vec<String>, scope: ReadScope, ) -> Result<TransactionContext>

Acquire a TransactionContext for the given stores and scope.

The returned context includes main-tree parents with heights, per-store subtree parents, _settings tips, and the merged _settings value — everything needed to build and sign an entry locally without further round-trips.

pub async fn get_store_state( &self, root_id: ID, identity: SigKey, store: String, ) -> Result<WireCrdtValue>

Fetch the server-materialized merged state of an unencrypted store.

pub async fn get_store_entries( &self, root_id: ID, identity: SigKey, store: String, tips: Vec<ID>, scope: ReadScope, ) -> Result<Vec<Entry>>

Fetch ordered, verified, opaque store entries reachable from tips.

Universal primitive — works for encrypted stores (client decrypts locally) as well as unencrypted ones.

pub async fn get_verified_tips( &self, root_id: ID, identity: SigKey, ) -> Result<Snapshot>

Fetch the database’s Verified-frontier tips.

pub async fn submit_signed_entry( &self, root_id: ID, identity: SigKey, entry: Entry, ) -> Result<()>

Submit a client-signed entry to the server.

The server stores the entry as Unverified and runs its own verification pass — it never trusts a submitted entry’s claimed validity.

pub async fn db_get_entry( &self, root_id: ID, identity: SigKey, id: ID, ) -> Result<Entry>

Fetch a single database entry by id.

Gated post-fetch by the entry’s owning tree, so the caller must hold at least Read on the database the entry belongs to.

pub async fn store_snapshot_at( &self, root_id: ID, identity: SigKey, store: String, up_to: Vec<ID>, ) -> Result<Snapshot>

Subtree tips reachable from given main-tree entries.

pub async fn compute_merge_state( &self, root_id: ID, identity: SigKey, store: String, entry_ids: Vec<ID>, ) -> Result<MergeState>

Compute merge state: lowest common ancestor + path to tip entries.

pub async fn get_cached_crdt_state_remote( &self, root_id: ID, identity: SigKey, store: String, key: ID, ) -> Result<Option<Vec<u8>>>

Tier 2 cache read: ask the daemon for a previously-stashed CRDT state blob. None on miss; the caller falls back to a full recompute from store entries.

pub async fn cache_crdt_state_remote( &self, root_id: ID, identity: SigKey, store: String, key: ID, blob: Vec<u8>, ) -> Result<()>

Tier 2 cache write: stash a client-computed CRDT state blob in the daemon’s unified cache, scoped to the session user (crate::backend::CacheScope::User). Per-user trust; the daemon stores opaque bytes verbatim.

Trait Implementations

impl Clone for RemoteConnection

fn clone(&self) -> RemoteConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RemoteConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.