Struct TransportSelector 

pub struct TransportSelector { /* private fields */ }

Transport selector for DORS.

This struct implements the intelligent transport selection algorithm that chooses between Internet, BLE, and Wi-Fi Direct based on network conditions.

Implementations

impl TransportSelector

pub fn new() -> Self

Creates a new transport selector with default configuration.

pub fn with_config(config: DorsConfig) -> Self

Creates a new transport selector with custom configuration.

pub fn select_transport( &mut self, message: &Message, available_transports: &HashMap<TransportType, TransportMetrics>, ) -> Option<TransportType>

Selects the best transport for sending a message.

Arguments

• message - The message to send
• available_transports - Available transport types and their metrics

Returns

Returns the recommended transport type.

pub fn score_and_rank( &self, message: &Message, available_transports: &HashMap<TransportType, TransportMetrics>, ) -> Vec<(TransportType, f32)>

Scores all available transports and returns them ranked by score (descending).

Unlike select_transport, this is read-only: it does not record metrics, update history, or mutate selector state. It is used by TransportManager::send() to build a fallback list when the primary transport’s send fails — at that point select_transport has already recorded the state for this scoring cycle.

Important: This method reads transport_history for reliability and load scores but does not update it. If called independently of a prior select_transport in the same cycle, the scores may reflect stale history. Always call select_transport first in any given scoring cycle.

pub fn score_and_rank_detailed( &self, message: &Message, available_transports: &HashMap<TransportType, TransportMetrics>, ) -> Vec<(TransportType, TransportScore)>

Diagnostic variant of Self::score_and_rank that returns the full seven-factor TransportScore per transport rather than just the total. Used by telemetry consumers that opted into routing_diagnostic.

Sorted descending by total; ties resolve via the same priority (Internet > WiFiDirect > BLE) used by selection. Identical read-only guarantees as score_and_rank.

pub fn record_retry_failure(&mut self, transport_type: TransportType)

Records a retry failure for a transport. Uses saturating addition to prevent overflow.

pub fn reset_retry_count(&mut self, transport_type: TransportType)

Resets retry count for a transport (e.g., after successful delivery).

pub fn escalation_trigger_reason(&self) -> Option<EscalationTriggerReason>

Returns which condition triggered escalation, if any.

Returns None when battery is too low (escalation suppressed) or when no escalation condition is active.

pub fn should_escalate_to_wifi(&self) -> bool

Checks if escalation from BLE to Wi-Fi Direct is needed.

pub fn should_escalate_to_wifi_for_priority( &self, priority: MessagePriority, ) -> bool

Checks if WiFi escalation is appropriate for a message with given priority.

For Critical priority messages, battery constraints are bypassed since message delivery is more important than battery preservation.

pub fn update_config(&mut self, config: DorsConfig)

Replaces the configuration while preserving accumulated state (history, retry counts, signal tracking, score history).

pub fn config(&self) -> &DorsConfig

Returns the configuration scoring actually runs against.

This selector — not ProtocolConfig::dors, which is read once at construction — is the live consumer, so this is the honest place to confirm a runtime update landed.

pub fn current_transport(&self) -> Option<TransportType>

Gets the current transport.

pub fn set_current_transport(&mut self, transport: TransportType)

Updates the current transport tracked by the selector.

Used by TransportManager when a fallback transport succeeds so that subsequent select_transport calls apply hysteresis against the transport that actually carried the last message. Also resets the switch cooldown timer so the next selection uses a full cooldown window measured from this fallback, not from the original primary selection.

The caller is responsible for ensuring transport is currently available. Setting a transport that has since become unavailable is safe — select_transport handles the !current_still_available case — but may cause one wasted hysteresis evaluation.

Trait Implementations

impl Default for TransportSelector

fn default() -> Self

Returns the “default value” for a type.