Struct RuntimeObservationOwner 

pub struct RuntimeObservationOwner { /* private fields */ }

Cloneable shared ownership of one query observation session.

Clones carry the same terminal authority and the recorder’s first-terminal rule makes sealing idempotent. Execution contexts still receive only RuntimeObservationHandle.

Implementations

impl RuntimeObservationOwner

pub fn new( query_id: impl Into<QueryId>, trace_id: Option<TraceId>, config: RuntimeObservationConfig, ) -> Self

Creates shared owner authority for a new query observation session.

pub fn with_clock( query_id: impl Into<QueryId>, trace_id: Option<TraceId>, config: RuntimeObservationConfig, clock: Arc<dyn RuntimeObservationClock>, ) -> Self

Creates shared owner authority with an injected monotonic clock.

pub fn from_session(session: RuntimeObservationSession) -> Self

Wraps an existing unique session in shared one-shot ownership.

pub fn disabled() -> Self

Creates a disabled shared owner.

pub fn handle(&self) -> RuntimeObservationHandle

Returns cloneable recording access without terminal authority.

pub fn query_id(&self) -> Option<&QueryId>

Returns the immutable query identity.

pub fn trace_id(&self) -> Option<&TraceId>

Returns the immutable optional trace identity.

pub fn config(&self) -> RuntimeObservationConfig

Returns the immutable recorder configuration used to create this owner.

pub fn seal( &self, outcome: RuntimeTerminalOutcome, ) -> Option<SealedRuntimeObservationSnapshot>

Fixes the first terminal and returns the shared sealed snapshot.

pub fn finish_query( &self, outcome: Option<RuntimeTerminalOutcome>, ) -> Option<SealedRuntimeObservationSnapshot>

Completes a query that has no admitted handle responsible for cleanup.

None is reserved for coordinator-owned records that have no attempt lifecycle. Their observation still seals, and its terminal field stays absent. The seal does not synthesize an engine attempt outcome from delivery data.

pub fn live_snapshot(&self) -> Option<LiveRuntimeObservationSnapshot>

Returns a live incomplete snapshot before terminal sealing.

pub fn sealed_snapshot(&self) -> Option<SealedRuntimeObservationSnapshot>

Returns the immutable sealed snapshot once the first terminal outcome is fixed.

pub fn register_seal_observer<F>(&self, observer: F)

where F: Fn(SealedRuntimeObservationSnapshot) + Send + Sync + 'static,

Registers an infallible notification for this session’s immutable seal.

The observer runs at most once for this registration and outside recorder locks. Registrations racing terminal publication join the owner’s delivery fence; registrations after that fence has completed deliver the existing snapshot immediately. A panic is isolated from query execution and cleanup.

Trait Implementations

impl Clone for RuntimeObservationOwner

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeObservationOwner

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

Formats the value using the given formatter.

impl Default for RuntimeObservationOwner

fn default() -> Self

Returns the “default value” for a type.