Struct HttpEventSink 

pub struct HttpEventSink { /* private fields */ }

Implementations

impl HttpEventSink

pub fn new( addr_server: &str, config: HttpSinkConfig, 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. Sends run on a dedicated tokio runtime, with up to config.max_in_flight_requests requests in flight concurrently, drained strictly in priority order (Metadata, Logs, Metrics, Traces).

Arguments

• addr_server - The address of the HTTP server to send data to.
• config - Transport configuration: byte budgets, concurrency, retries.
• 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.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

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 on_init_image_stream(&self, stream: &EventStream<EventBlock<ImageMsgQueue>>)

fn on_process_image_block(&self, block: Arc<EventBlock<ImageMsgQueue>>)

fn is_busy(&self) -> bool