From f38fa2d184b9be73fcbb770ea4ed6eae6c5da034 Mon Sep 17 00:00:00 2001 From: Sandeep Sukhani Date: Mon, 5 Aug 2019 13:56:08 +0530 Subject: [PATCH] gofmt file --- pkg/querier/tail.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/querier/tail.go b/pkg/querier/tail.go index 52076b37cd..b788af1e54 100644 --- a/pkg/querier/tail.go +++ b/pkg/querier/tail.go @@ -37,7 +37,7 @@ type TailResponse struct { type Tailer struct { // openStreamIterator is for streams already open openStreamIterator iter.HeapIterator - streamMtx sync.Mutex // for synchronizing access to openStreamIterator + streamMtx sync.Mutex // for synchronizing access to openStreamIterator currEntry logproto.Entry currLabels string @@ -264,7 +264,7 @@ func newTailer( tailMaxDuration time.Duration, ) *Tailer { t := Tailer{ - openStreamIterator: iter.NewHeapIterator([]iter.EntryIterator{historicEntries}, logproto.FORWARD), + openStreamIterator: iter.NewHeapIterator([]iter.EntryIterator{historicEntries}, logproto.FORWARD), querierTailClients: querierTailClients, delayFor: delayFor, responseChan: make(chan *TailResponse, bufferSizeForTailResponse),