Copyright	(c) Ian Duncan 2021
License	BSD-3
Maintainer	Ian Duncan
Stability	experimental
Portability	non-portable (GHC extensions)
Safe Haskell	None
Language	Haskell2010

OpenTelemetry.Processor.Batch

Description

This is an implementation of the Span Processor which create batches of finished spans and passes the export-friendly span data representations to the configured Exporter.

Synopsis

data BatchTimeoutConfig = BatchTimeoutConfig {
- maxQueueSize :: Int
- scheduledDelayMillis :: Int
- exportTimeoutMillis :: Int
- maxExportBatchSize :: Int
}
batchTimeoutConfig :: BatchTimeoutConfig
batchProcessor :: MonadIO m => BatchTimeoutConfig -> Exporter ImmutableSpan -> m Processor

Documentation

data BatchTimeoutConfig Source #

Configurable options for batch exporting frequence and size

Constructors

BatchTimeoutConfig

Fields

maxQueueSize :: Int
The maximum queue size. After the size is reached, spans are dropped.
scheduledDelayMillis :: Int
The delay interval in milliseconds between two consective exports. The default value is 5000.
exportTimeoutMillis :: Int
How long the export can run before it is cancelled. The default value is 30000.
maxExportBatchSize :: Int
The maximum batch size of every export. It must be smaller or equal to maxQueueSize. The default value is 512.

Instances

Instances details

Show BatchTimeoutConfig Source #
Instance details Defined in OpenTelemetry.Processor.Batch Methods showsPrec :: Int -> BatchTimeoutConfig -> ShowS # show :: BatchTimeoutConfig -> String # showList :: [BatchTimeoutConfig] -> ShowS #

batchTimeoutConfig :: BatchTimeoutConfig Source #

Default configuration values

batchProcessor :: MonadIO m => BatchTimeoutConfig -> Exporter ImmutableSpan -> m Processor Source #

The batch processor accepts spans and places them into batches. Batching helps better compress the data and reduce the number of outgoing connections required to transmit the data. This processor supports both size and time based batching.