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
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 ¶
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 ¶ added in v0.35.0
func (args *Arguments) SetToDefault()
SetToDefault implements river.Defaulter.
Source Files
Click to show internal directories.
Click to hide internal directories.