From 05ac0c37625fba71d1811afe0f33ce6e606e0814 Mon Sep 17 00:00:00 2001 From: Callum Styan Date: Sun, 24 Nov 2024 19:22:36 -0800 Subject: [PATCH] remove minor dead code that was missed in a PR review Signed-off-by: Callum Styan --- pkg/logql/log/pipeline.go | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/pkg/logql/log/pipeline.go b/pkg/logql/log/pipeline.go index a205039dd7715..181947fc07435 100644 --- a/pkg/logql/log/pipeline.go +++ b/pkg/logql/log/pipeline.go @@ -68,7 +68,7 @@ func (n *noopPipeline) ForStream(labels labels.Labels) StreamPipeline { } n.mu.RUnlock() - sp := &noopStreamPipeline{n.baseBuilder.ForLabels(labels, h), make([]int, 0, 10)} + sp := &noopStreamPipeline{n.baseBuilder.ForLabels(labels, h)} n.mu.Lock() defer n.mu.Unlock() @@ -93,8 +93,7 @@ func IsNoopPipeline(p Pipeline) bool { } type noopStreamPipeline struct { - builder *LabelsBuilder - offsetsBuf []int + builder *LabelsBuilder } func (n noopStreamPipeline) ReferencedStructuredMetadata() bool { @@ -181,13 +180,12 @@ func NewPipeline(stages []Stage) Pipeline { } type streamPipeline struct { - stages []Stage - builder *LabelsBuilder - offsetsBuf []int + stages []Stage + builder *LabelsBuilder } func NewStreamPipeline(stages []Stage, labelsBuilder *LabelsBuilder) StreamPipeline { - return &streamPipeline{stages, labelsBuilder, make([]int, 0, 10)} + return &streamPipeline{stages, labelsBuilder} } func (p *pipeline) ForStream(labels labels.Labels) StreamPipeline {