Enum PipelineEvent 

pub enum PipelineEvent {
    FileDiscovered {
        path: String,
        size: u64,
    },
    FileProcessed {
        path: String,
        shard_id: u64,
    },
    ShardCreated {
        cid: String,
        size: u64,
        file_count: usize,
    },
    ShardFetched {
        cid: String,
        source: FetchSource,
    },
    Progress {
        stage: String,
        current: u64,
        total: u64,
    },
    Warning {
        message: String,
    },
    Error {
        message: String,
        recoverable: bool,
    },
}

Events emitted during pipeline operations (seal/unseal).

Variants

FileDiscovered

A file was discovered during workspace traversal.

Fields

path: String

Path to the discovered file.

size: u64

Size of the file in bytes.

FileProcessed

A file was processed (compressed, encrypted, or written).

Fields

path: String

Path to the processed file.

shard_id: u64

ID of the shard containing the file.

ShardCreated

A shard was created and stored.

Fields

cid: String

CID of the created shard.

size: u64

Size of the shard in bytes.

file_count: usize

Number of files in the shard.

ShardFetched

A shard was fetched from storage.

Fields

cid: String

CID of the fetched shard.

source: FetchSource

Source from which the shard was fetched.

Progress

Progress update for long-running operations.

Fields

stage: String

Current stage name.

current: u64

Current progress value.

total: u64

Total expected value.

Warning

Non-fatal warning during operation.

Fields

message: String

Warning message.

Error

Error occurred (may or may not be recoverable).

Fields

message: String

Error message.

recoverable: bool

Whether the error is recoverable.

Trait Implementations

impl Clone for PipelineEvent

fn clone(&self) -> PipelineEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineEvent

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

Formats the value using the given formatter.