Struct StreamProgress 

pub struct StreamProgress {
    pub name: &'static str,
    pub total: AtomicU32,
    pub completed: AtomicU32,
    pub failed: AtomicU32,
    pub is_dynamic: AtomicBool,
    /* private fields */
}

Progress tracking for a single data stream

Fields

name: &'static str

Display name for this stream

total: AtomicU32

Total items to process

completed: AtomicU32

Completed items

failed: AtomicU32

Failed items

is_dynamic: AtomicBool

Whether this stream’s total is discovered dynamically (pagination, etc.)

Implementations

impl StreamProgress

pub fn new(name: &'static str) -> Self

Create a new stream progress tracker

pub fn set_dynamic(&self, dynamic: bool)

Mark this stream as having a dynamically discovered total

pub fn is_dynamic(&self) -> bool

Check if this stream has a dynamic total

pub fn set_total(&self, total: u32)

Set the total count

pub fn add_total(&self, count: u32)

Add to total (for dynamic task generation like activities -> GPX)

pub fn complete_one(&self)

Increment completed count

pub fn fail_one(&self)

Increment failed count

pub fn set_last_item(&self, desc: String)

Set the last processed item description

pub fn get_last_item(&self) -> String

Get the last processed item description

pub fn set_current_item(&self, desc: String)

Set the current item being processed

pub fn get_current_item(&self) -> String

Get the current item being processed

pub fn clear_current_item(&self)

Clear the current item (when done processing)

pub fn percent(&self) -> u16

Get completion percentage (0-100)

pub fn is_complete(&self) -> bool

Check if this stream is complete

pub fn get_total(&self) -> u32

Get total count

pub fn get_completed(&self) -> u32

Get completed count

pub fn get_failed(&self) -> u32

Get failed count

Trait Implementations

impl Debug for StreamProgress

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.