Skip to content

Commit

Permalink
Remove deprecated funcs/types from service related to Config (#5755)
Browse files Browse the repository at this point in the history
Signed-off-by: Bogdan <bogdandrutu@gmail.com>
  • Loading branch information
bogdandrutu authored Jul 27, 2022
1 parent 73b7320 commit de51f9e
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 16 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

### 🛑 Breaking changes 🛑

- Remove deprecated funcs/types from service related to `Config` (#5755)
- Change`confighttp.ToClient` to accept a `component.Host` (#5737)
- Remove deprecated funcs from pdata related to mutable slices (#5754)

Expand Down
10 changes: 0 additions & 10 deletions service/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,20 +16,10 @@ package service // import "go.opentelemetry.io/collector/service"

import (
"go.opentelemetry.io/collector/config"
"go.opentelemetry.io/collector/service/telemetry"
)

type Config = config.Config

type ConfigService = config.Service

// Deprecated: [v0.54.0] use telemetry.Config
type ConfigServiceTelemetry = telemetry.Config

// Deprecated: [v0.54.0] use telemetry.Config
type ConfigServiceTelemetryLogs = telemetry.LogsConfig

// Deprecated: [v0.54.0] use telemetry.Config
type ConfigServiceTelemetryMetrics = telemetry.MetricsConfig

type ConfigServicePipeline = config.Pipeline
7 changes: 4 additions & 3 deletions service/config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ import (

"go.opentelemetry.io/collector/config"
"go.opentelemetry.io/collector/config/configtelemetry"
"go.opentelemetry.io/collector/service/telemetry"
)

var (
Expand Down Expand Up @@ -264,8 +265,8 @@ func generateConfig() *Config {
},
},
Service: ConfigService{
Telemetry: ConfigServiceTelemetry{
Logs: ConfigServiceTelemetryLogs{
Telemetry: telemetry.Config{
Logs: telemetry.LogsConfig{
Level: zapcore.DebugLevel,
Development: true,
Encoding: "console",
Expand All @@ -275,7 +276,7 @@ func generateConfig() *Config {
ErrorOutputPaths: []string{"stderr", "./error-output-logs"},
InitialFields: map[string]interface{}{"fieldKey": "filed-value"},
},
Metrics: ConfigServiceTelemetryMetrics{
Metrics: telemetry.MetricsConfig{
Level: configtelemetry.LevelNormal,
Address: ":8080",
},
Expand Down
7 changes: 4 additions & 3 deletions service/telemetry.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ import (
"go.opentelemetry.io/collector/processor/batchprocessor"
semconv "go.opentelemetry.io/collector/semconv/v1.5.0"
"go.opentelemetry.io/collector/service/featuregate"
"go.opentelemetry.io/collector/service/telemetry"
)

// collectorTelemetry is collector's own telemetrySettings.
Expand Down Expand Up @@ -79,7 +80,7 @@ func newColTelemetry(registry *featuregate.Registry) *telemetryInitializer {
}
}

func (tel *telemetryInitializer) init(buildInfo component.BuildInfo, logger *zap.Logger, cfg ConfigServiceTelemetry, asyncErrorChannel chan error) error {
func (tel *telemetryInitializer) init(buildInfo component.BuildInfo, logger *zap.Logger, cfg telemetry.Config, asyncErrorChannel chan error) error {
var err error
tel.doInitOnce.Do(
func() {
Expand All @@ -89,7 +90,7 @@ func (tel *telemetryInitializer) init(buildInfo component.BuildInfo, logger *zap
return err
}

func (tel *telemetryInitializer) initOnce(buildInfo component.BuildInfo, logger *zap.Logger, cfg ConfigServiceTelemetry, asyncErrorChannel chan error) error {
func (tel *telemetryInitializer) initOnce(buildInfo component.BuildInfo, logger *zap.Logger, cfg telemetry.Config, asyncErrorChannel chan error) error {
if cfg.Metrics.Level == configtelemetry.LevelNone || cfg.Metrics.Address == "" {
logger.Info(
"Skipping telemetry setup.",
Expand Down Expand Up @@ -157,7 +158,7 @@ func (tel *telemetryInitializer) initOnce(buildInfo component.BuildInfo, logger
return nil
}

func (tel *telemetryInitializer) initOpenCensus(cfg ConfigServiceTelemetry, telAttrs map[string]string) (http.Handler, error) {
func (tel *telemetryInitializer) initOpenCensus(cfg telemetry.Config, telAttrs map[string]string) (http.Handler, error) {
tel.ocRegistry = ocmetric.NewRegistry()
metricproducer.GlobalManager().AddProducer(tel.ocRegistry)

Expand Down

0 comments on commit de51f9e

Please sign in to comment.