Struct FeedState 

pub struct FeedState { /* private fields */ }

Shared state for the feed system

This struct manages the broadcast channel and client tracking. It should be wrapped in Arc and shared across handlers.

Implementations

impl FeedState

pub fn new(capacity: usize) -> Self

Create a new FeedState with the specified channel capacity

Arguments

• capacity - Maximum number of events to buffer in the channel. Clients that fall behind will miss events.

pub fn subscribe(&self) -> Receiver<FeedEvent>

Subscribe to the event feed

Returns a receiver that will receive all events published after subscription.

pub fn publish(&self, event: FeedEvent) -> usize

Publish an event to all connected clients

Returns the number of clients that received the event. Returns 0 if no clients are connected.

pub fn publish_capture_received( &self, capture_id: impl Into<String>, url: impl Into<String>, capture_type: impl Into<String>, ) -> usize

Publish a capture_received event

pub fn publish_processing_complete( &self, capture_id: impl Into<String>, duration_ms: u64, size_bytes: u64, summary: Option<String>, ) -> usize

Publish a processing_complete event

pub fn publish_error( &self, capture_id: Option<String>, code: impl Into<String>, message: impl Into<String>, recoverable: bool, ) -> usize

Publish an error event

pub fn connected_clients(&self) -> u64

Get the number of connected clients

pub fn uptime_seconds(&self) -> u64

Get the server uptime in seconds

pub fn capacity(&self) -> usize

Get the channel capacity

Trait Implementations

impl Default for FeedState

fn default() -> Self

Returns the “default value” for a type.