Enum mz_adapter::command::Command

pub enum Command {
    CatalogSnapshot {
        tx: Sender<CatalogSnapshot>,
    },
    Startup {
        tx: Sender<Result<StartupResponse, AdapterError>>,
        user: User,
        conn_id: ConnectionId,
        client_ip: Option<IpAddr>,
        secret_key: u32,
        uuid: Uuid,
        application_name: String,
        notice_tx: UnboundedSender<AdapterNotice>,
    },
    Execute {
        portal_name: String,
        session: Session,
        tx: Sender<Response<ExecuteResponse>>,
        outer_ctx_extra: Option<ExecuteContextExtra>,
    },
    Commit {
        action: EndTransactionAction,
        session: Session,
        tx: Sender<Response<ExecuteResponse>>,
    },
    CancelRequest {
        conn_id: ConnectionIdType,
        secret_key: u32,
    },
    PrivilegedCancelRequest {
        conn_id: ConnectionId,
    },
    GetWebhook {
        database: String,
        schema: String,
        name: String,
        tx: Sender<Result<AppendWebhookResponse, AppendWebhookError>>,
    },
    GetSystemVars {
        conn_id: ConnectionId,
        tx: Sender<Result<GetVariablesResponse, AdapterError>>,
    },
    SetSystemVars {
        vars: BTreeMap<String, String>,
        conn_id: ConnectionId,
        tx: Sender<Result<(), AdapterError>>,
    },
    Terminate {
        conn_id: ConnectionId,
        tx: Option<Sender<Result<(), AdapterError>>>,
    },
    RetireExecute {
        data: ExecuteContextExtra,
        reason: StatementEndedExecutionReason,
    },
    CheckConsistency {
        tx: Sender<Result<(), CoordinatorInconsistencies>>,
    },
    Dump {
        tx: Sender<Result<Value, Error>>,
    },
}

Variants

CatalogSnapshot

Fields

tx: Sender<CatalogSnapshot>

Startup

Fields

tx: Sender<Result<StartupResponse, AdapterError>>

user: User

conn_id: ConnectionId

client_ip: Option<IpAddr>

secret_key: u32

uuid: Uuid

application_name: String

notice_tx: UnboundedSender<AdapterNotice>

Execute

Fields

portal_name: String

session: Session

tx: Sender<Response<ExecuteResponse>>

outer_ctx_extra: Option<ExecuteContextExtra>

Commit

Attempts to commit or abort the session’s transaction. Guarantees that the Coordinator’s transaction state has been cleared, even if the commit or abort fails. (A failure can happen, for example, if the session’s role id has been dropped which will prevent sequence_end_transaction from running.)

Fields

action: EndTransactionAction

session: Session

tx: Sender<Response<ExecuteResponse>>

CancelRequest

Fields

conn_id: ConnectionIdType

secret_key: u32

PrivilegedCancelRequest

Fields

conn_id: ConnectionId

GetWebhook

Fields

database: String

schema: String

name: String

tx: Sender<Result<AppendWebhookResponse, AppendWebhookError>>

GetSystemVars

Fields

conn_id: ConnectionId

tx: Sender<Result<GetVariablesResponse, AdapterError>>

SetSystemVars

Fields

vars: BTreeMap<String, String>

conn_id: ConnectionId

tx: Sender<Result<(), AdapterError>>

Terminate

Fields

conn_id: ConnectionId

tx: Option<Sender<Result<(), AdapterError>>>

RetireExecute

Performs any cleanup and logging actions necessary for finalizing a statement execution.

Only used for cases that terminate in the protocol layer and otherwise have no reason to hand control back to the coordinator. In other cases, we piggy-back on another command.

Fields

data: ExecuteContextExtra

reason: StatementEndedExecutionReason

CheckConsistency

Fields

tx: Sender<Result<(), CoordinatorInconsistencies>>

Dump

Fields

tx: Sender<Result<Value, Error>>

Implementations

impl Command

pub fn session(&self) -> Option<&Session>

pub fn session_mut(&mut self) -> Option<&mut Session>

Trait Implementations

impl Debug for Command

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

Formats the value using the given formatter.