Documentation
¶
Overview ¶
Package batch provides an otelcol.processor.batch component.
Index ¶
- Variables
- type Arguments
- func (args Arguments) Convert() (otelcomponent.Config, error)
- func (args Arguments) DebugMetricsConfig() otelcolCfg.DebugMetricsArguments
- func (args Arguments) Exporters() map[pipeline.Signal]map[otelcomponent.ID]otelcomponent.Component
- func (args Arguments) Extensions() map[otelcomponent.ID]otelcomponent.Component
- 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 `alloy:"timeout,attr,optional"`
SendBatchSize uint32 `alloy:"send_batch_size,attr,optional"`
SendBatchMaxSize uint32 `alloy:"send_batch_max_size,attr,optional"`
MetadataKeys []string `alloy:"metadata_keys,attr,optional"`
MetadataCardinalityLimit uint32 `alloy:"metadata_cardinality_limit,attr,optional"`
// Output configures where to send processed data. Required.
Output *otelcol.ConsumerArguments `alloy:"output,block"`
// DebugMetrics configures component internal metrics. Optional.
DebugMetrics otelcolCfg.DebugMetricsArguments `alloy:"debug_metrics,block,optional"`
}
Arguments configures the otelcol.processor.batch component.
func (Arguments) Convert ¶
func (args Arguments) Convert() (otelcomponent.Config, error)
Convert implements processor.Arguments.
func (Arguments) DebugMetricsConfig ¶ added in v1.2.0
func (args Arguments) DebugMetricsConfig() otelcolCfg.DebugMetricsArguments
DebugMetricsConfig implements processor.Arguments.
func (Arguments) Exporters ¶
func (args Arguments) Exporters() map[pipeline.Signal]map[otelcomponent.ID]otelcomponent.Component
Exporters implements processor.Arguments.
func (Arguments) Extensions ¶
func (args Arguments) Extensions() map[otelcomponent.ID]otelcomponent.Component
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 syntax.Defaulter.
Source Files
Click to show internal directories.
Click to hide internal directories.