Skip to content

Commit d970dd1

Browse files
committed
update lsmintervalprocessor to remove deprecated NewTransformContext
1 parent 3eb80e4 commit d970dd1

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

processor/lsmintervalprocessor/factory.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ func createMetricsProcessor(
5757
ivlDef := intervalDef{Duration: ivl.Duration}
5858
if len(ivl.Statements) > 0 {
5959
parser, err := ottldatapoint.NewParser(
60-
ottlfuncs.StandardFuncs[ottldatapoint.TransformContext](),
60+
ottlfuncs.StandardFuncs[*ottldatapoint.TransformContext](),
6161
set.TelemetrySettings,
6262
)
6363
if err != nil {
@@ -88,5 +88,5 @@ func createMetricsProcessor(
8888

8989
type intervalDef struct {
9090
Duration time.Duration
91-
Statements *ottl.StatementSequence[ottldatapoint.TransformContext]
91+
Statements *ottl.StatementSequence[*ottldatapoint.TransformContext]
9292
}

processor/lsmintervalprocessor/processor.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -543,7 +543,8 @@ func (p *Processor) exportForInterval(
543543
for k := 0; k < metrics.Len(); k++ {
544544
metric := metrics.At(k)
545545
executeTransform := func(dp any) {
546-
dCtx := ottldatapoint.NewTransformContext(dp, metric, metrics, scope.Scope(), res.Resource(), scope, res)
546+
dCtx := ottldatapoint.NewTransformContextPtr(res, scope, metric, dp)
547+
defer dCtx.Close()
547548
if err := ivl.Statements.Execute(ctx, dCtx); err != nil {
548549
errs = append(errs, fmt.Errorf("failed to execute ottl statement for interval %s: %w", ivl.Duration, err))
549550
}

0 commit comments

Comments
 (0)