nzb-dispatch 0.2.4

Article-level dispatcher: per-server worker pool, priority gating, retry + hopeless tracking. Part of the nzb-* layered usenet engine.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! nzb-dispatch — article-level download dispatcher for the nzb-* engine.
//!
//! Responsibilities:
//! - Per-server worker pool (spawn/retire workers as server config changes)
//! - Priority-aware article-fetch scheduling with retry across servers
//! - Connection tracking, circuit breaker, byte-level heartbeat
//! - Job context lifecycle (register on submit, drain on completion)
//! - Hopeless-job detection hooks exposed via progress events
//!
//! Boundary: the [`dispatch_engine::DispatchEngine`] trait is the contract
//! consumed by the job queue / orchestrator layer. Progress is reported
//! back via a `mpsc::Sender<dispatch_engine::ProgressUpdate>` channel per job.
//!
//! This crate does NOT own job persistence, post-processing, or the public
//! HTTP API. Those live in `nzb-queue`, `nzb-postproc`, and `nzb-engine`.

pub mod article_failure;
pub mod bandwidth;
pub mod dispatch_engine;
pub mod download_engine;
pub mod news_engine;
pub mod util;

pub use news_engine::{NewsDispatchEngine, NewsEngineConfig};

// Re-export the underlying probe-policy type so downstream crates (nzb-web,
// Arz, ...) can configure it without depending on nzb-news directly.
pub use nzb_news::ServerProbePolicy;

// Convenience re-exports — the types downstream crates reach for.
pub use article_failure::{ArticleFailure, ArticleFailureKind};
pub use bandwidth::{BandwidthConfig, BandwidthLimiter};
pub use dispatch_engine::{DispatchEngine, DispatchHandle};
pub use download_engine::{
    ConnectionSlot, ConnectionTracker, ProgressUpdate, ServerHealth, SlotStatus, WorkerPool,
};