Enum DownloadEvent 

pub enum DownloadEvent {
    QueueSnapshot {
        items: Vec<DownloadSummary>,
        max_size: u32,
    },
    DownloadStarted {
        id: String,
    },
    DownloadProgress {
        id: String,
        downloaded: u64,
        total: u64,
        speed_bps: f64,
        eta_seconds: f64,
        percentage: f64,
    },
    ShardProgress {
        id: String,
        shard_index: u32,
        total_shards: u32,
        shard_filename: String,
        shard_downloaded: u64,
        shard_total: u64,
        aggregate_downloaded: u64,
        aggregate_total: u64,
        speed_bps: f64,
        eta_seconds: f64,
        percentage: f64,
    },
    DownloadCompleted {
        id: String,
        message: Option<String>,
    },
    DownloadFailed {
        id: String,
        error: String,
    },
    DownloadCancelled {
        id: String,
    },
    QueueRunComplete {
        summary: QueueRunSummary,
    },
}

Single discriminated union for all download events.

The frontend handles this as a TypeScript discriminated union:

type DownloadEvent =
  | { type: "queue_snapshot"; items: DownloadSummary[]; max_size: number }
  | { type: "download_started"; id: string }
  | { type: "download_progress"; id: string; downloaded: number; total: number; ... }
  | { type: "shard_progress"; id: string; shard_index: number; ... }
  | { type: "download_completed"; id: string }
  | { type: "download_failed"; id: string; error: string }
  | { type: "download_cancelled"; id: string };

Variants

QueueSnapshot

Snapshot of the entire queue state.

Fields

items: Vec<DownloadSummary>

All items currently in the queue.

max_size: u32

Maximum queue capacity.

DownloadStarted

A download has started.

Fields

id: String

Canonical ID of the download.

DownloadProgress

Progress update for a non-sharded download.

Fields

id: String

Canonical ID of the download.

downloaded: u64

Bytes downloaded so far.

total: u64

Total bytes to download.

speed_bps: f64

Current download speed in bytes per second.

eta_seconds: f64

Estimated time remaining in seconds.

percentage: f64

Progress percentage (0.0 - 100.0).

ShardProgress

Progress update for a sharded download.

Fields

id: String

Canonical ID of the download (group ID).

shard_index: u32

Current shard index (0-based).

total_shards: u32

Total number of shards.

shard_filename: String

Filename of the current shard.

shard_downloaded: u64

Bytes downloaded for current shard.

shard_total: u64

Total bytes for current shard.

aggregate_downloaded: u64

Aggregate bytes downloaded across all shards.

aggregate_total: u64

Aggregate total bytes across all shards.

speed_bps: f64

Current download speed in bytes per second.

eta_seconds: f64

Estimated time remaining in seconds.

percentage: f64

Aggregate progress percentage (0.0 - 100.0).

DownloadCompleted

Download completed successfully.

Fields

id: String

Canonical ID of the download.

message: Option<String>

Optional success message.

DownloadFailed

Download failed with an error.

Fields

id: String

Canonical ID of the download.

error: String

Error message describing what went wrong.

DownloadCancelled

Download was cancelled by the user.

Fields

id: String

Canonical ID of the download.

QueueRunComplete

Queue run completed (all downloads in the queue finished).

Emitted when the download queue transitions from busy → idle, providing a complete summary of all artifacts that were processed during the run.

Fields

summary: QueueRunSummary

Complete summary of the queue run.

Implementations

impl DownloadEvent

pub const fn queue_snapshot(items: Vec<DownloadSummary>, max_size: u32) -> Self

Create a queue snapshot event.

pub fn started(id: impl Into<String>) -> Self

Create a download started event.

pub fn progress( id: impl Into<String>, downloaded: u64, total: u64, speed_bps: f64, ) -> Self

Create a non-sharded progress event.

pub fn shard_progress( id: impl Into<String>, shard_index: u32, total_shards: u32, shard_filename: impl Into<String>, shard_downloaded: u64, shard_total: u64, aggregate_downloaded: u64, aggregate_total: u64, speed_bps: f64, ) -> Self

Create a sharded progress event.

pub fn completed( id: impl Into<String>, message: Option<impl Into<String>>, ) -> Self

Create a download completed event.

pub fn failed(id: impl Into<String>, error: impl Into<String>) -> Self

Create a download failed event.

pub fn cancelled(id: impl Into<String>) -> Self

Create a download cancelled event.

pub const fn queue_run_complete(summary: QueueRunSummary) -> Self

Create a queue run complete event.

pub fn id(&self) -> Option<&str>

Get the download ID from any event type.

pub const fn event_name(&self) -> &'static str

Get the event name for wire protocols.

This provides consistent event naming for Tauri and SSE transports. Note: Both ShardProgress and DownloadProgress use “download:progress” as the channel name; differentiation happens via the type discriminator.

Trait Implementations

impl Clone for DownloadEvent

fn clone(&self) -> DownloadEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DownloadEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DownloadEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DownloadEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.