subscription-proxy-pool 0.1.0

Subscription-backed HTTP and SOCKS proxy pools with caching, health checks, and request-count or time-based rotation
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

/// Result for an individual subscription source.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum SourceOutcome {
    /// A new successful HTTP response replaced the source's nodes.
    Updated,
    /// HTTP 304 confirmed the existing nodes; no body download was needed.
    NotModified,
    /// Startup used a fresh disk cache without contacting the source.
    FreshCache,
    /// A failed fetch fell back to a still-allowed disk cache.
    StaleCache,
    /// A failed fetch retained the source's running in-memory nodes.
    Retained,
    /// No source data could be loaded.
    Failed,
}

/// Per-source diagnostics. Keys are hashes; URLs and credentials are omitted.
#[derive(Clone, Debug)]
pub struct SourceReport {
    /// Stable hash returned by SubscriptionSource::key().
    pub source_key: String,
    /// How this source was resolved.
    pub outcome: SourceOutcome,
    /// Number of usable nodes in this source, before cross-source deduplication.
    pub nodes: usize,
    /// Sanitized remote error, if this update failed.
    pub error: Option<String>,
    /// Sanitized cache I/O error, if caching failed.
    pub cache_error: Option<String>,
}

/// Last completed refresh, available after build and background refresh too.
#[derive(Clone, Debug, Default)]
pub struct RefreshReport {
    /// Unique nodes in the resulting pool.
    pub nodes: usize,
    /// Sources with changed, successfully parsed content.
    pub updated_sources: usize,
    /// Sources confirmed by HTTP 304.
    pub not_modified_sources: usize,
    /// Sources restored from disk.
    pub cached_sources: usize,
    /// Failed remote sources, including those with successful fallback.
    pub failed_sources: usize,
    /// Unsupported, duplicate or invalid parsed nodes.
    pub skipped_nodes: usize,
    /// Cache reads that failed due to filesystem errors.
    pub cache_read_failures: usize,
    /// Cache writes that failed after successful remote validation.
    pub cache_write_failures: usize,
    /// Details for each configured subscription, in configuration order.
    pub sources: Vec<SourceReport>,
}