self documenting pipeline process ifc

grafana · Jan 5, 2021 · 89ed39c · 89ed39c
1 parent ad803af
commit 89ed39c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/logql/log/pipeline.go b/pkg/logql/log/pipeline.go
@@ -19,8 +19,8 @@ type Pipeline interface {
 // StreamPipeline transform and filter log lines and labels.
 // A StreamPipeline never mutate the received line.
 type StreamPipeline interface {
-	Process(line []byte) ([]byte, LabelsResult, bool)
-	ProcessString(line string) (string, LabelsResult, bool)
+	Process(line []byte) (resultLine []byte, resultLabels LabelsResult, skip bool)
+	ProcessString(line string) (resultLine string, resultLabels LabelsResult, skip bool)
 }
 
 // Stage is a single step of a Pipeline.