Struct StreamEntry 

pub struct StreamEntry {
    pub gop_buffer: GopBuffer,
    pub video_header: Option<BroadcastFrame>,
    pub audio_header: Option<BroadcastFrame>,
    pub metadata: Option<BroadcastFrame>,
    pub publisher_id: Option<u64>,
    pub subscriber_count: AtomicU32,
    pub publisher_disconnected_at: Option<Instant>,
    pub created_at: Instant,
    pub state: StreamState,
    /* private fields */
}

Entry for a single stream in the registry

Fields

gop_buffer: GopBuffer

GOP buffer for late-joiner support

video_header: Option<BroadcastFrame>

Cached video sequence header for fast subscriber catchup

audio_header: Option<BroadcastFrame>

Cached audio sequence header for fast subscriber catchup

metadata: Option<BroadcastFrame>

Cached metadata

publisher_id: Option<u64>

Current publisher’s session ID (None if no publisher)

subscriber_count: AtomicU32

Number of active subscribers

publisher_disconnected_at: Option<Instant>

When the publisher disconnected (for grace period tracking)

created_at: Instant

When the stream was created

state: StreamState

Current stream state

Implementations

impl StreamEntry

pub fn subscriber_count(&self) -> u32

Get the number of subscribers

pub fn has_publisher(&self) -> bool

Check if the stream has an active publisher

pub fn get_catchup_frames(&self) -> Vec<BroadcastFrame>

Get catchup frames for a new subscriber

Returns sequence headers followed by GOP buffer contents.