Struct H3RequestObservation
pub struct H3RequestObservation {
pub stream_id: u64,
pub connection: Arc<H3ObservationSnapshot>,
pub first_request: Arc<OnceLock<Arc<H3ObservationSnapshot>>>,
pub fields: Vec<ObservedFieldRepresentation>,
pub fields_complete: bool,
pub priority: Option<Box<[u8]>>,
}Available on crate features
http and std only.Expand description
Immutable connection and field-representation data at request-head delivery.
Fields§
§stream_id: u64The request stream that owns these field representations.
connection: Arc<H3ObservationSnapshot>§first_request: Arc<OnceLock<Arc<H3ObservationSnapshot>>>Published after the first head, peer SETTINGS, the available CONTROL chunk, and currently ready peer unidirectional type classification. QPACK instructions stay fixed at the first decoded head. Stream/control events describe native processing/publication, not packet chronology; optional streams never require waiting for future bytes. The boundary is independent of which request an optional collector selects. Pending or unavailable observations never imply a complete connection prefix.
fields: Vec<ObservedFieldRepresentation>§fields_complete: bool§priority: Option<Box<[u8]>>Implementations§
§impl H3RequestObservation
impl H3RequestObservation
pub fn view<'a>( &'a self, connection: &'a H3ObservationSnapshot, settings_status: SettingsStatus, pseudo_headers: Option<&'a PseudoHeaderOrder>, ) -> H3ObservationView<'a>
Trait Implementations§
§impl Clone for H3RequestObservation
impl Clone for H3RequestObservation
§fn clone(&self) -> H3RequestObservation
fn clone(&self) -> H3RequestObservation
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read more§impl Debug for H3RequestObservation
impl Debug for H3RequestObservation
impl Extension for H3RequestObservation
Auto Trait Implementations§
impl Freeze for H3RequestObservation
impl RefUnwindSafe for H3RequestObservation
impl Send for H3RequestObservation
impl Sync for H3RequestObservation
impl Unpin for H3RequestObservation
impl UnsafeUnpin for H3RequestObservation
impl UnwindSafe for H3RequestObservation
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
Mutably borrows from an owned value. Read more
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> ⓘ
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§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
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>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more