Struct Message
pub struct Message {Show 19 fields
pub id: u64,
pub connection: u64,
pub connection_display_id: Option<u64>,
pub exchange: Option<u64>,
pub protocol: Protocol,
pub direction: Direction,
pub method: Method,
pub url: Uri,
pub host: Option<Host>,
pub port: Option<u16>,
pub kind: Option<NonEmptyStr>,
pub headers: HeaderMap,
pub status: Option<StatusCode>,
pub payload: Option<Payload>,
pub binary: bool,
pub oversized: bool,
pub conditional: bool,
pub http_version: Version,
pub queued_at: Option<Timestamp>,
}Available on crate features
http and inspect and std only.Expand description
A captured HTTP head or an adapter-supplied message on an upgraded connection. Routing and HTTP values retain their types; upgraded protocols supply their own kind tags.
Fields§
§id: u64§connection: u64§connection_display_id: Option<u64>§exchange: Option<u64>§protocol: Protocol§direction: Direction§method: Method§url: Uri§host: Option<Host>§port: Option<u16>§kind: Option<NonEmptyStr>Optional protocol-owned application message tag (for example WebSocket
text or binary). HTTP heads have no kind; custom upgrade adapters may
supply their own nonempty tags without adding a protocol dependency here.
headers: HeaderMap§status: Option<StatusCode>§payload: Option<Payload>§binary: bool§oversized: bool§conditional: bool§http_version: Version§queued_at: Option<Timestamp>Implementations§
§impl Message
impl Message
pub fn serialize<__S>(
__self: &Message,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Trait Implementations§
§impl From<&Message> for PendingSummary
impl From<&Message> for PendingSummary
§fn from(m: &Message) -> PendingSummary
fn from(m: &Message) -> PendingSummary
Converts to this type from the input type.
§impl Serialize for Message
impl Serialize for Message
§fn serialize<S>(
&self,
serializer: S,
) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error>where
S: Serializer,
fn serialize<S>(
&self,
serializer: S,
) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error>where
S: Serializer,
Serialize this value into the given Serde serializer. Read more
Auto Trait Implementations§
impl !Freeze for Message
impl RefUnwindSafe for Message
impl Send for Message
impl Sync for Message
impl Unpin for Message
impl UnsafeUnpin for Message
impl UnwindSafe for Message
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