From ce5e4c842a00746a729e2e530c28f68142e36037 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Sun, 26 May 2024 02:01:32 +0200 Subject: [PATCH] lib/logstorage: fix golangci-lint warnings --- lib/logstorage/pipe_copy.go | 2 +- lib/logstorage/pipe_delete.go | 2 +- lib/logstorage/pipe_field_names.go | 2 +- lib/logstorage/pipe_fields.go | 2 +- lib/logstorage/pipe_limit.go | 2 +- lib/logstorage/pipe_offset.go | 2 +- lib/logstorage/pipe_pack_json.go | 2 +- lib/logstorage/pipe_rename.go | 2 +- lib/logstorage/pipe_sort.go | 2 +- lib/logstorage/pipe_uniq.go | 2 +- lib/logstorage/pipe_unroll.go | 4 ++-- 11 files changed, 12 insertions(+), 12 deletions(-) diff --git a/lib/logstorage/pipe_copy.go b/lib/logstorage/pipe_copy.go index 340b1d97f..00d91edca 100644 --- a/lib/logstorage/pipe_copy.go +++ b/lib/logstorage/pipe_copy.go @@ -58,7 +58,7 @@ func (pc *pipeCopy) hasFilterInWithQuery() bool { return false } -func (pc *pipeCopy) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pc *pipeCopy) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pc, nil } diff --git a/lib/logstorage/pipe_delete.go b/lib/logstorage/pipe_delete.go index 0bf861076..9f2ca5a68 100644 --- a/lib/logstorage/pipe_delete.go +++ b/lib/logstorage/pipe_delete.go @@ -40,7 +40,7 @@ func (pd *pipeDelete) hasFilterInWithQuery() bool { return false } -func (pd *pipeDelete) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pd *pipeDelete) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pd, nil } diff --git a/lib/logstorage/pipe_field_names.go b/lib/logstorage/pipe_field_names.go index 3d4faf31a..1185eb75e 100644 --- a/lib/logstorage/pipe_field_names.go +++ b/lib/logstorage/pipe_field_names.go @@ -45,7 +45,7 @@ func (pf *pipeFieldNames) hasFilterInWithQuery() bool { return false } -func (pf *pipeFieldNames) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pf *pipeFieldNames) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pf, nil } diff --git a/lib/logstorage/pipe_fields.go b/lib/logstorage/pipe_fields.go index f0fb5873a..1724897df 100644 --- a/lib/logstorage/pipe_fields.go +++ b/lib/logstorage/pipe_fields.go @@ -57,7 +57,7 @@ func (pf *pipeFields) hasFilterInWithQuery() bool { return false } -func (pf *pipeFields) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pf *pipeFields) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pf, nil } diff --git a/lib/logstorage/pipe_limit.go b/lib/logstorage/pipe_limit.go index 2f4054393..f480cb46c 100644 --- a/lib/logstorage/pipe_limit.go +++ b/lib/logstorage/pipe_limit.go @@ -28,7 +28,7 @@ func (pl *pipeLimit) hasFilterInWithQuery() bool { return false } -func (pl *pipeLimit) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pl *pipeLimit) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pl, nil } diff --git a/lib/logstorage/pipe_offset.go b/lib/logstorage/pipe_offset.go index fc0363d6a..f5d07554c 100644 --- a/lib/logstorage/pipe_offset.go +++ b/lib/logstorage/pipe_offset.go @@ -28,7 +28,7 @@ func (po *pipeOffset) hasFilterInWithQuery() bool { return false } -func (po *pipeOffset) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (po *pipeOffset) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return po, nil } diff --git a/lib/logstorage/pipe_pack_json.go b/lib/logstorage/pipe_pack_json.go index ef647f6ec..d320fb6fb 100644 --- a/lib/logstorage/pipe_pack_json.go +++ b/lib/logstorage/pipe_pack_json.go @@ -42,7 +42,7 @@ func (pp *pipePackJSON) hasFilterInWithQuery() bool { return false } -func (pp *pipePackJSON) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pp *pipePackJSON) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pp, nil } diff --git a/lib/logstorage/pipe_rename.go b/lib/logstorage/pipe_rename.go index 44ded34ac..6911413fc 100644 --- a/lib/logstorage/pipe_rename.go +++ b/lib/logstorage/pipe_rename.go @@ -62,7 +62,7 @@ func (pr *pipeRename) hasFilterInWithQuery() bool { return false } -func (pr *pipeRename) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pr *pipeRename) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pr, nil } diff --git a/lib/logstorage/pipe_sort.go b/lib/logstorage/pipe_sort.go index da87c7a83..0b6d3cbbd 100644 --- a/lib/logstorage/pipe_sort.go +++ b/lib/logstorage/pipe_sort.go @@ -75,7 +75,7 @@ func (ps *pipeSort) hasFilterInWithQuery() bool { return false } -func (ps *pipeSort) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (ps *pipeSort) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return ps, nil } diff --git a/lib/logstorage/pipe_uniq.go b/lib/logstorage/pipe_uniq.go index c261aea05..c80c5c657 100644 --- a/lib/logstorage/pipe_uniq.go +++ b/lib/logstorage/pipe_uniq.go @@ -59,7 +59,7 @@ func (pu *pipeUniq) hasFilterInWithQuery() bool { return false } -func (pu *pipeUniq) initFilterInValues(cache map[string][]string, getFieldValuesFunc getFieldValuesFunc) (pipe, error) { +func (pu *pipeUniq) initFilterInValues(_ map[string][]string, _ getFieldValuesFunc) (pipe, error) { return pu, nil } diff --git a/lib/logstorage/pipe_unroll.go b/lib/logstorage/pipe_unroll.go index 180b5687b..2a2978f0b 100644 --- a/lib/logstorage/pipe_unroll.go +++ b/lib/logstorage/pipe_unroll.go @@ -144,7 +144,7 @@ func (pup *pipeUnrollProcessor) writeBlock(workerID uint, br *blockResult) { if needStop(pup.stopCh) { return } - shard.writeUnrolledFields(br, pu.fields, columnValues, rowIdx) + shard.writeUnrolledFields(pu.fields, columnValues, rowIdx) } else { fields = fields[:0] for i, f := range pu.fields { @@ -163,7 +163,7 @@ func (pup *pipeUnrollProcessor) writeBlock(workerID uint, br *blockResult) { shard.a.reset() } -func (shard *pipeUnrollProcessorShard) writeUnrolledFields(br *blockResult, fieldNames []string, columnValues [][]string, rowIdx int) { +func (shard *pipeUnrollProcessorShard) writeUnrolledFields(fieldNames []string, columnValues [][]string, rowIdx int) { // unroll values at rowIdx row shard.unrolledValues = slicesutil.SetLength(shard.unrolledValues, len(columnValues))