Struct SyncProgress 

pub struct SyncProgress {

    pub activities: StreamProgress,
    pub gpx: StreamProgress,
    pub health: StreamProgress,
    pub performance: StreamProgress,
    pub start_time: Instant,
    pub profile_name: Mutex<String>,
    pub date_range: Mutex<String>,
    pub latest_range: Mutex<Option<(String, String)>>,
    pub backfill_range: Mutex<Option<(String, String)>>,
    pub rate_history: Mutex<Vec<u32>>,
    pub total_requests: AtomicU32,
    pub errors: Mutex<Vec<ErrorEntry>>,
    pub storage_path: Mutex<String>,
    pub is_planning: AtomicBool,
    pub shutdown: AtomicBool,
    pub planning_step: Mutex<PlanningStep>,
    pub oldest_activity_date: Mutex<Option<String>>,
    /* private fields */
}

Overall sync progress across all streams

Fields

activities: StreamProgress

Activities stream progress

gpx: StreamProgress

GPX downloads progress

health: StreamProgress

Health data progress

performance: StreamProgress

Performance metrics progress

start_time: Instant

Start time for ETA calculation

profile_name: Mutex<String>

User profile name

date_range: Mutex<String>

Date range being synced (legacy, kept for compatibility)

latest_range: Mutex<Option<(String, String)>>

Latest sync date range (from -> to)

backfill_range: Mutex<Option<(String, String)>>

Backfill date range (frontier -> target, syncing backwards)

rate_history: Mutex<Vec<u32>>

Request rate history (last 60 seconds)

total_requests: AtomicU32

Total requests made

errors: Mutex<Vec<ErrorEntry>>

Error details for display

storage_path: Mutex<String>

Storage path for display

is_planning: AtomicBool

Whether we’re in planning phase

shutdown: AtomicBool

Whether shutdown has been requested

planning_step: Mutex<PlanningStep>

Current planning step

oldest_activity_date: Mutex<Option<String>>

Oldest activity date found during planning

Implementations

impl SyncProgress

pub fn new() -> Self

Create new sync progress tracker

pub fn set_planning_step(&self, step: PlanningStep)

Set planning step

pub fn get_planning_step(&self) -> PlanningStep

Get current planning step

pub fn finish_planning(&self)

Mark planning as complete

pub fn is_planning(&self) -> bool

Check if still planning

pub fn request_shutdown(&self)

Request that progress reporting shuts down

pub fn should_shutdown(&self) -> bool

Check if shutdown has been requested

pub fn set_oldest_activity_date(&self, date: &str)

Set oldest activity date found

pub fn get_oldest_activity_date(&self) -> Option<String>

Get oldest activity date

pub fn set_profile(&self, name: &str)

Set profile name

pub fn get_profile(&self) -> String

Get profile name

pub fn set_date_range(&self, from: &str, to: &str)

Set date range

pub fn get_date_range(&self) -> String

Get date range

pub fn set_sync_mode(&self, mode: SyncMode)

Set sync mode

pub fn get_sync_mode(&self) -> SyncMode

Get sync mode

pub fn set_latest_range(&self, from: &str, to: &str)

Set latest sync date range

pub fn get_latest_range(&self) -> Option<(String, String)>

Get latest sync date range

pub fn set_backfill_range(&self, frontier: &str, target: &str)

Set backfill date range (frontier -> target, syncing backwards)

pub fn get_backfill_range(&self) -> Option<(String, String)>

Get backfill date range

pub fn set_storage_path(&self, path: &str)

Set storage path

pub fn get_storage_path(&self) -> String

Get storage path

pub fn add_error(&self, stream: &'static str, item: String, error: String)

Add an error entry

pub fn get_errors(&self) -> Vec<ErrorEntry>

Get all errors

pub fn get_current_task(&self) -> Option<String>

Get current task description (finds first active stream)

pub fn record_request(&self)

Record a request for rate tracking

pub fn update_rate_history(&self)

Update rate history (call once per second)

pub fn requests_per_minute(&self) -> u32

Get rate per minute (average over last minute)

pub fn elapsed_str(&self) -> String

Get elapsed time as formatted string

pub fn eta_str(&self) -> String

Estimate time remaining

pub fn total_remaining(&self) -> u32

Get total items remaining across all streams

pub fn total_completed(&self) -> u32

Get total completed across all streams

pub fn total_failed(&self) -> u32

Get total failed across all streams

pub fn is_complete(&self) -> bool

Check if all streams are complete

pub fn print_simple_status(&self)

Print a status line for terminal progress reporting.

Trait Implementations

impl Default for SyncProgress

fn default() -> Self

Returns the “default value” for a type.