Struct SendErrorTracker 

pub struct SendErrorTracker { /* private fields */ }

Production-grade send error tracker with per-channel state.

Thread-safe — uses DashMap for per-channel state and atomics for global counters.

Implementations

impl SendErrorTracker

pub fn new(config: SendErrorTrackerConfig) -> Self

Create a new tracker with the given configuration.

pub fn with_defaults() -> Self

Create a tracker with default configuration.

pub fn is_enabled(&self) -> bool

Check if the tracker is enabled.

pub fn config(&self) -> &SendErrorTrackerConfig

Get the configuration.

pub fn on_send_success(&self, channel_id: u8)

Record a successful send for a channel.

pub fn on_send_failure( &self, channel_id: u8, category: ErrorCategory, ) -> TrackingResult

Record a send failure for a channel.

Returns a TrackingResult indicating whether any threshold was exceeded.

pub fn on_ack_error(&self, channel_id: u8, _status: u8) -> TrackingResult

Record an ACK error.

pub fn on_ack_timeout(&self, channel_id: u8) -> TrackingResult

Record an ACK timeout.

pub fn on_confirmation_nack(&self, channel_id: u8) -> TrackingResult

Record a confirmation NACK.

pub fn on_confirmation_timeout(&self, channel_id: u8) -> TrackingResult

Record a confirmation timeout.

pub fn on_flow_control_drop(&self, channel_id: u8) -> TrackingResult

Record a flow control drop.

pub fn consecutive_errors(&self, channel_id: u8) -> u32

Get the consecutive error count for a channel.

pub fn window_error_count(&self, channel_id: u8) -> usize

Get the error count in the current sliding window for a channel.

pub fn is_restart_triggered(&self, channel_id: u8) -> bool

Check if a channel has triggered a restart.

pub fn reset_channel(&self, channel_id: u8)

Reset error state for a channel.

pub fn remove_channel(&self, channel_id: u8)

Remove a channel’s tracking state entirely.

pub fn channel_summary(&self, channel_id: u8) -> Option<ChannelErrorSummary>

Get a summary for a specific channel.

pub fn stats_snapshot(&self) -> TrackerStatsSnapshot

Get global statistics.

Trait Implementations

impl Debug for SendErrorTracker

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

Formats the value using the given formatter.

impl Default for SendErrorTracker

fn default() -> Self

Returns the “default value” for a type.