Struct StreamState 

pub struct StreamState {

    pub id: u32,
    pub mode: StreamMode,
    pub stream_key: Option<String>,
    pub publish_type: Option<String>,
    pub started_at: Option<Instant>,
    pub has_video_header: bool,
    pub has_audio_header: bool,
    pub has_metadata: bool,
    pub last_video_ts: u32,
    pub last_audio_ts: u32,
    pub video_frames: u64,
    pub audio_frames: u64,
    pub keyframes: u64,
    pub bytes_received: u64,
    pub gop_buffer: GopBuffer,
}

Per-stream state

Fields

id: u32

Message stream ID

mode: StreamMode

Current mode

stream_key: Option<String>

Stream key/name (for publish/play)

publish_type: Option<String>

Publish type (“live”, “record”, “append”)

started_at: Option<Instant>

Time when stream became active

has_video_header: bool

Whether we’ve received video sequence header

has_audio_header: bool

Whether we’ve received audio sequence header

has_metadata: bool

Whether we’ve received metadata

last_video_ts: u32

Last video timestamp

last_audio_ts: u32

Last audio timestamp

video_frames: u64

Video frames received

audio_frames: u64

Audio frames received

keyframes: u64

Keyframes received

bytes_received: u64

Total bytes received on this stream

gop_buffer: GopBuffer

GOP buffer for late-joiner support

Implementations

impl StreamState

pub fn new(id: u32) -> Self

Create a new stream state

pub fn start_publish(&mut self, stream_key: String, publish_type: String)

Start publishing on this stream

pub fn start_play(&mut self, stream_name: String)

Start playing on this stream

pub fn stop(&mut self)

Stop the stream

pub fn is_publishing(&self) -> bool

Check if stream is publishing

pub fn is_playing(&self) -> bool

Check if stream is playing

pub fn is_ready(&self) -> bool

Check if stream is ready (has required headers)

pub fn duration(&self) -> Option<Duration>

Get stream duration

pub fn on_video( &mut self, timestamp: u32, is_keyframe: bool, is_header: bool, size: usize, )

Update video state

pub fn on_audio(&mut self, timestamp: u32, is_header: bool, size: usize)

Update audio state

pub fn on_metadata(&mut self)

Mark metadata received

pub fn bitrate(&self) -> Option<u64>

Get bitrate estimate (bits per second)

Trait Implementations

impl Debug for StreamState

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

Formats the value using the given formatter.