Struct OrderedProtocolCapture
pub struct OrderedProtocolCapture {
pub completeness: ProfileCaptureCompleteness,
pub namespace: OrderNamespace,
pub fields: Box<[OrderedProtocolField]>,
}Available on crate features
std and ua only.Expand description
A complete ordered list from one protocol namespace.
Fields§
§completeness: ProfileCaptureCompletenessWhether the source observation was complete enough to retain.
namespace: OrderNamespaceRegistry used to interpret the field identifiers.
fields: Box<[OrderedProtocolField]>Fields in their observed wire order.
Implementations§
§impl OrderedProtocolCapture
impl OrderedProtocolCapture
pub fn capture<B>(
completeness: ProfileCaptureCompleteness,
namespace: OrderNamespace,
input: impl IntoIterator<Item = (u64, B)>,
limits: OrderCaptureLimits,
) -> Result<OrderedProtocolCapture, ProfileDataError>
pub fn capture<B>( completeness: ProfileCaptureCompleteness, namespace: OrderNamespace, input: impl IntoIterator<Item = (u64, B)>, limits: OrderCaptureLimits, ) -> Result<OrderedProtocolCapture, ProfileDataError>
Values for SETTINGS use eight-byte big-endian integers; version values are empty. Source completeness is required before iterating or retaining available fields.
pub fn canonical( &self, limits: OrderCaptureLimits, ) -> Result<CanonicalValue, ProfileDataError>
pub fn from_canonical( value: &CanonicalValue, limits: OrderCaptureLimits, ) -> Result<OrderedProtocolCapture, ProfileDataError>
pub fn structural(
&self,
limits: OrderCaptureLimits,
) -> Result<CanonicalValue, ProfileDataError>
pub fn structural( &self, limits: OrderCaptureLimits, ) -> Result<CanonicalValue, ProfileDataError>
Order and reserved-candidate identifiers do not multiply structural rows. Literal semantic choices and duplicate multiplicity remain in the key. Complete samples retain path measurements, padding and nested version ordering.
Trait Implementations§
§impl Clone for OrderedProtocolCapture
impl Clone for OrderedProtocolCapture
§fn clone(&self) -> OrderedProtocolCapture
fn clone(&self) -> OrderedProtocolCapture
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 OrderedProtocolCapture
impl Debug for OrderedProtocolCapture
§impl Serialize for OrderedProtocolCapture
impl Serialize for OrderedProtocolCapture
§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 OrderedProtocolCapture
impl RefUnwindSafe for OrderedProtocolCapture
impl Send for OrderedProtocolCapture
impl Sync for OrderedProtocolCapture
impl Unpin for OrderedProtocolCapture
impl UnsafeUnpin for OrderedProtocolCapture
impl UnwindSafe for OrderedProtocolCapture
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