pub struct RuntimeQueryLifecycle { /* private fields */ }Expand description
Owner-only query lifecycle. Normal completion consumes the owner; Drop terminalizes abandoned and unwinding executions without exposing seal authority to workers.
Implementations§
Source§impl RuntimeQueryLifecycle
impl RuntimeQueryLifecycle
Sourcepub fn new(
session: RuntimeObservationSession,
plan_execution_id: PlanExecutionId,
) -> Self
pub fn new( session: RuntimeObservationSession, plan_execution_id: PlanExecutionId, ) -> Self
Opens one query and plan-execution lifecycle.
Sourcepub fn from_owner(
owner: RuntimeObservationOwner,
plan_execution_id: PlanExecutionId,
) -> Self
pub fn from_owner( owner: RuntimeObservationOwner, plan_execution_id: PlanExecutionId, ) -> Self
Opens one lifecycle using a shared owner created before admission.
Sourcepub fn plan_execution_id(&self) -> &PlanExecutionId
pub fn plan_execution_id(&self) -> &PlanExecutionId
Returns the invocation identity attached to all descendant events.
Sourcepub const fn plan_span_id(&self) -> RuntimeSpanId
pub const fn plan_span_id(&self) -> RuntimeSpanId
Returns the root span for descendant task attempts.
Sourcepub fn handle(&self) -> RuntimeObservationHandle
pub fn handle(&self) -> RuntimeObservationHandle
Returns cloneable recording access without terminal authority.
Sourcepub fn execution_scope(&self) -> RuntimeExecutionObservationScope
pub fn execution_scope(&self) -> RuntimeExecutionObservationScope
Returns the non-owning scope passed to schedulers and reservations.
Sourcepub fn finish(
self,
outcome: RuntimeTerminalOutcome,
) -> Option<SealedRuntimeObservationSnapshot>
pub fn finish( self, outcome: RuntimeTerminalOutcome, ) -> Option<SealedRuntimeObservationSnapshot>
Records cleanup and exactly one terminal, seals the owner, and consumes the lifecycle so Drop cannot emit a second terminal.
Trait Implementations§
Source§impl Debug for RuntimeQueryLifecycle
impl Debug for RuntimeQueryLifecycle
Source§impl Drop for RuntimeQueryLifecycle
impl Drop for RuntimeQueryLifecycle
Auto Trait Implementations§
impl !RefUnwindSafe for RuntimeQueryLifecycle
impl !UnwindSafe for RuntimeQueryLifecycle
impl Freeze for RuntimeQueryLifecycle
impl Send for RuntimeQueryLifecycle
impl Sync for RuntimeQueryLifecycle
impl Unpin for RuntimeQueryLifecycle
impl UnsafeUnpin for RuntimeQueryLifecycle
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more