Struct EdgePopCoverage 

pub struct EdgePopCoverage {
    pub schema_version: u32,
    pub entries: BTreeMap<String, EgressTargetPops>,
    /* private fields */
}

Coverage map keyed by (egress_label, target_host).

The composite key is encoded as egress_label \u{1F} target_host (ASCII unit separator). BTreeMap over the joined key gives stable iteration order for deterministic save/load. Operators read the map via pops_for / uncovered_pops without seeing the internal key encoding.

Fields

schema_version: u32

Schema version of the on-disk format.

entries: BTreeMap<String, EgressTargetPops>

(egress_label, target_host) → observed POPs.

Implementations

impl EdgePopCoverage

pub fn new() -> Self

Construct an empty map at the current schema version.

pub fn set_exhaustion_threshold(&mut self, n: usize)

Override the exhaustion threshold. Useful for tests, or for operators on extremely well-distributed proxy pools.

pub fn exhaustion_threshold(&self) -> usize

Current exhaustion threshold.

pub fn record(&mut self, egress: &str, target: &str, pop_raw: &str) -> bool

Record that we observed pop (must be a valid IATA-style string — pass the raw signal.edge_pop from parse_cf_block). Returns true if the POP was newly observed for this (egress, target), false if already known.

Invalid POP strings (wrong length, non-letter) increment total_probes but don’t add to the set — they’re noise from non-CF responses (origin direct, captive portals, etc).

pub fn record_no_pop(&mut self, egress: &str, target: &str)

Record a probe with NO POP observed (e.g. timeout, non-CF edge, raw TCP error). Updates only the probe counter.

pub fn pops_for(&self, egress: &str, target: &str) -> BTreeSet<String>

Look up observed POPs for this pair. Returns an empty set if the pair has never been probed.

pub fn probes_for(&self, egress: &str, target: &str) -> u64

Total probes recorded for this pair. Zero if never probed.

pub fn is_exhausted(&self, egress: &str, target: &str) -> bool

True if (egress, target) has hit at least exhaustion_threshold distinct POPs and is unlikely to surface more without major IP rotation.

pub fn pops_covered_for_target(&self, target: &str) -> BTreeSet<String>

All POPs seen across every egress for this target. Used to answer “what’s the union of CF POPs our hunt has touched for target.example”.

pub fn pops_covered_global(&self) -> BTreeSet<String>

All POPs seen across every (egress, target). Useful for the global “we touched N distinct POPs this hunt round” headline.

pub fn egress_labels(&self) -> BTreeSet<String>

All egress labels we have data for. Stable order (BTreeMap iteration).

pub fn rank_egresses_for_discovery(&self, target: &str) -> Vec<(String, usize)>

Egress entries that are NOT yet exhausted for target — these are the candidates the hunt loop should prioritize for new probes, sorted ascending by current POP count so we favor entries with the most room to grow.

pub fn save_atomic(&self, path: &Path) -> Result<()>

Persist atomically via tempfile + rename. The on-disk format is JSON for human-readable diffs across hunt sessions.

R55 pass-19 I4 (CLAUDE.md §7 DEDUP): delegates to wafrift_types::loaders::write_atomic so the atomic-write recipe lives in one place. Pre-fix: 3 evolution modules each rolled their own.

pub fn load_or_default(path: &Path) -> Self

Load from disk; on missing file or corrupt JSON return default(). Same forgiveness contract as rule_corpus::load_or_default — operator data is precious but a corrupt coverage map shouldn’t crash a hunt round.

Trait Implementations

impl Clone for EdgePopCoverage

fn clone(&self) -> EdgePopCoverage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EdgePopCoverage

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

Formats the value using the given formatter.

impl Default for EdgePopCoverage

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EdgePopCoverage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EdgePopCoverage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.