Documentation
¶
Index ¶
Constants ¶
View Source
const ( TracesStability = component.StabilityLevelBeta MetricsStability = component.StabilityLevelBeta LogsStability = component.StabilityLevelBeta )
Variables ¶
View Source
var ( Type = component.MustNewType("concurrentbatch") ScopeName = "github.com/open-telemetry/otel-arrow/collector/processor/concurrentbatchprocessor" )
Functions ¶
Types ¶
type TelemetryBuilder ¶
type TelemetryBuilder struct {
ProcessorBatchBatchSendSize metric.Int64Histogram
ProcessorBatchBatchSendSizeBytes metric.Int64Histogram
ProcessorBatchBatchSizeTriggerSend metric.Int64Counter
ProcessorBatchMetadataCardinality metric.Int64ObservableUpDownCounter
ProcessorBatchTimeoutTriggerSend metric.Int64Counter
// contains filtered or unexported fields
}
TelemetryBuilder provides an interface for components to report telemetry as defined in metadata and user config.
func NewTelemetryBuilder ¶
func NewTelemetryBuilder(settings component.TelemetrySettings, options ...TelemetryBuilderOption) (*TelemetryBuilder, error)
NewTelemetryBuilder provides a struct with methods to update all internal telemetry for a component
func (*TelemetryBuilder) RegisterProcessorBatchMetadataCardinalityCallback ¶ added in v0.33.0
func (builder *TelemetryBuilder) RegisterProcessorBatchMetadataCardinalityCallback(cb metric.Int64Callback) error
RegisterProcessorBatchMetadataCardinalityCallback sets callback for observable ProcessorBatchMetadataCardinality metric.
func (*TelemetryBuilder) Shutdown ¶ added in v0.33.0
func (builder *TelemetryBuilder) Shutdown()
Shutdown unregister all registered callbacks for async instruments.
type TelemetryBuilderOption ¶
type TelemetryBuilderOption interface {
// contains filtered or unexported methods
}
TelemetryBuilderOption applies changes to default builder.
Source Files
Click to show internal directories.
Click to hide internal directories.