Struct InMemorySink 

pub struct InMemorySink {
    pub state: Mutex<MemSinkState>,
}

for tests where we want to inspect the collected data

Fields

state: Mutex<MemSinkState>

Implementations

impl InMemorySink

pub fn new() -> InMemorySink

impl InMemorySink

pub fn thread_block_count(&self) -> usize

Get the total number of thread blocks collected

pub fn log_block_count(&self) -> usize

Get the total number of log blocks collected

pub fn metrics_block_count(&self) -> usize

Get the total number of metrics blocks collected

pub fn total_thread_events(&self) -> usize

Get the total number of events across all thread blocks

pub fn total_log_events(&self) -> usize

Get the total number of events across all log blocks

pub fn total_metrics_events(&self) -> usize

Get the total number of events across all metrics blocks

Trait Implementations

impl Default for InMemorySink

fn default() -> InMemorySink

Returns the “default value” for a type.

impl EventSink for InMemorySink

fn on_startup(&self, process_info: Arc<ProcessInfo>)

fn on_shutdown(&self)

fn on_log_enabled(&self, _metadata: &LogMetadata<'_>) -> bool

fn on_log( &self, _desc: &LogMetadata<'_>, _properties: &[Property], _time: i64, _args: Arguments<'_>, )

fn on_init_log_stream(&self, log_stream: &EventStream<EventBlock<LogMsgQueue>>)

fn on_process_log_block(&self, log_block: Arc<EventBlock<LogMsgQueue>>)

fn on_init_metrics_stream( &self, metrics_stream: &EventStream<EventBlock<MetricsMsgQueue>>, )

fn on_process_metrics_block( &self, metrics_block: Arc<EventBlock<MetricsMsgQueue>>, )

fn on_init_thread_stream( &self, thread_stream: &EventStream<EventBlock<ThreadEventQueue>>, )

fn on_process_thread_block( &self, thread_block: Arc<EventBlock<ThreadEventQueue>>, )

fn is_busy(&self) -> bool