From e45bde549637cea4c8283fe8185bf6e248538475 Mon Sep 17 00:00:00 2001 From: Daniel Jaglowski Date: Wed, 3 Apr 2024 14:08:33 -0500 Subject: [PATCH] [chore][pkg/stanza] Cleanup move operator files (#32064) Contributes to #32058 --- .../transformer/move/{move.go => config.go} | 22 ------------- .../operator/transformer/move/transformer.go | 33 +++++++++++++++++++ .../{move_test.go => transformer_test.go} | 0 3 files changed, 33 insertions(+), 22 deletions(-) rename pkg/stanza/operator/transformer/move/{move.go => config.go} (73%) create mode 100644 pkg/stanza/operator/transformer/move/transformer.go rename pkg/stanza/operator/transformer/move/{move_test.go => transformer_test.go} (100%) diff --git a/pkg/stanza/operator/transformer/move/move.go b/pkg/stanza/operator/transformer/move/config.go similarity index 73% rename from pkg/stanza/operator/transformer/move/move.go rename to pkg/stanza/operator/transformer/move/config.go index bb88b1fa92e4..77a11c92fc3e 100644 --- a/pkg/stanza/operator/transformer/move/move.go +++ b/pkg/stanza/operator/transformer/move/config.go @@ -4,7 +4,6 @@ package move // import "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/transformer/move" import ( - "context" "fmt" "go.uber.org/zap" @@ -56,24 +55,3 @@ func (c Config) Build(logger *zap.SugaredLogger) (operator.Operator, error) { To: c.To, }, nil } - -// Transformer is an operator that moves a field's value to a new field -type Transformer struct { - helper.TransformerOperator - From entry.Field - To entry.Field -} - -// Process will process an entry with a move transformation. -func (p *Transformer) Process(ctx context.Context, entry *entry.Entry) error { - return p.ProcessWith(ctx, entry, p.Transform) -} - -// Transform will apply the move operation to an entry -func (p *Transformer) Transform(e *entry.Entry) error { - val, exist := p.From.Delete(e) - if !exist { - return fmt.Errorf("move: field does not exist: %s", p.From.String()) - } - return p.To.Set(e, val) -} diff --git a/pkg/stanza/operator/transformer/move/transformer.go b/pkg/stanza/operator/transformer/move/transformer.go new file mode 100644 index 000000000000..c491df9c51f1 --- /dev/null +++ b/pkg/stanza/operator/transformer/move/transformer.go @@ -0,0 +1,33 @@ +// Copyright The OpenTelemetry Authors +// SPDX-License-Identifier: Apache-2.0 + +package move // import "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/transformer/move" + +import ( + "context" + "fmt" + + "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/entry" + "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/stanza/operator/helper" +) + +// Transformer is an operator that moves a field's value to a new field +type Transformer struct { + helper.TransformerOperator + From entry.Field + To entry.Field +} + +// Process will process an entry with a move transformation. +func (t *Transformer) Process(ctx context.Context, entry *entry.Entry) error { + return t.ProcessWith(ctx, entry, t.Transform) +} + +// Transform will apply the move operation to an entry +func (t *Transformer) Transform(e *entry.Entry) error { + val, exist := t.From.Delete(e) + if !exist { + return fmt.Errorf("move: field does not exist: %s", t.From.String()) + } + return t.To.Set(e, val) +} diff --git a/pkg/stanza/operator/transformer/move/move_test.go b/pkg/stanza/operator/transformer/move/transformer_test.go similarity index 100% rename from pkg/stanza/operator/transformer/move/move_test.go rename to pkg/stanza/operator/transformer/move/transformer_test.go