Struct NewsEngineConfig 

pub struct NewsEngineConfig {
    pub servers: Arc<Mutex<Vec<ServerConfig>>>,
    pub article_timeout: Duration,
    pub max_concurrent_fetches: usize,
    pub work_channel_capacity: usize,
    pub outcome_channel_capacity: usize,
    pub probe_policy: Option<ServerProbePolicy>,
}

Configuration for NewsDispatchEngine. Mirrors the knobs exposed by the old engine so the swap is drop-in from the caller’s perspective.

servers is held as an Arc<Mutex<_>> so the caller (queue manager) can mutate it and DispatchEngine::reconcile_servers will pick up the new list without requiring a new config instance or a full engine rebuild.

Fields

servers: Arc<Mutex<Vec<ServerConfig>>>

article_timeout: Duration

max_concurrent_fetches: usize

work_channel_capacity: usize

outcome_channel_capacity: usize

probe_policy: Option<ServerProbePolicy>

Optional backup-server probe policy. Forwarded verbatim to nzb_news::DownloaderConfig::probe_policy.

None disables probing (every cascade article tries every server). Some(_) enables fast-fail on a backup server when the probed hit-rate falls below the threshold for that job.

Defaults to Some(ServerProbePolicy::default()) which matches the nzb-news default (probe 10 articles, require >=10% hits).

Implementations

impl NewsEngineConfig

pub fn new(servers: Vec<ServerConfig>, article_timeout: Duration) -> Self

Construct a config from an owned server list. Wraps the list in an Arc<Mutex<_>> internally; if the caller already owns a shared Arc (e.g. queue manager’s live server list), use NewsEngineConfig::with_shared_servers instead so mutations are visible to the engine.

pub fn with_shared_servers( servers: Arc<Mutex<Vec<ServerConfig>>>, article_timeout: Duration, ) -> Self

Construct a config sharing an existing Arc<Mutex<Vec<ServerConfig>>> with the caller. Mutating the Arc from outside and then calling DispatchEngine::reconcile_servers rebuilds the downloader with the latest server list — this is how live “add/remove server” operations reach the fetch layer.

Trait Implementations

impl Clone for NewsEngineConfig

fn clone(&self) -> NewsEngineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.