Skip to content

Commit

Permalink
Revert deprecation of WithConfigUnmarshaler
Browse files Browse the repository at this point in the history
Signed-off-by: Bogdan Drutu <[email protected]>
  • Loading branch information
bogdandrutu committed Apr 8, 2022
1 parent a7d0f00 commit c4730cd
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 13 deletions.
3 changes: 0 additions & 3 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@

- Deprecate configmapprovider package, replace with mapconverter (#5167)
- Deprecate `service.MustNewConfigProvider` and `service.MustNewDefaultConfigProvider`in favor of `service.NewConfigProvider` (#4762)
- There is no equivalent to provide custom ConfigUnmarshaler, if you need to apply changes to the parsed config wrap the default ConfigProvider.
>>>>>>> 2daa6ab9 (Change deprecated NewConfigProvider to use options and do input validation)

### 💡 Enhancements 💡

Expand Down Expand Up @@ -50,7 +48,6 @@

- Move MapProvider to config, split providers in their own package (#5030)
- API related to `pdata.AttributeValue` is deprecated in favor of `pdata.Value` (#4978)
- API related to `pdata.AttributeValue` is deprecated in favor of `pdata.Value` (#4975)
- `pdata.AttributeValue` struct is deprecated in favor of `pdata.Value`
- `pdata.AttributeValueType` type is deprecated in favor of `pdata.ValueType`
- `pdata.AttributeValueType...` constants are deprecated in favor of `pdata.ValueType...`
Expand Down
2 changes: 1 addition & 1 deletion service/command.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,10 @@ package service // import "go.opentelemetry.io/collector/service"

import (
"github.com/spf13/cobra"
"go.opentelemetry.io/collector/config/mapconverter/overwritepropertiesmapconverter"

"go.opentelemetry.io/collector/config"
"go.opentelemetry.io/collector/config/mapconverter/expandmapconverter"
"go.opentelemetry.io/collector/config/mapconverter/overwritepropertiesmapconverter"
"go.opentelemetry.io/collector/service/featuregate"
)

Expand Down
3 changes: 0 additions & 3 deletions service/config_provider.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,9 +99,6 @@ func WithConfigMapConverters(c []config.MapConverterFunc) ConfigProviderOption {
}

// WithConfigUnmarshaler overwrites the default unmarshaler.
// Deprecated: [v0.49.0] because providing custom ConfigUnmarshaler is not necessary since users can wrap/implement
// ConfigProvider if needed to change the resulted config. This functionality will be kept for at least 2 minor versions,
// and if nobody express a need for it will be removed.
func WithConfigUnmarshaler(c configunmarshaler.ConfigUnmarshaler) ConfigProviderOption {
return func(opts *configProvider) {
opts.configUnmarshaler = c
Expand Down
12 changes: 6 additions & 6 deletions service/config_provider_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ import (
)

type mockProvider struct {
shceme string
scheme string
retM *config.Map
errR error
errS error
Expand All @@ -56,10 +56,10 @@ func (m *mockProvider) Retrieve(_ context.Context, _ string, watcher config.Watc
}

func (m *mockProvider) Scheme() string {
if m.shceme == "" {
if m.scheme == "" {
return "mock"
}
return m.shceme
return m.scheme
}

func (m *mockProvider) Shutdown(context.Context) error {
Expand Down Expand Up @@ -100,7 +100,7 @@ func TestConfigProvider_Errors(t *testing.T) {
locations: []string{"mock:", "err:"},
parserProvider: []config.MapProvider{
&mockProvider{},
&mockProvider{shceme: "err", errR: errors.New("retrieve_err")},
&mockProvider{scheme: "err", errR: errors.New("retrieve_err")},
},
configUnmarshaler: configunmarshaler.NewDefault(),
expectNewErr: true,
Expand Down Expand Up @@ -133,7 +133,7 @@ func TestConfigProvider_Errors(t *testing.T) {
parserProvider: func() []config.MapProvider {
cfgMap, err := configtest.LoadConfigMap(filepath.Join("testdata", "otelcol-nop.yaml"))
require.NoError(t, err)
return []config.MapProvider{&mockProvider{}, &mockProvider{shceme: "err", retM: cfgMap, errW: errors.New("watch_err")}}
return []config.MapProvider{&mockProvider{}, &mockProvider{scheme: "err", retM: cfgMap, errW: errors.New("watch_err")}}
}(),
configUnmarshaler: configunmarshaler.NewDefault(),
expectWatchErr: true,
Expand All @@ -146,7 +146,7 @@ func TestConfigProvider_Errors(t *testing.T) {
require.NoError(t, err)
return []config.MapProvider{
&mockProvider{},
&mockProvider{shceme: "err", retM: cfgMap, errC: errors.New("close_err")},
&mockProvider{scheme: "err", retM: cfgMap, errC: errors.New("close_err")},
}
}(),
configUnmarshaler: configunmarshaler.NewDefault(),
Expand Down

0 comments on commit c4730cd

Please sign in to comment.