Struct UploadGroupProgress 

pub struct UploadGroupProgress {
    pub file_data: Arc<GroupProgress>,
    pub shards: Arc<ShardUploadProgress>,
}

Fields

file_data: Arc<GroupProgress>

shards: Arc<ShardUploadProgress>

Implementations

impl UploadGroupProgress

pub fn new() -> Self

Create a group progress tracker using default speed estimation parameters.

pub fn with_speed_config(half_life: Duration, min_observations: u32) -> Self

Create a group progress tracker with explicit speed estimation parameters.

pub fn new_item( self: &Arc<Self>, id: UniqueId, name: impl Into<Arc<str>>, ) -> Arc<ItemProgressUpdater>

Create a new tracked item and register it in the items map. Returns an ItemProgressUpdater handle for the caller to report progress.

pub fn report(&self) -> GroupProgressReport

Snapshot of aggregate data and shard upload progress.

pub fn item_reports(&self) -> HashMap<UniqueId, ItemProgressReport>

Snapshot of all per-item progress.

pub fn item_report(&self, id: UniqueId) -> Option<ItemProgressReport>

Snapshot of one item’s progress.

pub fn assert_complete(&self)

Debug verification that all items are complete.

pub fn register_shard_transfer(&self, shard_size: u64) -> UniqueId

Register a new shard upload size.

pub fn increment_shard_transfer_progress(&self, _id: UniqueId, nbytes: u64)

Update shard transfer bytes for transfer “_id”

pub fn decrement_shard_transfer_progress(&self, _id: UniqueId, nbytes: u64)

Undo previously reported shard transfer bytes for transfer “_id”.

pub fn register_shard_upload_progress( &self, id: UniqueId, event: &ShardUploadEvent, )

Update shard upload progress

Trait Implementations

impl Default for UploadGroupProgress

fn default() -> Self

Returns the “default value” for a type.