Struct OperationContext 

pub struct OperationContext {
    pub xid: Option<Xid>,
    pub connection_id: Option<u64>,
    pub audit_principal: String,
    pub request_id: String,
    pub write_consent: Option<WriteConsent>,
    pub tenant: Option<String>,
}

Per-request context plumbed through every port method.

Fields

xid: Option<Xid>

MVCC snapshot id when the request opened a transaction; None for autocommit reads/writes.

connection_id: Option<u64>

Connection identifier the request arrived on; ties this context back to per-connection state (current transaction, session variables) when needed.

audit_principal: String

Identity recorded in audit logs. "anonymous" when the caller did not authenticate.

request_id: String

Stable per-request id used for log correlation. Either supplied by the caller via X-Request-Id or minted as a monotonic ULID-like string at request entry.

write_consent: Option<WriteConsent>

Sealed gate token, present only when WriteGate::check granted permission. Mutating port methods demand this is Some(...); missing it is a runtime error (and during the migration window, a structural reminder that the call site hasn’t been threaded yet).

tenant: Option<String>

Optional tenant override. None falls back to the connection’s default tenant.

Implementations

impl OperationContext

pub fn implicit() -> Self

Anonymous, no-write-consent context. The default for any caller that hasn’t been migrated to construct an explicit context yet — keeps the migration window compilable.

pub fn read_only(request_id: impl Into<String>) -> Self

Read-only context bound to a stable request id. Use when the handler knows it is dispatching a query that never mutates.

pub fn writing(consent: WriteConsent, request_id: impl Into<String>) -> Self

Writing context with an attached gate token. Construct WriteConsent via WriteGate::check first; passing the token here is the single point that proves the request passed the policy.

pub fn with_principal(self, principal: impl Into<String>) -> Self

pub fn with_connection(self, connection_id: u64) -> Self

pub fn with_xid(self, xid: Xid) -> Self

pub fn with_tenant(self, tenant: impl Into<String>) -> Self

pub fn require_write_consent(&self) -> Result<&WriteConsent, RedDBError>

Trait Implementations

impl Clone for OperationContext

fn clone(&self) -> OperationContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperationContext

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

Formats the value using the given formatter.