Struct StatementLoggingGuard 

pub(crate) struct StatementLoggingGuard {
    id: Option<StatementLoggingId>,
    coordinator_client: Client,
    now: NowFn,
}

RAII guard owning a frontend statement-logging lifecycle.

Created by PeekClient::begin_statement_logging. Unless logging responsibility is handed off via defuse, the guard ensures that every statement for which BeganExecution was logged also receives a corresponding EndedExecution, even on early-return, panic, or mid-flight drop of the enclosing future: if the guard is dropped without being defused, it emits StatementEndedExecutionReason::Aborted.

When the guard is defused, some other component (e.g. the coordinator, for streaming peek / subscribe responses) takes over and logs EndedExecution itself.

For non-sampled statements the guard still exists but carries no id, and retirement / drop are no-ops.

Fields

id: Option<StatementLoggingId>

None if the statement was not sampled for logging.

coordinator_client: Client

now: NowFn

Implementations

impl StatementLoggingGuard

pub(crate) fn id(&self) -> Option<StatementLoggingId>

Returns the logging id, if this statement is being logged.

pub(crate) fn defuse(self)

Hands off logging responsibility without emitting an end-execution event. Use when another component (e.g. the coordinator, for streaming peek / subscribe responses) will log the end asynchronously.

fn emit(&mut self, reason: StatementEndedExecutionReason)

Trait Implementations

impl Drop for StatementLoggingGuard

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.