class Logit::Backend::OTLP::BatchProcessor

• Logit::Backend::OTLP::BatchProcessor
• Reference
• Object

Overview

Batches events and flushes them periodically or when size threshold is reached.

The batch processor uses a background fiber for interval-based flushing and provides thread-safe event buffering.

Defined in:

logit/backends/otlp/batch_processor.cr

Constructors

• .new(batch_size : Int32, flush_interval : Time::Span, &on_flush : Array(Event) -> Nil)

Instance Method Summary

• #add(event : Event) : Nil

  Adds an event to the buffer.

• #flush : Nil

  Forces an immediate flush of buffered events.

• #start : Nil

  Starts the background flush fiber.

• #stop : Nil

  Stops the batch processor and flushes remaining events.

Constructor Detail

Instance Method Detail