Struct DumpReceipt
#[non_exhaustive]pub struct DumpReceipt {
pub dump_id: DumpId,
pub segments_processed: usize,
pub finished_at: SystemTime,
pub time_range: (SystemTime, SystemTime),
pub manifest_key: Option<String>,
}dial9 and pipeline only.Expand description
What a completed dump produced.
Best-effort: a dump where some matched segments make it through the
pipeline and others fail terminally still resolves Ok, with
segments_processed counting only the
survivors (the failures are dropped silently, exactly like a segment the
ring evicted before the worker reached it). DumpError::Pipeline is
reserved for total failure: every captured segment failed and nothing
landed.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.dump_id: DumpIdULID minted when the dump was dispatched. Time-sortable; surfaces
as dump-id user metadata on each S3 object.
segments_processed: usizeCount of segments that made it through the pipeline.
finished_at: SystemTimeWhen the last segment finished the pipeline.
time_range: (SystemTime, SystemTime)Actual covered span. May be shorter than the requested window on either side: look-back if the ring did not retain that much history, look-forward if the dump stopped before the deadline.
manifest_key: Option<String>Some({prefix}/dumps/{dump_id}.json) when the pipeline ends at S3;
None otherwise (no manifest is written off S3).
Trait Implementations§
Auto Trait Implementations§
impl Freeze for DumpReceipt
impl RefUnwindSafe for DumpReceipt
impl Send for DumpReceipt
impl Sync for DumpReceipt
impl Unpin for DumpReceipt
impl UnsafeUnpin for DumpReceipt
impl UnwindSafe for DumpReceipt
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
§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