Wrap component opts for exporter and processor

Fixes open-telemetry#2787 Fixes open-telemetry#2788
punya · Mar 26, 2021 · a84536e · a84536e
1 parent d9b2c4b
commit a84536e
Show file tree

Hide file tree

Showing 9 changed files with 301 additions and 38 deletions.
diff --git a/exporter/exporterhelper/common.go b/exporter/exporterhelper/common.go
@@ -101,19 +101,11 @@ func fromOptions(options []Option) *baseSettings {
 // Option apply changes to baseSettings.
 type Option func(*baseSettings)
 
-// WithStart overrides the default Start function for an exporter.
-// The default shutdown function does nothing and always returns nil.
-func WithStart(start componenthelper.Start) Option {
+// WithComponentOptions adds options that apply to a generic component
+// (such as start and shutdown hooks).
+func WithComponentOptions(opts ...componenthelper.Option) Option {
 	return func(o *baseSettings) {
-		o.componentOptions = append(o.componentOptions, componenthelper.WithStart(start))
-	}
-}
-
-// WithShutdown overrides the default Shutdown function for an exporter.
-// The default shutdown function does nothing and always returns nil.
-func WithShutdown(shutdown componenthelper.Shutdown) Option {
-	return func(o *baseSettings) {
-		o.componentOptions = append(o.componentOptions, componenthelper.WithShutdown(shutdown))
+		o.componentOptions = append(o.componentOptions, opts...)
 	}
 }
 

diff --git a/exporter/jaegerexporter/exporter.go b/exporter/jaegerexporter/exporter.go
@@ -29,6 +29,7 @@ import (
 	"google.golang.org/grpc/metadata"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/consumer/consumererror"
 	"go.opentelemetry.io/collector/consumer/pdata"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -60,8 +61,10 @@ func newTraceExporter(cfg *Config, logger *zap.Logger) (component.TracesExporter
 	)
 	exp, err := exporterhelper.NewTraceExporter(
 		cfg, logger, s.pushTraceData,
-		exporterhelper.WithStart(s.start),
-		exporterhelper.WithShutdown(s.shutdown),
+		exporterhelper.WithComponentOptions(
+			componenthelper.WithStart(s.start),
+			componenthelper.WithShutdown(s.shutdown),
+		),
 		exporterhelper.WithTimeout(cfg.TimeoutSettings),
 		exporterhelper.WithRetry(cfg.RetrySettings),
 		exporterhelper.WithQueue(cfg.QueueSettings),

diff --git a/exporter/kafkaexporter/factory.go b/exporter/kafkaexporter/factory.go
@@ -19,6 +19,7 @@ import (
 	"time"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
 )
@@ -115,7 +116,7 @@ func (f *kafkaExporterFactory) createTraceExporter(
 		exporterhelper.WithTimeout(exporterhelper.TimeoutSettings{Timeout: 0}),
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(exp.Close))
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(exp.Close)))
 }
 
 func (f *kafkaExporterFactory) createMetricsExporter(
@@ -140,5 +141,5 @@ func (f *kafkaExporterFactory) createMetricsExporter(
 		exporterhelper.WithTimeout(exporterhelper.TimeoutSettings{Timeout: 0}),
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(exp.Close))
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(exp.Close)))
 }
diff --git a/exporter/loggingexporter/logging_exporter.go b/exporter/loggingexporter/logging_exporter.go
@@ -25,6 +25,7 @@ import (
 	"go.uber.org/zap"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/consumer/pdata"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -420,7 +421,7 @@ func newTraceExporter(config config.Exporter, level string, logger *zap.Logger)
 		exporterhelper.WithTimeout(exporterhelper.TimeoutSettings{Timeout: 0}),
 		exporterhelper.WithRetry(exporterhelper.RetrySettings{Enabled: false}),
 		exporterhelper.WithQueue(exporterhelper.QueueSettings{Enabled: false}),
-		exporterhelper.WithShutdown(loggerSync(logger)),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(loggerSync(logger))),
 	)
 }
 
