github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-19 21:27:53 +02:00
parent 3d674afd45
commit 030d3823b9
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/logstorage/pipe_extract.go
View file

@ -60,7 +60,7 @@ func (pe *pipeExtract) updateNeededFields(neededFields, unneededFields fieldsSet
} }
} }
func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor { func (pe *pipeExtract) newPipeProcessor(workersCount int, _ <-chan struct{}, _ func(), ppBase pipeProcessor) pipeProcessor {
shards := make([]pipeExtractProcessorShard, workersCount) shards := make([]pipeExtractProcessorShard, workersCount)
for i := range shards { for i := range shards {
ef := newExtractFormat(pe.steps) ef := newExtractFormat(pe.steps)
@ -78,7 +78,6 @@ func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}
pep := &pipeExtractProcessor{ pep := &pipeExtractProcessor{
pe: pe, pe: pe,
stopCh: stopCh,
ppBase: ppBase, ppBase: ppBase,
shards: shards, shards: shards,
@ -88,7 +87,6 @@ func (pe *pipeExtract) newPipeProcessor(workersCount int, stopCh <-chan struct{}
type pipeExtractProcessor struct { type pipeExtractProcessor struct {
pe *pipeExtract pe *pipeExtract
stopCh <-chan struct{}
ppBase pipeProcessor ppBase pipeProcessor
shards []pipeExtractProcessorShard shards []pipeExtractProcessorShard