batch

Documentation

Overview

Package batch provides an otelcol.processor.batch component.

Index

• Variables
• type Arguments
  • func (args Arguments) Convert() (otelcomponent.Config, error)
  • func (args Arguments) Exporters() map[otelcomponent.DataType]map[otelcomponent.ID]otelcomponent.Component
  • func (args Arguments) Extensions() map[otelcomponent.ID]otelextension.Extension
  • func (args Arguments) NextConsumers() *otelcol.ConsumerArguments
  • func (args *Arguments) SetToDefault()
  • func (args *Arguments) Validate() error

Variables

var DefaultArguments = Arguments{
	Timeout:                  200 * time.Millisecond,
	SendBatchSize:            8192,
	MetadataCardinalityLimit: 1000,
}

DefaultArguments holds default settings for Arguments.

Types

type Arguments

type Arguments struct {
	Timeout                  time.Duration `river:"timeout,attr,optional"`
	SendBatchSize            uint32        `river:"send_batch_size,attr,optional"`
	SendBatchMaxSize         uint32        `river:"send_batch_max_size,attr,optional"`
	MetadataKeys             []string      `river:"metadata_keys,attr,optional"`
	MetadataCardinalityLimit uint32        `river:"metadata_cardinality_limit,attr,optional"`

	// Output configures where to send processed data. Required.
	Output *otelcol.ConsumerArguments `river:"output,block"`
}

Arguments configures the otelcol.processor.batch component.

func (Arguments) Convert

func (args Arguments) Convert() (otelcomponent.Config, error)

Convert implements processor.Arguments.

func (Arguments) Exporters

func (args Arguments) Exporters() map[otelcomponent.DataType]map[otelcomponent.ID]otelcomponent.Component

Exporters implements processor.Arguments.

func (Arguments) Extensions

func (args Arguments) Extensions() map[otelcomponent.ID]otelextension.Extension

Extensions implements processor.Arguments.

func (Arguments) NextConsumers

func (args Arguments) NextConsumers() *otelcol.ConsumerArguments

NextConsumers implements processor.Arguments.

func (*Arguments) SetToDefault

func (args *Arguments) SetToDefault()

SetToDefault implements river.Defaulter.

func (*Arguments) Validate

func (args *Arguments) Validate() error

Validate implements river.Validator.