Struct LivestreamSwarm 

pub struct LivestreamSwarm {
    pub stream_id: u64,
    pub config: SwarmConfig,
    pub state: SwarmState,
    pub authority: LivestreamAuthority,
    pub interest: LivestreamInterest,
    pub stats: SwarmStats,
    /* private fields */
}

Livestream swarm - complete system for a single livestream

Fields

stream_id: u64

Stream ID

config: SwarmConfig

Configuration

state: SwarmState

Current state

authority: LivestreamAuthority

Authority model

interest: LivestreamInterest

Interest tracking

stats: SwarmStats

Statistics

Implementations

impl LivestreamSwarm

pub fn new(stream_id: u64, broadcaster: NodeId, config: SwarmConfig) -> Self

Create a new livestream swarm

pub fn start(&mut self)

Start the stream

pub fn pause(&mut self)

Pause the stream

pub fn resume(&mut self)

Resume the stream

pub fn end(&mut self)

End the stream

pub fn add_viewer(&mut self, viewer: NodeId)

Add a viewer

pub fn remove_viewer(&mut self, viewer: NodeId)

Remove a viewer

pub fn viewer_count(&self) -> usize

Get viewer count

pub fn broadcaster(&self) -> NodeId

Get broadcaster

pub fn can_broadcast(&self, node: NodeId) -> bool

Check if a node can broadcast

pub fn create_update( &mut self, timestamp: StateTime, size: usize, is_keyframe: bool, ) -> StateUpdate

Create a state update for broadcasting

pub fn needs_keyframe(&self, current_time: StateTime) -> bool

Check if we need a keyframe

pub fn get_targets(&self) -> Vec<NodeId>

Get propagation targets for an update

Trait Implementations

impl Debug for LivestreamSwarm

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

Formats the value using the given formatter.