Struct DataIntegrityAuditor 

pub struct DataIntegrityAuditor {
    pub config: AuditConfig,
    pub checksums: HashMap<String, BlockChecksum>,
    pub repair_history: VecDeque<RepairRecord>,
    pub total_audited: u64,
    pub total_passed: u64,
    pub total_failed: u64,
}

Proactive data integrity auditing system.

Continuously verifies stored blocks using configurable checksum algorithms, detects silent corruption, and tracks repair history.

Fields

config: AuditConfig

Configuration.

checksums: HashMap<String, BlockChecksum>

Map from CID → stored checksum record.

repair_history: VecDeque<RepairRecord>

Bounded ring of repair records (newest at the back).

total_audited: u64

Total audit operations performed.

total_passed: u64

Total audits that produced a Passed result.

total_failed: u64

Total audits that produced a Failed result.

Implementations

impl DataIntegrityAuditor

pub fn new(config: AuditConfig) -> Self

Create a new auditor with the supplied configuration.

pub fn compute_checksum(data: &[u8], algo: &ChecksumAlgo) -> u32

Compute a checksum over data using algo.

pub fn compute_crc32(data: &[u8]) -> u32

CRC-32 (Castagnoli, polynomial 0xEDB88320).

pub fn compute_adler32(data: &[u8]) -> u32

Adler-32.

pub fn compute_fnv_xor64(data: &[u8]) -> u32

FNV-1a 64-bit → 32-bit via XOR folding.

pub fn register_block(&mut self, cid: String, data: &[u8], now: u64)

Compute the block’s checksum and store it, overwriting any prior record.

Parameters

• cid — content identifier.
• data — raw block bytes.
• now — current Unix timestamp (seconds).

pub fn audit_block(&mut self, cid: &str, data: &[u8]) -> AuditResult

Audit a single block: recompute its checksum and compare with the stored value.

Updates total_audited, total_passed, and total_failed. If config.auto_repair is true and the check fails, a repair is automatically scheduled (with source = "auto" and detected_at = 0).

pub fn audit_batch(&mut self, blocks: &[(String, Vec<u8>)]) -> Vec<AuditResult>

Audit a batch of blocks, respecting config.audit_batch_size.

Processes at most audit_batch_size entries and returns one AuditResult per processed block.

pub fn schedule_repair(&mut self, cid: String, now: u64, source: String)

Record a repair request for cid.

Pushes a new RepairRecord with repaired_at = None to the back of the history ring. If the ring exceeds max_repair_history the oldest entry is evicted from the front.

pub fn mark_repaired(&mut self, cid: &str, now: u64) -> bool

Mark the most-recently scheduled (still-pending) repair for cid as completed.

Scans the history from newest to oldest. Returns true if a pending record was found and updated, false otherwise.

pub fn integrity_rate(&self) -> f64

Ratio of passed audits to total audits. Returns 0.0 when nothing has been audited yet.

pub fn pending_repairs(&self) -> Vec<&RepairRecord>

All repair records for which repaired_at.is_none().

pub fn auditor_stats(&self) -> AuditorStats

Snapshot of the current auditor statistics.

Trait Implementations

impl Debug for DataIntegrityAuditor

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

Formats the value using the given formatter.