Enum SessionOp 

pub enum SessionOp {
    Begin {
        client_id: Option<String>,
        mid: Option<u64>,
        producer: Option<ProducerWrite>,
        statements: Vec<SqlStatement>,
        query: Option<SqlStatement>,
        guarded: bool,
    },
    Exec {
        session_id: String,
        statements: Vec<SqlStatement>,
    },
    Query {
        session_id: String,
        query: SqlStatement,
    },
    Commit {
        session_id: String,
    },
    Rollback {
        session_id: String,
    },
    SqlBegin {
        read_only: bool,
        isolation: String,
        min_cursor: Option<u64>,
    },
    SqlExecute {
        session_id: String,
        statements: Vec<SqlStatementRequest>,
        operation_id: String,
    },
    SqlCommit {
        session_id: String,
        operation_id: String,
    },
    SqlRollback {
        session_id: String,
        operation_id: String,
    },
    SqlCancel {
        session_id: String,
        operation_id: String,
    },
}

One /mutate-session/* request, parsed on the intake thread. Begin optionally carries the accumulated write prefix and the first read, so a lazy-upgrading mutator’s first interactive read costs ONE round trip over the batch path (DAEMON-INTERACTIVE-TXN-DESIGN.md §4.1).

Variants

Begin

Fields

client_id: Option<String>

mid: Option<u64>

producer: Option<ProducerWrite>

statements: Vec<SqlStatement>

query: Option<SqlStatement>

guarded: bool

Run the session’s statements under the public reserved-object authorizer and serialize its reads with the tagged value wire. The public mutation facade sets this; the legacy /mutate-session/* control plane leaves it false.

Exec

Fields

session_id: String

statements: Vec<SqlStatement>

Query

Fields

session_id: String

query: SqlStatement

Commit

Fields

session_id: String

Rollback

Fields

session_id: String

SqlBegin

Fields

read_only: bool

isolation: String

min_cursor: Option<u64>

SqlExecute

Fields

session_id: String

statements: Vec<SqlStatementRequest>

operation_id: String

SqlCommit

Fields

session_id: String

operation_id: String

SqlRollback

Fields

session_id: String

operation_id: String

SqlCancel

Fields

session_id: String

operation_id: String