Introduce service.Settings.TelemetryFactory

.chloggen/service-settings-telemetryfactory.yaml

@@ -0,0 +1,25 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: breaking
+
+# The name of the component, or a single word describing the area of concern, (e.g. otlpreceiver)
+component: pkg/service
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: The `service.Settings` type now requires a `telemetry.Factory` to be provided
+
+# One or more tracking issues or pull requests related to the change
+issues: [4970]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:
+
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: [api]

.github/workflows/utils/cspell.json

@@ -448,6 +448,7 @@
       "tailsampling",
       "tchannel",
       "telemetrygen",
+      "telemetrytest",
       "testcomponents",
       "testconverter",
       "testdata",

cmd/builder/internal/builder/main_test.go

@@ -114,6 +114,7 @@ var replaceModules = []string{
 	"/receiver/xreceiver",
 	"/service",
 	"/service/hostcapabilities",
+	"/service/telemetry/telemetrytest",
 }
 
 func newTestConfig(tb testing.TB) *Config {

cmd/mdatagen/go.mod

@@ -203,3 +203,5 @@ replace go.opentelemetry.io/collector/extension/extensioncapabilities => ../../e
 replace go.opentelemetry.io/collector/pdata/xpdata => ../../pdata/xpdata
 
 replace go.opentelemetry.io/collector/exporter/exporterhelper => ../../exporter/exporterhelper
+
+replace go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../../service/telemetry/telemetrytest

cmd/otelcorecol/builder-config.yaml

@@ -115,3 +115,4 @@ replaces:
   - go.opentelemetry.io/collector/receiver/xreceiver => ../../receiver/xreceiver
   - go.opentelemetry.io/collector/service => ../../service
   - go.opentelemetry.io/collector/service/hostcapabilities => ../../service/hostcapabilities
+  - go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../../service/telemetry/telemetrytest

cmd/otelcorecol/go.mod

@@ -4,7 +4,7 @@ module go.opentelemetry.io/collector/cmd/otelcorecol
 
 go 1.24.0
 
-toolchain go1.24.7
+toolchain go1.24.8
 
 require (
 	go.opentelemetry.io/collector/component v1.43.0
@@ -333,3 +333,5 @@ replace go.opentelemetry.io/collector/receiver/xreceiver => ../../receiver/xrece
 replace go.opentelemetry.io/collector/service => ../../service
 
 replace go.opentelemetry.io/collector/service/hostcapabilities => ../../service/hostcapabilities
+
+replace go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../../service/telemetry/telemetrytest

internal/e2e/go.mod

@@ -238,6 +238,8 @@ replace go.opentelemetry.io/collector/extension/zpagesextension => ../../extensi
 
 replace go.opentelemetry.io/collector/service => ../../service
 
+replace go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../../service/telemetry/telemetrytest
+
 replace go.opentelemetry.io/collector/extension/extensioncapabilities => ../../extension/extensioncapabilities
 
 replace go.opentelemetry.io/collector/receiver/xreceiver => ../../receiver/xreceiver

internal/e2e/status_test.go

@@ -75,11 +75,12 @@ func Test_ComponentStatusReporting_SharedInstance(t *testing.T) {
 		ExtensionsFactories: map[component.Type]extension.Factory{
 			component.MustNewType("watcher"): newExtensionFactory(),
 		},
+		TelemetryFactory: otelconftelemetry.NewFactory(),
 	}
 	set.BuildInfo = component.BuildInfo{Version: "test version", Command: "otelcoltest"}
 
 	cfg := service.Config{
-		Telemetry: otelconftelemetry.Config{
+		Telemetry: &otelconftelemetry.Config{
 			Logs: otelconftelemetry.LogsConfig{
 				Level:       zapcore.InfoLevel,
 				Development: false,

otelcol/collector.go

@@ -25,6 +25,7 @@ import (
 	"go.opentelemetry.io/collector/confmap/xconfmap"
 	"go.opentelemetry.io/collector/otelcol/internal/grpclog"
 	"go.opentelemetry.io/collector/service"
+	"go.opentelemetry.io/collector/service/telemetry/otelconftelemetry"
 )
 
 // State defines Collector's state.
@@ -216,6 +217,10 @@ func (col *Collector) setupConfigurationComponents(ctx context.Context) error {
 		},
 		AsyncErrorChannel: col.asyncErrorChannel,
 		LoggingOptions:    col.set.LoggingOptions,
+
+		// TODO: inject the telemetry factory through factories.
+		// See https://github.com/open-telemetry/opentelemetry-collector/issues/4970
+		TelemetryFactory: otelconftelemetry.NewFactory(),
 	}, cfg.Service)
 	if err != nil {
 		return err

otelcol/collector_windows.go

@@ -19,6 +19,7 @@ import (
 
 	"go.opentelemetry.io/collector/featuregate"
 	"go.opentelemetry.io/collector/service"
+	"go.opentelemetry.io/collector/service/telemetry/otelconftelemetry"
 )
 
 type windowsService struct {
@@ -214,7 +215,7 @@ func (w windowsEventLogCore) Sync() error {
 func withWindowsCore(elog *eventlog.Log, serviceConfig **service.Config) func(zapcore.Core) zapcore.Core {
 	return func(core zapcore.Core) zapcore.Core {
 		if serviceConfig != nil && *serviceConfig != nil {
-			for _, output := range (*serviceConfig).Telemetry.Logs.OutputPaths {
+			for _, output := range (*serviceConfig).Telemetry.(*otelconftelemetry.Config).Logs.OutputPaths {
 				if output != "stdout" && output != "stderr" {
 					// A log file was specified in the configuration, so we should not use the Windows Event Log
 					return core

otelcol/config_test.go

@@ -50,10 +50,10 @@ func TestConfigValidate(t *testing.T) {
 			expected: nil,
 		},
 		{
-			name: "custom-service-telemetrySettings-encoding",
+			name: "valid-telemetry-config",
 			cfgFn: func() *Config {
 				cfg := generateConfig()
-				cfg.Service.Telemetry.Logs.Encoding = "json"
+				cfg.Service.Telemetry = fakeTelemetryConfig{}
 				return cfg
 			},
 			expected: nil,
@@ -89,6 +89,15 @@ func TestConfigValidate(t *testing.T) {
 			},
 			expected: errMissingReceivers,
 		},
+		{
+			name: "invalid-telemetry-config",
+			cfgFn: func() *Config {
+				cfg := generateConfig()
+				cfg.Service.Telemetry = fakeTelemetryConfig{Invalid: true}
+				return cfg
+			},
+			expected: errors.New("service::telemetry: invalid config"),
+		},
 		{
 			name: "invalid-extension-reference",
 			cfgFn: func() *Config {
@@ -330,3 +339,14 @@ func generateConfig() *Config {
 func newPtr[T int | string](str T) *T {
 	return &str
 }
+
+type fakeTelemetryConfig struct {
+	Invalid bool `mapstructure:"invalid"`
+}
+
+func (cfg fakeTelemetryConfig) Validate() error {
+	if cfg.Invalid {
+		return errors.New("invalid config")
+	}
+	return nil
+}

otelcol/go.mod

@@ -128,6 +128,8 @@ replace go.opentelemetry.io/collector => ../
 
 replace go.opentelemetry.io/collector/service => ../service
 
+replace go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../service/telemetry/telemetrytest
+
 replace go.opentelemetry.io/collector/service/hostcapabilities => ../service/hostcapabilities
 
 replace go.opentelemetry.io/collector/connector => ../connector

otelcol/otelcoltest/go.mod

@@ -211,6 +211,8 @@ replace go.opentelemetry.io/collector/extension/zpagesextension => ../../extensi
 
 replace go.opentelemetry.io/collector/service => ../../service
 
+replace go.opentelemetry.io/collector/service/telemetry/telemetrytest => ../../service/telemetry/telemetrytest
+
 replace go.opentelemetry.io/collector/service/hostcapabilities => ../../service/hostcapabilities
 
 replace go.opentelemetry.io/collector/internal/fanoutconsumer => ../../internal/fanoutconsumer

otelcol/unmarshaler.go

@@ -30,7 +30,7 @@ func unmarshal(v *confmap.Conf, factories Factories) (*configSettings, error) {
 	// TODO: inject the telemetry factory through factories, once available.
 	// See https://github.com/open-telemetry/opentelemetry-collector/issues/4970
 	telFactory := otelconftelemetry.NewFactory()
-	defaultTelConfig := *telFactory.CreateDefaultConfig().(*otelconftelemetry.Config)
+	defaultTelConfig := telFactory.CreateDefaultConfig().(*otelconftelemetry.Config)
 
 	// Unmarshal top level sections and validate.
 	cfg := &configSettings{

otelcol/unmarshaler_test.go

@@ -56,7 +56,7 @@ func TestUnmarshalEmptyAllSections(t *testing.T) {
 		OutputPaths:       zapProdCfg.OutputPaths,
 		ErrorOutputPaths:  zapProdCfg.ErrorOutputPaths,
 		InitialFields:     zapProdCfg.InitialFields,
-	}, cfg.Service.Telemetry.Logs)
+	}, cfg.Service.Telemetry.(*otelconftelemetry.Config).Logs)
 }
 
 func TestUnmarshalUnknownTopLevel(t *testing.T) {
@@ -149,26 +149,13 @@ func TestServiceUnmarshalError(t *testing.T) {
 		expectError string
 	}{
 		{
-			name: "invalid-logs-level",
+			name: "invalid-telemetry-unknown-key",
 			conf: confmap.NewFromStringMap(map[string]any{
 				"telemetry": map[string]any{
-					"logs": map[string]any{
-						"level": "UNKNOWN",
-					},
-				},
-			}),
-			expectError: "decoding failed due to the following error(s):\n\n'telemetry.logs' decoding failed due to the following error(s):\n\n'level' unrecognized level: \"UNKNOWN\"",
-		},
-		{
-			name: "invalid-metrics-level",
-			conf: confmap.NewFromStringMap(map[string]any{
-				"telemetry": map[string]any{
-					"metrics": map[string]any{
-						"level": "unknown",
-					},
+					"unknown": "key",
 				},
 			}),
-			expectError: "decoding failed due to the following error(s):\n\n'telemetry.metrics' decoding failed due to the following error(s):\n\n'level' unknown metrics level \"unknown\"",
+			expectError: "decoding failed due to the following error(s):\n\n'telemetry' has invalid keys: unknown",
 		},
 		{
 			name: "invalid-service-extensions-section",
@@ -201,7 +188,9 @@ func TestServiceUnmarshalError(t *testing.T) {
 
 	for _, tt := range testCases {
 		t.Run(tt.name, func(t *testing.T) {
-			err := tt.conf.Unmarshal(&service.Config{})
+			err := tt.conf.Unmarshal(&service.Config{
+				Telemetry: fakeTelemetryConfig{},
+			})
 			require.ErrorContains(t, err, tt.expectError)
 		})
 	}

service/config.go

@@ -4,15 +4,15 @@
 package service // import "go.opentelemetry.io/collector/service"
 
 import (
+	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/service/extensions"
 	"go.opentelemetry.io/collector/service/pipelines"
-	"go.opentelemetry.io/collector/service/telemetry/otelconftelemetry"
 )
 
 // Config defines the configurable components of the Service.
 type Config struct {
 	// Telemetry is the configuration for collector's own telemetry.
-	Telemetry otelconftelemetry.Config `mapstructure:"telemetry"`
+	Telemetry component.Config `mapstructure:"telemetry"`
 
 	// Extensions are the ordered list of extensions configured for the service.
 	Extensions extensions.Config `mapstructure:"extensions,omitempty"`