Struct ConnectionQlogControl
pub struct ConnectionQlogControl { /* private fields */ }quic and std only.Expand description
Recording controls obtained from crate::Connection::qlog_control.
Clones share this connection’s gate and retain its sink, never the QUIC connection.
Implements Rama’s extension trait for propagation through request context.
Implementations§
§impl ConnectionQlogControl
impl ConnectionQlogControl
pub fn group_id(&self) -> ConnectionId
pub fn group_id(&self) -> ConnectionId
Stable event group identifier, matching the connection’s trace_id().
pub fn recorder(&self) -> Option<&QlogRecorder>
pub fn recorder(&self) -> Option<&QlogRecorder>
The recorder configured directly through qlog_recorder or qlog.
Returns None for custom or composed sinks; retain their recorder handles separately.
pub fn is_enabled(&self) -> bool
pub fn is_enabled(&self) -> bool
Whether both this connection’s gate and its configured sink are enabled. Queue capacity can still cause individual observations to be rejected.
pub fn set_enabled(&self, enabled: bool)
pub fn set_enabled(&self, enabled: bool)
Toggle only this connection; enabling it does not override a disabled sink. Previously submitted observations still drain, and retained history stays available.
pub async fn dump_recent(&self) -> Result<(), Error>
pub async fn dump_recent(&self) -> Result<(), Error>
Consume this connection’s recent history and flush it to the configured destination. The request is ordered with submitted events. Concurrent triggers are serialized; a cancelled waiter does not retract a command already submitted to the worker. Requires a directly configured recorder with history enabled.
Trait Implementations§
§impl Clone for ConnectionQlogControl
impl Clone for ConnectionQlogControl
§fn clone(&self) -> ConnectionQlogControl
fn clone(&self) -> ConnectionQlogControl
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more§impl Debug for ConnectionQlogControl
impl Debug for ConnectionQlogControl
impl Extension for ConnectionQlogControl
Auto Trait Implementations§
impl !RefUnwindSafe for ConnectionQlogControl
impl !UnwindSafe for ConnectionQlogControl
impl Freeze for ConnectionQlogControl
impl Send for ConnectionQlogControl
impl Sync for ConnectionQlogControl
impl Unpin for ConnectionQlogControl
impl UnsafeUnpin for ConnectionQlogControl
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§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> ⓘ
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> ⓘ
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§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more