marple-db 0.2.1

Rust SDK for the MarpleDB API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

/// Receives byte-position updates from long-running transfers.
///
/// ```
/// use marple_db::ProgressReporter;
/// use std::sync::atomic::{AtomicU64, Ordering};
///
/// struct Counter(AtomicU64);
///
/// impl ProgressReporter for Counter {
///     fn set_position(&self, position: u64) {
///         self.0.store(position, Ordering::Relaxed);
///     }
///
///     fn finish(&self) {}
/// }
/// ```
pub trait ProgressReporter: Send + Sync + 'static {
    /// Sets the current byte position.
    fn set_position(&self, position: u64);

    /// Marks the transfer as finished.
    fn finish(&self);
}

/// Progress reporter that ignores all updates.
#[derive(Clone, Copy, Debug, Default)]
pub struct NoopProgress;

impl ProgressReporter for NoopProgress {
    fn set_position(&self, _position: u64) {}

    fn finish(&self) {}
}