Struct ReportTracker 

pub struct ReportTracker { /* private fields */ }

Per-connection tracker for paginated reports.

Created when the authenticated message loop starts, dropped when the connection closes. No shared or global state.

Implementations

impl ReportTracker

pub fn new() -> Self

Create a new empty tracker.

pub fn register_page( &mut self, report_id: Uuid, page: u32, total_pages: u32, ) -> Result<PageOutcome, WireValidationError>

Register a page of a paginated report.

Returns:

• Ok(PageOutcome::Pending) if more pages are expected.
• Ok(PageOutcome::Final { .. }) if all pages have now been received.
• Err(WireValidationError) if limits are violated (duplicate page, too many concurrent reports, total_pages mismatch, etc.).

The caller must process the page’s payload regardless of the outcome.

pub fn add_discovered_count(&mut self, report_id: Uuid, count: u32)

Add to the accumulated discovered_count for an in-progress report.

No-op if the report has already been finalized or does not exist.

pub fn evict_expired(&mut self)

Evict reports that have exceeded the total or idle timeout.

Called automatically by register_page. Can also be called periodically from a background task.

pub fn pending_count(&self) -> usize

Returns the number of currently pending reports.

Trait Implementations

impl Debug for ReportTracker

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

Formats the value using the given formatter.

impl Default for ReportTracker

fn default() -> Self

Returns the “default value” for a type.