batch

package
v0.36.0-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 28, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package batch provides an otelcol.processor.batch component.

Index

Constants

This section is empty.

Variables

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

DefaultArguments holds default settings for Arguments.

Functions

This section is empty.

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

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 added in v0.35.0

func (args *Arguments) SetToDefault()

SetToDefault implements river.Defaulter.

func (*Arguments) Validate added in v0.35.0

func (args *Arguments) Validate() error

Validate implements river.Validator.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL