Struct SqliteSyncWork 

pub struct SqliteSyncWork<'a> { /* private fields */ }

Bounded provider-owned unit of work; never exposes SQL or a connection. Callbacks must be short and must not reenter this store or wait for network I/O. Filesystem writes are outside this transaction and require a recovery journal.

Implementations

impl SqliteSyncWork<'_>

pub fn append( &mut self, payload: &[u8], sequence: u64, ) -> SqliteSyncResult<usize>

Appends an opaque record. Identical positive sequence replay is a no-op.

pub fn enqueue(&mut self, message: &SyncMessage) -> SqliteSyncResult<bool>

Enqueues one bounded message. Identical pending replay returns false; a full queue returns an error, ensuring the whole unit of work rolls back.

pub fn checkpoint( &mut self, peer: &str, sequence: u64, hash: &str, observed_head: u64, ) -> SqliteSyncResult<()>

Advances a checkpoint only within an authenticated observed history head. Head authenticity and materialization are the caller’s responsibility.

pub fn stage_object_write( &mut self, intent: &ObjectWriteIntentV1, ) -> SqliteSyncResult<bool>

Journals opaque bytes before filesystem publication in the same transaction as enqueue/log/checkpoint. Replay materializes committed intents only.

pub fn acknowledge( &mut self, receipt: &SyncOutboxReceipt, ) -> SqliteSyncResult<usize>

Applies an exact ordered outbox receipt in this transaction, so checkpoint advancement and acknowledgement may share one commit boundary.

pub fn put_object_v1( &mut self, object: &OpaqueObjectV1, mutation_id: &str, expected: ObjectRevisionV1, ) -> SqliteSyncResult<ObjectWriteResultV1>

Mutates a canonical opaque object atomically with this work’s sync operations. Exact mutation replay returns its original revision without replacing later data. Reusing an identity with different bytes fails. Propagate every returned error.