use delegate

exporter/googlecloudexporter/factory.go

@@ -35,38 +35,30 @@ var once sync.Once
 
 // NewFactory creates a factory for the googlecloud exporter
 func NewFactory() component.ExporterFactory {
-	return NewFactoryWithTypeStr(typeStr)
-}
-
-// creates a factory for the googlecloud exporter, overriding the type string
-// used in config
-func NewFactoryWithTypeStr(ts string) component.ExporterFactory {
 	// register view for self-observability
 	once.Do(func() {
 		view.Register(viewPointCount)
 	})
 
 	return exporterhelper.NewFactory(
-		configmodels.Type(ts),
-		createDefaultConfigWithTypeStr(ts),
+		typeStr,
+		createDefaultConfig,
 		exporterhelper.WithTraces(createTraceExporter),
 		exporterhelper.WithMetrics(createMetricsExporter),
 	)
 }
 
 // createDefaultConfig creates the default configuration for exporter.
-func createDefaultConfigWithTypeStr(ts string) exporterhelper.CreateDefaultConfig {
-	return func() configmodels.Exporter {
-		return &Config{
-			ExporterSettings: configmodels.ExporterSettings{
-				TypeVal: configmodels.Type(ts),
-				NameVal: ts,
-			},
-			TimeoutSettings: exporterhelper.TimeoutSettings{Timeout: defaultTimeout},
-			RetrySettings:   exporterhelper.DefaultRetrySettings(),
-			QueueSettings:   exporterhelper.DefaultQueueSettings(),
-			UserAgent:       "opentelemetry-collector-contrib {{version}}",
-		}
+func createDefaultConfig() configmodels.Exporter {
+	return &Config{
+		ExporterSettings: configmodels.ExporterSettings{
+			TypeVal: configmodels.Type(typeStr),
+			NameVal: typeStr,
+		},
+		TimeoutSettings: exporterhelper.TimeoutSettings{Timeout: defaultTimeout},
+		RetrySettings:   exporterhelper.DefaultRetrySettings(),
+		QueueSettings:   exporterhelper.DefaultQueueSettings(),
+		UserAgent:       "opentelemetry-collector-contrib {{version}}",
 	}
 }
 

exporter/stackdriverexporter/factory.go

@@ -15,17 +15,58 @@
 package stackdriverexporter
 
 import (
+	"context"
+
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/config/configmodels"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudexporter"
 )
 
+type factory struct {
+	delegate component.ExporterFactory
+}
+
 const (
 	// The value of "type" key in configuration.
 	typeStr = "stackdriver"
 )
 
 // NewFactory creates a factory for the stackdriver exporter
 func NewFactory() component.ExporterFactory {
-	return googlecloudexporter.NewFactoryWithTypeStr(typeStr)
+	return &factory{delegate: googlecloudexporter.NewFactory()}
+}
+
+func (*factory) Type() configmodels.Type {
+	return configmodels.Type(typeStr)
+}
+
+func (f *factory) CreateDefaultConfig() configmodels.Exporter {
+	cfg := f.delegate.CreateDefaultConfig()
+	cfg.(*googlecloudexporter.Config).TypeVal = f.Type()
+	return cfg
+}
+
+func (f *factory) CreateTracesExporter(
+	ctx context.Context,
+	params component.ExporterCreateParams,
+	cfg configmodels.Exporter,
+) (component.TracesExporter, error) {
+	return f.delegate.CreateTracesExporter(ctx, params, cfg)
+}
+
+func (f *factory) CreateMetricsExporter(
+	ctx context.Context,
+	params component.ExporterCreateParams,
+	cfg configmodels.Exporter,
+) (component.MetricsExporter, error) {
+	return f.delegate.CreateMetricsExporter(ctx, params, cfg)
+}
+
+func (f *factory) CreateLogsExporter(
+	ctx context.Context,
+	params component.ExporterCreateParams,
+	cfg configmodels.Exporter,
+) (component.LogsExporter, error) {
+	return f.delegate.CreateLogsExporter(ctx, params, cfg)
 }