@@ -440,7 +441,7 @@ func newMetricsExporter(config config.Exporter, level string, logger *zap.Logger
 		exporterhelper.WithTimeout(exporterhelper.TimeoutSettings{Timeout: 0}),
 		exporterhelper.WithRetry(exporterhelper.RetrySettings{Enabled: false}),
 		exporterhelper.WithQueue(exporterhelper.QueueSettings{Enabled: false}),
-		exporterhelper.WithShutdown(loggerSync(logger)),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(loggerSync(logger))),
 	)
 }
 
@@ -460,7 +461,7 @@ func newLogsExporter(config config.Exporter, level string, logger *zap.Logger) (
 		exporterhelper.WithTimeout(exporterhelper.TimeoutSettings{Timeout: 0}),
 		exporterhelper.WithRetry(exporterhelper.RetrySettings{Enabled: false}),
 		exporterhelper.WithQueue(exporterhelper.QueueSettings{Enabled: false}),
-		exporterhelper.WithShutdown(loggerSync(logger)),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(loggerSync(logger))),
 	)
 }
 

diff --git a/exporter/opencensusexporter/factory.go b/exporter/opencensusexporter/factory.go
@@ -18,6 +18,7 @@ import (
 	"context"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/config/configgrpc"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -65,7 +66,7 @@ func createTraceExporter(ctx context.Context, params component.ExporterCreatePar
 		oce.pushTraceData,
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(oce.shutdown))
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(oce.shutdown)))
 }
 
 func createMetricsExporter(ctx context.Context, params component.ExporterCreateParams, cfg config.Exporter) (component.MetricsExporter, error) {
@@ -81,5 +82,5 @@ func createMetricsExporter(ctx context.Context, params component.ExporterCreateP
 		oce.pushMetricsData,
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(oce.shutdown))
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(oce.shutdown)))
 }
diff --git a/exporter/otlpexporter/factory.go b/exporter/otlpexporter/factory.go
@@ -18,6 +18,7 @@ import (
 	"context"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/config/configgrpc"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -72,7 +73,7 @@ func createTraceExporter(
 		exporterhelper.WithTimeout(oCfg.TimeoutSettings),
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(oce.shutdown))
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(oce.shutdown)))
 	if err != nil {
 		return nil, err
 	}
@@ -97,7 +98,7 @@ func createMetricsExporter(
 		exporterhelper.WithTimeout(oCfg.TimeoutSettings),
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(oce.shutdown),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(oce.shutdown)),
 	)
 	if err != nil {
 		return nil, err
@@ -123,7 +124,7 @@ func createLogsExporter(
 		exporterhelper.WithTimeout(oCfg.TimeoutSettings),
 		exporterhelper.WithRetry(oCfg.RetrySettings),
 		exporterhelper.WithQueue(oCfg.QueueSettings),
-		exporterhelper.WithShutdown(oce.shutdown),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(oce.shutdown)),
 	)
 	if err != nil {
 		return nil, err

diff --git a/exporter/prometheusremotewriteexporter/factory.go b/exporter/prometheusremotewriteexporter/factory.go
@@ -19,6 +19,7 @@ import (
 	"errors"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/component/componenthelper"
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/config/confighttp"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -61,7 +62,7 @@ func createMetricsExporter(_ context.Context, params component.ExporterCreatePar
 		exporterhelper.WithTimeout(prwCfg.TimeoutSettings),
 		exporterhelper.WithQueue(prwCfg.QueueSettings),
 		exporterhelper.WithRetry(prwCfg.RetrySettings),
-		exporterhelper.WithShutdown(prwe.Shutdown),
+		exporterhelper.WithComponentOptions(componenthelper.WithShutdown(prwe.Shutdown)),
 	)
 
 	return prwexp, err