Struct EventBlock 

pub struct EventBlock<Q>
where
    Q: ExtractDeps,
{
    pub process_id: Uuid,
    pub stream_id: Uuid,
    pub begin: DualTime,
    pub events: Q,
    pub end: Option<DualTime>,
    pub event_offset: usize,
    pub dyn_deps: DynDeps<<Q as ExtractDeps>::DepsQueue>,
}

Blocks are a batch of events sent as a unit

Fields

process_id: Uuid

stream_id: Uuid

begin: DualTime

events: Q

end: Option<DualTime>

event_offset: usize

dyn_deps: DynDeps<<Q as ExtractDeps>::DepsQueue>

Dependency records for the dynamic property sets and dynamic strings that events refer to by id, inserted by log, metrics and thread dispatch.

Implementations

impl<Q> EventBlock<Q>

where Q: HeterogeneousQueue + ExtractDeps,

pub fn close(&mut self)

pub fn close_at(&mut self, end: DualTime)

Close this block with an already-stamped DualTime, so that it can be the same value used as the replacement block’s begin — making block[k].end == block[k+1].begin true by construction. Used by the four dispatch.rs flush paths; close() is retained for standalone callers (benches/tests) that swap no stream and so have no shared timestamp to pass.

Trait Implementations

impl<Q> Debug for EventBlock<Q>

where Q: Debug + ExtractDeps, <Q as ExtractDeps>::DepsQueue: Debug,

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

Formats the value using the given formatter.

impl StreamBlock for EventBlock<ImageMsgQueue>

fn encode_bin(&self, process_info: &ProcessInfo) -> Result<Vec<u8>, Error>

Encodes the stream block into a binary format.

impl StreamBlock for EventBlock<LogMsgQueue>

fn encode_bin(&self, process_info: &ProcessInfo) -> Result<Vec<u8>, Error>

Encodes the stream block into a binary format.

impl StreamBlock for EventBlock<MetricsMsgQueue>

fn encode_bin(&self, process_info: &ProcessInfo) -> Result<Vec<u8>, Error>

Encodes the stream block into a binary format.

impl StreamBlock for EventBlock<ThreadEventQueue>

fn encode_bin(&self, process_info: &ProcessInfo) -> Result<Vec<u8>, Error>

Encodes the stream block into a binary format.

impl<Q> TracingBlock for EventBlock<Q>

where Q: HeterogeneousQueue + ExtractDeps,

type Queue = Q

fn new( buffer_size: usize, process_id: Uuid, stream_id: Uuid, event_offset: usize, ) -> EventBlock<Q>

fn len_bytes(&self) -> usize

fn capacity_bytes(&self) -> usize

fn nb_objects(&self) -> usize

fn object_offset(&self) -> usize

fn events_mut(&mut self) -> &mut <EventBlock<Q> as TracingBlock>::Queue

fn hint_max_obj_size(&self) -> usize