Struct DownloadCommand 

pub struct DownloadCommand { /* private fields */ }

Implementations

impl DownloadCommand

pub fn new( gid: GroupId, uri: &str, options: &DownloadOptions, output_dir: Option<&str>, output_name: Option<&str>, ) -> Result<Self>

Create a DownloadCommand with a standalone RequestGroup (not registered in RequestGroupMan). Use this for simple CLI/test scenarios where external progress queries are not needed.

pub fn new_with_group( group: Arc<RwLock<RequestGroup>>, uri: &str, options: &DownloadOptions, output_dir: Option<&str>, output_name: Option<&str>, ) -> Result<Self>

Create a DownloadCommand with a shared RequestGroup Arc (registered in RequestGroupMan). Use this for RPC and CLI paths where external progress queries are needed.

pub fn new_with_client( gid: GroupId, uri: &str, options: &DownloadOptions, output_dir: Option<&str>, output_name: Option<&str>, client: Arc<Client>, ) -> Result<Self>

Create a DownloadCommand with a custom HTTP client and standalone group.

pub fn new_with_group_and_client( group: Arc<RwLock<RequestGroup>>, uri: &str, options: &DownloadOptions, output_dir: Option<&str>, output_name: Option<&str>, client: Arc<Client>, ) -> Result<Self>

Create a DownloadCommand with a shared group Arc and custom HTTP client.

pub fn new_with_stat_man( gid: GroupId, uri: &str, options: &DownloadOptions, output_dir: Option<&str>, output_name: Option<&str>, stat_man: Arc<ServerStatMan>, ) -> Result<Self>

Create a DownloadCommand with a shared ServerStatMan.

This allows multiple downloads to share server performance statistics, enabling intelligent mirror selection based on historical data.

pub fn enable_perf_monitor(&mut self)

Enable performance monitoring for this download.

This adds minimal overhead (< 1%) to track throughput, latency, memory, and lock wait times.

pub fn get_perf_metrics(&self) -> Metrics

Get performance metrics snapshot (low-overhead, always available)

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

Get performance report if monitoring is enabled

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

Get performance report in JSON format if monitoring is enabled

pub async fn group(&self) -> RwLockReadGuard<'_, RequestGroup>

pub async fn group_mut(&self) -> RwLockWriteGuard<'_, RequestGroup>

pub fn no_proxy_matcher(&self) -> Option<&NoProxyMatcher>

Get the NoProxy matcher for checking if a host should bypass proxy

pub fn stat_man(&self) -> &Arc<ServerStatMan>

Get a reference to the server statistics manager.

Trait Implementations

impl Command for DownloadCommand

fn execute<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn status(&self) -> CommandStatus

fn timeout(&self) -> Option<Duration>

fn started_at(&self) -> Option<Instant>

Returns the instant at which this command started executing, if the engine has informed the command via [set_started_at].

fn set_started_at(&mut self, _instant: Instant)

Called by the engine immediately before the command is spawned onto a background task. The default implementation is a no-op; commands that store the instant can expose it through [started_at].