Refactor config sources into provider wrapper and support all service…

… providers (#2893)

* refactor config source and its provider

* forward wrapped providers to config source resolver

* support raw confmap.Provider retrieved values

* remove unnecessary previous value merging

* update configsource.Provider for clarity

* exercise both env provider types in vault test

cmd/otelcol/main.go

@@ -32,8 +32,7 @@ import (
 
 	"github.com/signalfx/splunk-otel-collector/internal/components"
 	"github.com/signalfx/splunk-otel-collector/internal/configconverter"
-	"github.com/signalfx/splunk-otel-collector/internal/configprovider"
-	"github.com/signalfx/splunk-otel-collector/internal/configsources"
+	"github.com/signalfx/splunk-otel-collector/internal/confmapprovider/configsource"
 	"github.com/signalfx/splunk-otel-collector/internal/confmapprovider/discovery"
 	"github.com/signalfx/splunk-otel-collector/internal/settings"
 	"github.com/signalfx/splunk-otel-collector/internal/version"
@@ -72,31 +71,20 @@ func main() {
 		log.Fatalf("failed to create discovery provider: %v", err)
 	}
 
-	hooks := []configprovider.Hook{configServer, dryRun}
+	hooks := []configsource.Hook{configServer, dryRun}
 	envProvider := envprovider.New()
 	fileProvider := fileprovider.New()
+	configSourceProvider := configsource.New(zap.NewNop(), hooks)
 	serviceConfigProvider, err := otelcol.NewConfigProvider(
 		otelcol.ConfigProviderSettings{
 			ResolverSettings: confmap.ResolverSettings{
 				URIs: collectorSettings.ResolverURIs(),
 				Providers: map[string]confmap.Provider{
-					discovery.PropertyScheme(): configprovider.NewConfigSourceConfigMapProvider(
-						discovery.PropertyProvider(), zap.NewNop(), info, hooks, configsources.Get()...,
-					),
-					discovery.ConfigDScheme(): configprovider.NewConfigSourceConfigMapProvider(
-						discovery.ConfigDProvider(),
-						zap.NewNop(), // The service logger is not available yet, setting it to Nop.
-						info, hooks, configsources.Get()...,
-					),
-					discovery.DiscoveryModeScheme(): configprovider.NewConfigSourceConfigMapProvider(
-						discovery.DiscoveryModeProvider(), zap.NewNop(), info, hooks, configsources.Get()...,
-					),
-					envProvider.Scheme(): configprovider.NewConfigSourceConfigMapProvider(
-						envProvider, zap.NewNop(), info, hooks, configsources.Get()...,
-					),
-					fileProvider.Scheme(): configprovider.NewConfigSourceConfigMapProvider(
-						fileProvider, zap.NewNop(), info, hooks, configsources.Get()...,
-					),
+					discovery.PropertyScheme():      configSourceProvider.Wrap(discovery.PropertyProvider()),
+					discovery.ConfigDScheme():       configSourceProvider.Wrap(discovery.ConfigDProvider()),
+					discovery.DiscoveryModeScheme(): configSourceProvider.Wrap(discovery.DiscoveryModeProvider()),
+					envProvider.Scheme():            configSourceProvider.Wrap(envProvider),
+					fileProvider.Scheme():           configSourceProvider.Wrap(fileProvider),
 				}, Converters: confMapConverters,
 			},
 		})

internal/configconverter/config_server.go

@@ -32,7 +32,7 @@ import (
 	"go.opentelemetry.io/collector/confmap"
 	"gopkg.in/yaml.v2"
 
-	"github.com/signalfx/splunk-otel-collector/internal/configprovider"
+	"github.com/signalfx/splunk-otel-collector/internal/confmapprovider/configsource"
 )
 
 const (
@@ -51,7 +51,7 @@ const (
 )
 
 var _ confmap.Converter = (*ConfigServer)(nil)
-var _ configprovider.Hook = (*ConfigServer)(nil)
+var _ configsource.Hook = (*ConfigServer)(nil)
 
 type ConfigServer struct {
 	// Use get/set methods instead of direct usage

internal/configconverter/dry_run.go

@@ -23,11 +23,11 @@ import (
 	"go.opentelemetry.io/collector/confmap"
 	"gopkg.in/yaml.v2"
 
-	"github.com/signalfx/splunk-otel-collector/internal/configprovider"
+	"github.com/signalfx/splunk-otel-collector/internal/confmapprovider/configsource"
 )
 
 var _ confmap.Converter = (*DryRun)(nil)
-var _ configprovider.Hook = (*DryRun)(nil)
+var _ configsource.Hook = (*DryRun)(nil)
 
 type DryRun struct {
 	*sync.Mutex