Struct StreamGroup 

pub struct StreamGroup {
    pub name: String,
    pub stream_ids: Vec<StreamId>,
    /* private fields */
}

Group of streams to be aligned together

Fields

name: String

Name of this group

stream_ids: Vec<StreamId>

Stream IDs in this group

Implementations

impl StreamGroup

pub fn new(name: impl Into<String>) -> Self

Create a new empty stream group

pub fn add_stream(&mut self, id: StreamId)

Add a stream to the group

pub fn add_offset(&mut self, offset: StreamOffset)

Add a measured offset between two streams

pub fn len(&self) -> usize

Number of streams in the group

pub fn is_empty(&self) -> bool

Returns true if the group is empty

pub fn select_reference( &mut self, strategy: ReferenceStrategy, ) -> Option<StreamId>

Select reference stream using the given strategy

pub fn reference_id(&self) -> Option<StreamId>

Get the current reference stream

pub fn compute_bulk_offsets(&self) -> HashMap<StreamId, StreamOffset>

Compute bulk offsets for all streams relative to a given reference

pub fn compute_bulk_offsets_for_reference( &self, ref_id: StreamId, ) -> HashMap<StreamId, StreamOffset>

Compute bulk offsets for all streams relative to a specific reference

pub fn offsets(&self) -> &[StreamOffset]

Get all offsets in the group

Trait Implementations

impl Clone for StreamGroup

fn clone(&self) -> StreamGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamGroup

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

Formats the value using the given formatter.