mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
a46b19a87d
#### Description Embed `confignet.AddrConfig` in `confighttp.ServerConfig`, replacing the `Endpoint` field. This introduces the "transport" config attribute, which can be set to "unix" for binding a Unix domain socket. #### Link to tracking issue Fixes #8752 Fixes #14187 #### Testing ```bash $ ./bin/otelcorecol_linux_amd64 \ --config examples/local/otel-config.yaml \ --set receivers::otlp::protocols::http::transport=unix \ --set receivers::otlp::protocols::http::endpoint=\"@otlphttp\" ``` ```bash $ curl --abstract-unix-socket otlphttp http://testing.invalid:1234/v1/traces 405 method not allowed, supported: [POST] ``` #### Documentation Updated README.md --------- Co-authored-by: Antoine Toulme <[email protected]>
44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package zpagesextension
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/component/componenttest"
|
|
"go.opentelemetry.io/collector/config/confighttp"
|
|
"go.opentelemetry.io/collector/extension/extensiontest"
|
|
"go.opentelemetry.io/collector/extension/zpagesextension/internal/metadata"
|
|
"go.opentelemetry.io/collector/internal/testutil"
|
|
)
|
|
|
|
func TestFactory_CreateDefaultConfig(t *testing.T) {
|
|
expectedServerConfig := confighttp.NewDefaultServerConfig()
|
|
expectedServerConfig.NetAddr.Endpoint = "localhost:55679"
|
|
|
|
cfg := createDefaultConfig()
|
|
assert.Equal(t, &Config{ServerConfig: expectedServerConfig}, cfg)
|
|
|
|
require.NoError(t, componenttest.CheckConfigStruct(cfg))
|
|
ext, err := create(context.Background(), extensiontest.NewNopSettings(metadata.Type), cfg)
|
|
require.NoError(t, err)
|
|
require.NotNil(t, ext)
|
|
}
|
|
|
|
func TestFactoryCreate(t *testing.T) {
|
|
cfg := createDefaultConfig().(*Config)
|
|
cfg.NetAddr.Endpoint = testutil.GetAvailableLocalAddress(t)
|
|
|
|
set := extensiontest.NewNopSettings(extensiontest.NopType)
|
|
set.ID = component.NewID(NewFactory().Type())
|
|
ext, err := create(context.Background(), set, cfg)
|
|
require.NoError(t, err)
|
|
require.NotNil(t, ext)
|
|
}
|