Struct WriterActor 

pub struct WriterActor { /* private fields */ }

Single-threaded writer that serializes all mutations through one SQLite connection.

On drop, the channel is closed and the writer thread is joined, ensuring all in-flight writes complete and the SQLite connection closes cleanly.

Implementations

impl WriterActor

pub fn start( path: impl AsRef<Path>, schema_manager: Arc<SchemaManager>, provenance_mode: ProvenanceMode, telemetry: Arc<TelemetryCounters>, ) -> Result<Self, EngineError>

Errors

Returns EngineError if the writer thread cannot be spawned.

pub fn submit(&self, request: WriteRequest) -> Result<WriteReceipt, EngineError>

Errors

Returns EngineError if the write request validation fails, the writer actor has shut down, or the underlying SQLite transaction fails.

pub fn touch_last_accessed( &self, request: LastAccessTouchRequest, ) -> Result<LastAccessTouchReport, EngineError>

Errors

Returns EngineError if validation fails, the writer actor has shut down, or the underlying SQLite transaction fails.

Trait Implementations

impl Debug for WriterActor

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

Formats the value using the given formatter.

impl Drop for WriterActor

fn drop(&mut self)

Executes the destructor for this type.