From d5b2af1ae012de6496d07bac7862a66e5dbdc241 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Sun, 19 May 2024 21:28:11 +0200 Subject: [PATCH] wip --- lib/logstorage/pipe_unpack_json.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/lib/logstorage/pipe_unpack_json.go b/lib/logstorage/pipe_unpack_json.go index 52a3d2b4a..214eae5ec 100644 --- a/lib/logstorage/pipe_unpack_json.go +++ b/lib/logstorage/pipe_unpack_json.go @@ -37,12 +37,11 @@ func (pu *pipeUnpackJSON) updateNeededFields(neededFields, unneededFields fields } } -func (pu *pipeUnpackJSON) newPipeProcessor(workersCount int, stopCh <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor { +func (pu *pipeUnpackJSON) newPipeProcessor(workersCount int, _ <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor { shards := make([]pipeUnpackJSONProcessorShard, workersCount) pup := &pipeUnpackJSONProcessor{ pu: pu, - stopCh: stopCh, ppBase: ppBase, shards: shards, @@ -52,7 +51,6 @@ func (pu *pipeUnpackJSON) newPipeProcessor(workersCount int, stopCh <-chan struc type pipeUnpackJSONProcessor struct { pu *pipeUnpackJSON - stopCh <-chan struct{} ppBase pipeProcessor shards []pipeUnpackJSONProcessorShard