Struct HttpEventSink 

pub struct HttpEventSink { /* private fields */ }

Implementations

impl HttpEventSink

pub fn new( addr_server: &str, max_queue_size: isize, metadata_retry: Take<ExponentialBackoff>, blocks_retry: Take<ExponentialBackoff>, make_decorator: Box<dyn FnOnce() -> Arc<dyn RequestDecorator> + Send>, ) -> HttpEventSink

Creates a new HttpEventSink.

This function spawns a new thread that handles sending telemetry data to the specified HTTP server.

Arguments

• addr_server - The address of the HTTP server to send data to.
• max_queue_size - The maximum number of events to queue before dropping them.
• metadata_retry - The retry strategy for sending metadata (process info, stream info).
• blocks_retry - The retry strategy for sending blocks (log, metrics, thread).
• make_decorator - A closure that returns a RequestDecorator for modifying HTTP requests.

Trait Implementations

impl Drop for HttpEventSink

fn drop(&mut self)

Executes the destructor for this type.

impl EventSink for HttpEventSink

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

fn on_shutdown(&self)

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

fn on_log( &self, _metadata: &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