mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Dmitry AnoshinandGitHub
abbddc8579
Fixes https://github.com/open-telemetry/opentelemetry-collector/issues/15178 `Config.Protocols` is now a named field instead of an anonymous embedded field according to our [coding guidelines](https://github.com/open-telemetry/opentelemetry-collector/blob/main/docs/coding-guidelines.md#avoid-embedded-structs) Access to `cfg.GRPC` and `cfg.HTTP` must be updated to `cfg.Protocols.GRPC` and `cfg.Protocols.HTTP`.
84 lines
2.9 KiB
Go
84 lines
2.9 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package e2e
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/config/configgrpc"
|
|
"go.opentelemetry.io/collector/config/configoptional"
|
|
"go.opentelemetry.io/collector/config/configretry"
|
|
"go.opentelemetry.io/collector/config/configtls"
|
|
"go.opentelemetry.io/collector/exporter/exporterhelper"
|
|
"go.opentelemetry.io/collector/exporter/exportertest"
|
|
"go.opentelemetry.io/collector/exporter/otlpexporter"
|
|
"go.opentelemetry.io/collector/internal/testutil"
|
|
"go.opentelemetry.io/collector/pipeline"
|
|
"go.opentelemetry.io/collector/receiver/otlpreceiver"
|
|
)
|
|
|
|
func testExporterConfig(endpoint string) component.Config {
|
|
retryConfig := configretry.NewDefaultBackOffConfig()
|
|
retryConfig.InitialInterval = time.Millisecond // interval is short for the test purposes
|
|
return &otlpexporter.Config{
|
|
QueueConfig: configoptional.None[exporterhelper.QueueBatchConfig](),
|
|
RetryConfig: retryConfig,
|
|
ClientConfig: configgrpc.ClientConfig{
|
|
Endpoint: endpoint,
|
|
TLS: configtls.ClientConfig{
|
|
Insecure: true,
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
func testReceiverConfig(endpoint string) component.Config {
|
|
cfg := otlpreceiver.NewFactory().CreateDefaultConfig()
|
|
cfg.(*otlpreceiver.Config).Protocols.GRPC.GetOrInsertDefault().NetAddr.Endpoint = endpoint
|
|
return cfg
|
|
}
|
|
|
|
// TestConsumeContract is an example of testing of the exporter for the contract between the
|
|
// exporter and the receiver.
|
|
func TestConsumeContractOtlpLogs(t *testing.T) {
|
|
addr := testutil.GetAvailableLocalAddress(t)
|
|
exportertest.CheckConsumeContract(exportertest.CheckConsumeContractParams{
|
|
T: t,
|
|
NumberOfTestElements: 10,
|
|
ExporterFactory: otlpexporter.NewFactory(),
|
|
Signal: pipeline.SignalLogs,
|
|
ExporterConfig: testExporterConfig(addr),
|
|
ReceiverFactory: otlpreceiver.NewFactory(),
|
|
ReceiverConfig: testReceiverConfig(addr),
|
|
})
|
|
}
|
|
|
|
func TestConsumeContractOtlpTraces(t *testing.T) {
|
|
addr := testutil.GetAvailableLocalAddress(t)
|
|
exportertest.CheckConsumeContract(exportertest.CheckConsumeContractParams{
|
|
T: t,
|
|
NumberOfTestElements: 10,
|
|
Signal: pipeline.SignalTraces,
|
|
ExporterFactory: otlpexporter.NewFactory(),
|
|
ExporterConfig: testExporterConfig(addr),
|
|
ReceiverFactory: otlpreceiver.NewFactory(),
|
|
ReceiverConfig: testReceiverConfig(addr),
|
|
})
|
|
}
|
|
|
|
func TestConsumeContractOtlpMetrics(t *testing.T) {
|
|
addr := testutil.GetAvailableLocalAddress(t)
|
|
exportertest.CheckConsumeContract(exportertest.CheckConsumeContractParams{
|
|
T: t,
|
|
NumberOfTestElements: 10,
|
|
ExporterFactory: otlpexporter.NewFactory(),
|
|
Signal: pipeline.SignalMetrics,
|
|
ExporterConfig: testExporterConfig(addr),
|
|
ReceiverFactory: otlpreceiver.NewFactory(),
|
|
ReceiverConfig: testReceiverConfig(addr),
|
|
})
|
|
}
|