diff --git a/lib/protoparser/clusternative/streamparser.go b/lib/protoparser/clusternative/streamparser.go index 218270e108..44e520de52 100644 --- a/lib/protoparser/clusternative/streamparser.go +++ b/lib/protoparser/clusternative/streamparser.go @@ -113,11 +113,10 @@ var ( ) type unmarshalWork struct { - wg *sync.WaitGroup - callback func(rows []storage.MetricRow) - reqBuf []byte - mrs []storage.MetricRow - lastResetTime uint64 + wg *sync.WaitGroup + callback func(rows []storage.MetricRow) + reqBuf []byte + mrs []storage.MetricRow } // Unmarshal implements common.UnmarshalWork