weave-agentfs-mirror · progress

Reviewed implementation boundary: The mirror plan executor contains NotImplemented paths. A generated plan is not a successfully synchronized remote filesystem. See /libraries/agentfs-mirror/overview.

Source: sigil/weave/local/agentfs-mirror/src/progress.rs. SHA-256: 769feea9ea672578474b5555455cef6df5ede1445a2b680a3be465cb8e284aff.

This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.

progress::ProgressEvent

Progress event types

#[derive(Debug, Clone, Serialize)]
pub enum ProgressEvent {
    /// Sync started
    Started {
        total_files: usize,
        total_bytes: u64,
    },

    /// File transfer started
    FileStarted { path: PathBuf, size: u64 },

    /// File transfer progress
    FileProgress {
        path: PathBuf,
        bytes_transferred: u64,
        total_bytes: u64,
    },

    /// File transfer completed
    FileCompleted { path: PathBuf, success: bool },

    /// Directory created
    DirectoryCreated { path: PathBuf },

    /// Conflict detected
    ConflictDetected { path: PathBuf },

    /// Sync completed
    Completed { stats: crate::stats::SyncStats },

    /// Error occurred
    Error {
        path: Option<PathBuf>,
        message: String,
    },
}

Source line: 12.

progress::ProgressReporter

Progress reporter

pub struct ProgressReporter {

}

Source line: 49.

progress::ProgressReporter::new

Create a new progress reporter

pub fn new() -> Self;

Source line: 68.

progress::ProgressReporter::sender

Get event sender

pub fn sender(&self) -> mpsc::UnboundedSender<ProgressEvent>;

Source line: 91.

progress::ProgressReporter::start

Start progress display

pub async fn start(mut self);

Source line: 96.