added shutdown function

coralogix · Jul 12, 2023 · 764b59e · 764b59e
1 parent 5b6348a
commit 764b59e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/otel-agent/ecs-ec2/ecsattributesprocessor/factory.go b/otel-agent/ecs-ec2/ecsattributesprocessor/factory.go
@@ -62,7 +62,8 @@ func (f *factory) createLogsProcessor(
 		return nil, fmt.Errorf("invalid config for processor %s", typeStr)
 	}
 
-	if err := config.validate(); err != nil {
+	// initialise config
+	if err := config.init(); err != nil {
 		return nil, err
 	}
 
@@ -74,5 +75,6 @@ func (f *factory) createLogsProcessor(
 		processLogsFunc(logger, config),
 		processorhelper.WithCapabilities(consumerCapabilities),
 		processorhelper.WithStart(startFn(logger)),
+		processorhelper.WithShutdown(shutdownFn()),
 	)
 }