Struct RamaOperationFinished
pub struct RamaOperationFinished {
pub timestamp_ns: u64,
pub flow_id: u64,
pub operation_id: u64,
pub name: &'static str,
pub started_ns: u64,
pub duration_ns: u64,
pub outcome: u32,
pub bytes_sent: u64,
pub bytes_received: u64,
}Available on crate feature
dial9 only.Expand description
A recorded operation ended, including cancellation by dropping its future.
Fields§
§timestamp_ns: u64§flow_id: u64§operation_id: u64§name: &'static str§started_ns: u64§duration_ns: u64§outcome: u32Numeric Outcome.
bytes_sent: u64§bytes_received: u64Trait Implementations§
§impl TraceEvent for RamaOperationFinished
impl TraceEvent for RamaOperationFinished
§fn event_name() -> &'static str
fn event_name() -> &'static str
The event type name (used in schema registration).
§fn field_defs() -> Vec<FieldDef>
fn field_defs() -> Vec<FieldDef>
Field definitions for schema registration.
The timestamp is NOT included here — it is encoded in the event frame
header.
§fn schema_entry() -> SchemaEntry
fn schema_entry() -> SchemaEntry
Build a SchemaEntry for this event type.
§fn encode_fields<W>(&self, enc: &mut EventEncoder<'_, W>) -> Result<(), Error>where
W: Write,
fn encode_fields<W>(&self, enc: &mut EventEncoder<'_, W>) -> Result<(), Error>where
W: Write,
Encode this event’s non-timestamp fields into the encoder.
Auto Trait Implementations§
impl Freeze for RamaOperationFinished
impl RefUnwindSafe for RamaOperationFinished
impl Send for RamaOperationFinished
impl Sync for RamaOperationFinished
impl Unpin for RamaOperationFinished
impl UnsafeUnpin for RamaOperationFinished
impl UnwindSafe for RamaOperationFinished
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
§impl<T> Encodable for Twhere
T: TraceEvent,
impl<T> Encodable for Twhere
T: TraceEvent,
§fn encode(&self, encoder: &mut ThreadLocalEncoder<'_>)
fn encode(&self, encoder: &mut ThreadLocalEncoder<'_>)
Encode this event into the thread-local trace buffer. Read more
§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