Struct EventStream 

pub struct EventStream<Block> { /* private fields */ }

EventStream are a sequence of blocks sent (or dropped) as they become full

Implementations

impl<Block> EventStream<Block>

where Block: TracingBlock,

pub fn new( buffer_size: usize, process_id: Uuid, tags: &[String], properties: HashMap<String, String>, ) -> EventStream<Block>

pub fn desc(&self) -> Arc<StreamDesc>

pub fn stream_id(&self) -> Uuid

pub fn set_full(&mut self)

pub fn replace_block(&mut self, new_block: Arc<Block>) -> Arc<Block>

pub fn is_full(&self) -> bool

pub fn is_empty(&self) -> bool

pub fn get_block_ref(&self) -> &Block

pub fn get_events_mut(&mut self) -> &mut <Block as TracingBlock>::Queue

pub fn process_id(&self) -> Uuid

pub fn tags(&self) -> &[String]

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

Trait Implementations

impl<Block> Debug for EventStream<Block>

where Block: Debug,

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

Formats the value using the given formatter.