pub struct BulkProgress {
pub written: usize,
pub total: usize,
pub rows: usize,
pub held: Duration,
}Expand description
One chunk’s worth of progress, handed to the callback on
BulkControl::on_progress (0.13.8, W7.6).
Reported after the chunk has committed, so written is a count of rows
that are in the database and will stay there even if the next chunk fails.
Fields§
§written: usizeRows committed so far, across every chunk including this one.
total: usizeRows in the batch the caller passed. written reaching this means the
last chunk has committed.
rows: usizeRows this chunk wrote. Not a constant: the loop resizes chunks against
CHUNK_BUDGET as it measures them (D-058).
held: DurationHow long the actor held the write lock for this chunk — the same figure the controller steers on. Measured inside the actor, around its own transaction, so it excludes the time the command spent queued.
Trait Implementations§
Source§impl Clone for BulkProgress
impl Clone for BulkProgress
Source§fn clone(&self) -> BulkProgress
fn clone(&self) -> BulkProgress
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 moreimpl Copy for BulkProgress
Source§impl Debug for BulkProgress
impl Debug for BulkProgress
impl Eq for BulkProgress
Source§impl PartialEq for BulkProgress
impl PartialEq for BulkProgress
impl StructuralPartialEq for BulkProgress
Auto Trait Implementations§
impl Freeze for BulkProgress
impl RefUnwindSafe for BulkProgress
impl Send for BulkProgress
impl Sync for BulkProgress
impl Unpin for BulkProgress
impl UnsafeUnpin for BulkProgress
impl UnwindSafe for BulkProgress
Blanket Implementations§
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,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request