Struct Stream 

pub struct Stream { /* private fields */ }

Priority data stream entity

Implementations

impl Stream

pub fn new( session_id: SessionId, source_data: JsonData, config: StreamConfig, ) -> Stream

Create new stream

pub fn id(&self) -> StreamId

Get stream ID

pub fn session_id(&self) -> SessionId

Get session ID

pub fn state(&self) -> &StreamState

Get current state

pub fn config(&self) -> &StreamConfig

Get configuration

pub fn stats(&self) -> &StreamStats

Get statistics

pub fn created_at(&self) -> DateTime<Utc>

Get creation timestamp

pub fn updated_at(&self) -> DateTime<Utc>

Get last update timestamp

pub fn completed_at(&self) -> Option<DateTime<Utc>>

Get completion timestamp

pub fn source_data(&self) -> Option<&JsonData>

Get source data

pub fn metadata(&self) -> &HashMap<String, String>

Get metadata

pub fn add_metadata(&mut self, key: String, value: String)

Add metadata

pub fn start_streaming(&mut self) -> Result<(), DomainError>

Start streaming (transition to Streaming state)

pub fn complete(&mut self) -> Result<(), DomainError>

Complete stream successfully

pub fn fail(&mut self, error: String) -> Result<(), DomainError>

Fail stream with error

pub fn cancel(&mut self) -> Result<(), DomainError>

Cancel stream

pub fn create_skeleton_frame(&mut self) -> Result<Frame, DomainError>

Generate skeleton frame for the stream

pub fn create_patch_frames( &mut self, priority_threshold: Priority, max_frames: usize, ) -> Result<Vec<Frame>, DomainError>

Create batch of patch frames based on priority

pub fn create_completion_frame( &mut self, checksum: Option<String>, ) -> Result<Frame, DomainError>

Create completion frame

pub fn is_active(&self) -> bool

Check if stream is active

pub fn is_finished(&self) -> bool

Check if stream is finished

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

Get stream duration

pub fn progress(&self) -> f64

Calculate stream progress (0.0 to 1.0)

pub fn update_config(&mut self, config: StreamConfig) -> Result<(), DomainError>

Update configuration

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Stream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Stream

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Stream

fn deserialize<__D>( __deserializer: __D, ) -> Result<Stream, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Stream

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.