Struct EventDetector 

pub struct EventDetector { /* private fields */ }

Monitors event activity and detects when polling fallback is needed

Implementations

impl EventDetector

pub fn new(event_timeout: Duration, polling_activation_delay: Duration) -> Self

Create a new EventDetector

pub fn set_firewall_coordinator( &mut self, coordinator: Arc<FirewallDetectionCoordinator>, )

Set the firewall coordinator (must be called during initialization)

pub fn set_polling_request_sender( &mut self, sender: UnboundedSender<PollingRequest>, )

Set the polling request sender

pub async fn record_event(&self, registration_id: RegistrationId)

Record that an event was received for a registration

pub async fn should_start_polling( &self, registration_id: RegistrationId, ) -> bool

Check if a registration should start polling based on event timeout

pub async fn should_stop_polling(&self, registration_id: RegistrationId) -> bool

Check if a registration should stop polling (events have resumed)

pub async fn evaluate_firewall_status( &self, registration_id: RegistrationId, pair: &SpeakerServicePair, ) -> Option<PollingRequest>

Evaluate firewall status and make immediate polling decision

pub async fn start_monitoring(&self) -> JoinHandle<()>

Start monitoring event activity for all registered subscriptions. Returns the JoinHandle for the spawned monitoring task.

pub async fn register_subscription( &self, registration_id: RegistrationId, pair: SpeakerServicePair, )

Register a new subscription for monitoring with its speaker/service pair

pub async fn unregister_subscription(&self, registration_id: RegistrationId)

Unregister a subscription from monitoring

pub async fn stats(&self) -> EventDetectorStats

Get monitoring statistics