Struct axiom_rs::datasets::IngestStatus
source · [−]pub struct IngestStatus {
pub ingested: u64,
pub failed: u64,
pub failures: Vec<IngestFailure>,
pub processed_bytes: u64,
pub blocks_created: u32,
pub wal_length: u32,
}
Expand description
Returned on event ingestion operation.
Fields
ingested: u64
Amount of events that have been ingested.
failed: u64
Amount of events that failed to ingest.
failures: Vec<IngestFailure>
Ingestion failures, if any.
processed_bytes: u64
Number of bytes processed.
blocks_created: u32
Amount of blocks created.
wal_length: u32
The length of the Write-Ahead Log.
Trait Implementations
sourceimpl Add<IngestStatus> for IngestStatus
impl Add<IngestStatus> for IngestStatus
type Output = IngestStatus
type Output = IngestStatus
The resulting type after applying the +
operator.
sourceimpl Debug for IngestStatus
impl Debug for IngestStatus
sourceimpl Default for IngestStatus
impl Default for IngestStatus
sourcefn default() -> IngestStatus
fn default() -> IngestStatus
Returns the “default value” for a type. Read more
sourceimpl<'de> Deserialize<'de> for IngestStatus
impl<'de> Deserialize<'de> for IngestStatus
sourcefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
sourceimpl Serialize for IngestStatus
impl Serialize for IngestStatus
Auto Trait Implementations
impl RefUnwindSafe for IngestStatus
impl Send for IngestStatus
impl Sync for IngestStatus
impl Unpin for IngestStatus
impl UnwindSafe for IngestStatus
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more