Define 'Start' and 'Shutdown' functions.

open-telemetry · Nov 1, 2024 · 80976e9 · 80976e9
1 parent b4a9b83
commit 80976e9
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/connector/blobuploadconnector/logs.go b/connector/blobuploadconnector/logs.go
@@ -14,10 +14,11 @@ import (
 
 type passThroughLogsConnector struct {
 	nextConsumer consumer.Logs
-	component.StartFunc
-	component.ShutdownFunc
 }
 
+func (c *passThroughLogsConnector) Start(_ context.Context, _ component.Host) error { return nil }
+func (c *passThroughLogsConnector) Shutdown(_ context.Context) error                { return nil }
+
 func (c *passThroughLogsConnector) ConsumeLogs(ctx context.Context, ld plog.Logs) error {
 	return c.nextConsumer.ConsumeLogs(ctx, ld)
 }

diff --git a/connector/blobuploadconnector/traces.go b/connector/blobuploadconnector/traces.go
@@ -18,6 +18,9 @@ type passThroughTracesConnector struct {
 	component.ShutdownFunc
 }
 
+func (c *passThroughTracesConnector) Start(_ context.Context, _ component.Host) error { return nil }
+func (c *passThroughTracesConnector) Shutdown(_ context.Context) error                { return nil }
+
 func (c *passThroughTracesConnector) ConsumeTraces(ctx context.Context, td ptrace.Traces) error {
 	return c.nextConsumer.ConsumeTraces(ctx, td)
 }