Struct ControlStore 

pub struct ControlStore { /* private fields */ }

Implementations

impl ControlStore

pub fn open(path: impl AsRef<Path>, identity: &ControlIdentity) -> Result<Self>

Opens and validates an existing sidecar, or creates it if absent.

pub fn create( path: impl AsRef<Path>, identity: &ControlIdentity, ) -> Result<Self>

pub fn open_existing( path: impl AsRef<Path>, identity: &ControlIdentity, ) -> Result<Self>

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

Opens a sidecar and validates its durable format without imposing an expected runtime identity. This is used by recovery paths that must load the persisted identity before they can validate the paired user DB.

pub fn read_identity(path: impl AsRef<Path>) -> Result<ControlIdentity>

pub fn path(&self) -> &Path

pub fn identity(&self) -> Result<ControlIdentity>

pub fn applied_tip(&self) -> Result<ApplyProgress>

pub fn configuration_state(&self) -> Result<ConfigurationState>

pub fn recovery_generation(&self) -> Result<u64>

pub fn materializer_fingerprint(&self) -> Result<LogHash>

pub fn user_state(&self) -> Result<StateIdentityV3>

pub fn lookup_request( &self, request_id: &str, request_digest: LogHash, ) -> Result<Option<RequestReceipt>>

pub fn lookup_requests( &self, requests: &[(&str, LogHash)], ) -> Result<Vec<Result<Option<RequestReceipt>>>>

Returns receipts in the exact order of the requested (id, digest) pairs using one bounded control-sidecar query.

Request ids must be unique. Missing ids produce Ok(None); an existing id with another digest produces an aligned request-conflict error so a caller can isolate that member without issuing another query.

pub fn embedded_log_entries( &self, from_index: u64, through_index: u64, ) -> Result<Vec<LogEntry>>

Returns a contiguous interval from the qlog embedded in the control sidecar.

pub fn pending(&self) -> Result<Option<PendingApply>>

pub fn export_replicated_snapshot(&self) -> Result<Vec<u8>>