[logstransformprocessor]: remove support for storage (open-telemetry#…

…12425) * feat(logstransformprocessor): remove support for storage Signed-off-by: Dominik Rosiek <[email protected]> * chore: changelog Signed-off-by: Dominik Rosiek <[email protected]>
sakulali · Jul 14, 2022 · f4d35b0 · f4d35b0
1 parent 21fa8bb
commit f4d35b0
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 6 deletions.
diff --git a/processor/logstransformprocessor/processor.go b/processor/logstransformprocessor/processor.go
@@ -24,6 +24,7 @@ import (
 
  "go.opentelemetry.io/collector/component"
  "go.opentelemetry.io/collector/config"
+ "go.opentelemetry.io/collector/extension/experimental/storage"
  "go.opentelemetry.io/collector/pdata/plog"
  "go.uber.org/zap"
 
@@ -86,12 +87,8 @@ func (ltp *logsTransformProcessor) Start(ctx context.Context, host component.Hos
  return err
  }
 
- storageClient, err := adapter.GetStorageClient(ctx, ltp.id, component.KindProcessor, host)
- if err != nil {
- return err
- }
-
- err = pipe.Start(adapter.GetPersister(storageClient))
+ // There is no need for this processor to use storage
+ err = pipe.Start(adapter.GetPersister(storage.NewNopClient()))
  if err != nil {
  return err
  }

diff --git a/unreleased/drosiek-logstransform.yaml b/unreleased/drosiek-logstransform.yaml
@@ -0,0 +1,16 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: bug_fix
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: logstransformprocessor
+
+# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Remove support for storage
+
+# One or more tracking issues related to the change
+issues: [12424]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext: