mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Pablo BaeyensandGitHub
69363faac2
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description <!-- Issue number if applicable --> Removes all deprecated symbols. #### Link to tracking issue Follows #13821 Follows #13868 Fixes #11143
33 lines
1.0 KiB
Go
33 lines
1.0 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package exporterhelper // import "go.opentelemetry.io/collector/exporter/exporterhelper"
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/consumer"
|
|
"go.opentelemetry.io/collector/exporter"
|
|
"go.opentelemetry.io/collector/exporter/exporterhelper/internal"
|
|
"go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
|
|
)
|
|
|
|
// NewLogs creates an exporter.Logs that records observability logs and wraps every request with a Span.
|
|
func NewLogs(
|
|
ctx context.Context,
|
|
set exporter.Settings,
|
|
cfg component.Config,
|
|
pusher consumer.ConsumeLogsFunc,
|
|
options ...Option,
|
|
) (exporter.Logs, error) {
|
|
if cfg == nil {
|
|
return nil, errNilConfig
|
|
}
|
|
if pusher == nil {
|
|
return nil, errNilPushLogs
|
|
}
|
|
return internal.NewLogsRequest(ctx, set, queuebatch.RequestFromLogs(), queuebatch.RequestConsumeFromLogs(pusher),
|
|
append([]Option{internal.WithQueueBatchSettings(queuebatch.NewLogsQueueBatchSettings())}, options...)...)
|
|
}
|