Skip to content

Commit

Permalink
Avoid using variable name that collides with imported package (#2811)
Browse files Browse the repository at this point in the history
Signed-off-by: Bogdan Drutu <[email protected]>
  • Loading branch information
bogdandrutu authored Mar 25, 2021
1 parent d8e9970 commit e3c5965
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 23 deletions.
14 changes: 7 additions & 7 deletions config/configparser/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ const typeAndNameSeparator = "/"
// After loading the config, need to check if it is valid by calling `ValidateConfig`.
func Load(v *config.Parser, factories component.Factories) (*configmodels.Config, error) {

var config configmodels.Config
var cfg configmodels.Config

// Load the config.

Expand All @@ -120,36 +120,36 @@ func Load(v *config.Parser, factories component.Factories) (*configmodels.Config
if err != nil {
return nil, err
}
config.Extensions = extensions
cfg.Extensions = extensions

// Load data components (receivers, exporters, and processors).

receivers, err := loadReceivers(cast.ToStringMap(v.Get(receiversKeyName)), factories.Receivers)
if err != nil {
return nil, err
}
config.Receivers = receivers
cfg.Receivers = receivers

exporters, err := loadExporters(cast.ToStringMap(v.Get(exportersKeyName)), factories.Exporters)
if err != nil {
return nil, err
}
config.Exporters = exporters
cfg.Exporters = exporters

processors, err := loadProcessors(cast.ToStringMap(v.Get(processorsKeyName)), factories.Processors)
if err != nil {
return nil, err
}
config.Processors = processors
cfg.Processors = processors

// Load the service and its data pipelines.
service, err := loadService(rawCfg.Service)
if err != nil {
return nil, err
}
config.Service = service
cfg.Service = service

return &config, nil
return &cfg, nil
}

// DecodeTypeAndName decodes a key in type[/name] format into type and fullName.
Expand Down
32 changes: 16 additions & 16 deletions config/configparser/config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,20 +34,20 @@ func TestDecodeConfig(t *testing.T) {
assert.NoError(t, err)

// Load the config
config, err := loadConfigFile(t, path.Join(".", "testdata", "valid-config.yaml"), factories)
cfg, err := loadConfigFile(t, path.Join(".", "testdata", "valid-config.yaml"), factories)
require.NoError(t, err, "Unable to load config")

// Verify extensions.
assert.Equal(t, 3, len(config.Extensions))
assert.Equal(t, "some string", config.Extensions["exampleextension/1"].(*testcomponents.ExampleExtensionCfg).ExtraSetting)
assert.Equal(t, 3, len(cfg.Extensions))
assert.Equal(t, "some string", cfg.Extensions["exampleextension/1"].(*testcomponents.ExampleExtensionCfg).ExtraSetting)

// Verify service.
assert.Equal(t, 2, len(config.Service.Extensions))
assert.Equal(t, "exampleextension/0", config.Service.Extensions[0])
assert.Equal(t, "exampleextension/1", config.Service.Extensions[1])
assert.Equal(t, 2, len(cfg.Service.Extensions))
assert.Equal(t, "exampleextension/0", cfg.Service.Extensions[0])
assert.Equal(t, "exampleextension/1", cfg.Service.Extensions[1])

// Verify receivers
assert.Equal(t, 2, len(config.Receivers), "Incorrect receivers count")
assert.Equal(t, 2, len(cfg.Receivers), "Incorrect receivers count")

assert.Equal(t,
&testcomponents.ExampleReceiver{
Expand All @@ -60,7 +60,7 @@ func TestDecodeConfig(t *testing.T) {
},
ExtraSetting: "some string",
},
config.Receivers["examplereceiver"],
cfg.Receivers["examplereceiver"],
"Did not load receiver config correctly")

assert.Equal(t,
Expand All @@ -74,11 +74,11 @@ func TestDecodeConfig(t *testing.T) {
},
ExtraSetting: "some string",
},
config.Receivers["examplereceiver/myreceiver"],
cfg.Receivers["examplereceiver/myreceiver"],
"Did not load receiver config correctly")

// Verify exporters
assert.Equal(t, 2, len(config.Exporters), "Incorrect exporters count")
assert.Equal(t, 2, len(cfg.Exporters), "Incorrect exporters count")

assert.Equal(t,
&testcomponents.ExampleExporter{
Expand All @@ -88,7 +88,7 @@ func TestDecodeConfig(t *testing.T) {
},
ExtraSetting: "some export string",
},
config.Exporters["exampleexporter"],
cfg.Exporters["exampleexporter"],
"Did not load exporter config correctly")

assert.Equal(t,
Expand All @@ -99,11 +99,11 @@ func TestDecodeConfig(t *testing.T) {
},
ExtraSetting: "some export string 2",
},
config.Exporters["exampleexporter/myexporter"],
cfg.Exporters["exampleexporter/myexporter"],
"Did not load exporter config correctly")

// Verify Processors
assert.Equal(t, 1, len(config.Processors), "Incorrect processors count")
assert.Equal(t, 1, len(cfg.Processors), "Incorrect processors count")

assert.Equal(t,
&testcomponents.ExampleProcessorCfg{
Expand All @@ -113,11 +113,11 @@ func TestDecodeConfig(t *testing.T) {
},
ExtraSetting: "some export string",
},
config.Processors["exampleprocessor"],
cfg.Processors["exampleprocessor"],
"Did not load processor config correctly")

// Verify Pipelines
assert.Equal(t, 1, len(config.Service.Pipelines), "Incorrect pipelines count")
assert.Equal(t, 1, len(cfg.Service.Pipelines), "Incorrect pipelines count")

assert.Equal(t,
&configmodels.Pipeline{
Expand All @@ -127,7 +127,7 @@ func TestDecodeConfig(t *testing.T) {
Processors: []string{"exampleprocessor"},
Exporters: []string{"exampleexporter"},
},
config.Service.Pipelines["traces"],
cfg.Service.Pipelines["traces"],
"Did not load pipeline config correctly")
}

Expand Down

0 comments on commit e3c5965

Please sign in to comment.