Struct WriteRequest 

pub struct WriteRequest<R: Send + 'static> { /* private fields */ }

One write request awaiting execution by the writer task.

Carries a typed closure and a typed oneshot reply so that the concrete return type R (e.g. BatchWriteSummary) is preserved end to end, while AnyWriteRequest lets the drain loop hold heterogeneous requests in one homogeneous channel.

top_level (ADR-067 Component A, Fork C slice 2 round 2): when true, the drain loop runs this request’s operation WITHOUT wrapping it in a BEGIN IMMEDIATE/COMMIT/ROLLBACK — still serialized through the single writer owner (only one request drains at a time regardless of this flag), but with the transaction wrap skipped entirely. Exists for statements SQLite forbids inside any open transaction (e.g. VACUUM); see WriterTaskHandle::send_top_level.

Trait Implementations

impl<R: Send + 'static> AnyWriteRequest for WriteRequest<R>

fn execute_and_reply(self: Box<Self>, conn: &Connection)

Runs this request’s operation against conn, commits or rolls back the enclosing transaction based on the outcome, and sends the (possibly commit-failure-adjusted) result to the request’s oneshot reply channel.

fn execute_and_reply_top_level(self: Box<Self>, conn: &Connection)

Runs this request’s operation directly against conn — no transaction wrap, no COMMIT/ROLLBACK — and sends the result to the request’s oneshot reply channel.

fn reply_error(self: Box<Self>, err: StorageError)

Replies with err without running this request’s operation or touching conn.

fn is_top_level(&self) -> bool

true if the drain loop must run this request via Self::execute_and_reply_top_level (no transaction wrap) instead of Self::execute_and_reply (wrapped in BEGIN IMMEDIATE).