storage: simplify sampleRing fix

Signed-off-by: beorn7 <beorn@grafana.com>
pull/13682/head
beorn7 9 months ago
parent d5ab1851dc
commit 7df0b9b92d

@ -306,10 +306,9 @@ func (r *sampleRing) reset() {
r.iBuf = r.iBuf[:0] r.iBuf = r.iBuf[:0]
} }
// Returns the current iterator. Invalidates previously returned iterators. // Resets and returns the iterator. Invalidates previously returned iterators.
func (r *sampleRing) iterator() *SampleRingIterator { func (r *sampleRing) iterator() *SampleRingIterator {
r.it.r = r r.it.reset(r)
r.it.i = -1
return &r.it return &r.it
} }
@ -322,34 +321,36 @@ type SampleRingIterator struct {
f float64 f float64
h *histogram.Histogram h *histogram.Histogram
fh *histogram.FloatHistogram fh *histogram.FloatHistogram
currType chunkenc.ValueType }
func (it *SampleRingIterator) reset(r *sampleRing) {
it.r = r
it.i = -1
it.h = nil
it.fh = nil
} }
func (it *SampleRingIterator) Next() chunkenc.ValueType { func (it *SampleRingIterator) Next() chunkenc.ValueType {
it.i++ it.i++
it.currType = chunkenc.ValNone
if it.i >= it.r.l { if it.i >= it.r.l {
return it.currType return chunkenc.ValNone
} }
switch it.r.bufInUse { switch it.r.bufInUse {
case fBuf: case fBuf:
s := it.r.atF(it.i) s := it.r.atF(it.i)
it.t = s.t it.t = s.t
it.f = s.f it.f = s.f
it.currType = chunkenc.ValFloat return chunkenc.ValFloat
case hBuf: case hBuf:
s := it.r.atH(it.i) s := it.r.atH(it.i)
it.t = s.t it.t = s.t
it.h = s.h it.h = s.h
it.currType = chunkenc.ValHistogram return chunkenc.ValHistogram
case fhBuf: case fhBuf:
s := it.r.atFH(it.i) s := it.r.atFH(it.i)
it.t = s.t it.t = s.t
it.fh = s.fh it.fh = s.fh
it.currType = chunkenc.ValFloatHistogram return chunkenc.ValFloatHistogram
}
if it.currType != chunkenc.ValNone {
return it.currType
} }
s := it.r.at(it.i) s := it.r.at(it.i)
it.t = s.T() it.t = s.T()
@ -357,31 +358,24 @@ func (it *SampleRingIterator) Next() chunkenc.ValueType {
case chunkenc.ValHistogram: case chunkenc.ValHistogram:
it.h = s.H() it.h = s.H()
it.fh = nil it.fh = nil
it.currType = chunkenc.ValHistogram return chunkenc.ValHistogram
case chunkenc.ValFloatHistogram: case chunkenc.ValFloatHistogram:
it.fh = s.FH() it.fh = s.FH()
it.h = nil it.h = nil
it.currType = chunkenc.ValFloatHistogram return chunkenc.ValFloatHistogram
default: default:
it.f = s.F() it.f = s.F()
it.currType = chunkenc.ValFloat return chunkenc.ValFloat
} }
return it.currType
} }
// At returns the current float element of the iterator. // At returns the current float element of the iterator.
func (it *SampleRingIterator) At() (int64, float64) { func (it *SampleRingIterator) At() (int64, float64) {
if it.currType != chunkenc.ValFloat {
panic(fmt.Sprintf("SampleRingIterator: impossible to read a float, current value type is %v", it.currType))
}
return it.t, it.f return it.t, it.f
} }
// AtHistogram returns the current histogram element of the iterator. // AtHistogram returns the current histogram element of the iterator.
func (it *SampleRingIterator) AtHistogram() (int64, *histogram.Histogram) { func (it *SampleRingIterator) AtHistogram() (int64, *histogram.Histogram) {
if it.currType != chunkenc.ValHistogram {
panic(fmt.Sprintf("SampleRingIterator: impossible to read a histogram, current value type is %v", it.currType))
}
return it.t, it.h return it.t, it.h
} }
@ -390,18 +384,15 @@ func (it *SampleRingIterator) AtHistogram() (int64, *histogram.Histogram) {
// An optional histogram.FloatHistogram can be provided to avoid allocating a new // An optional histogram.FloatHistogram can be provided to avoid allocating a new
// object for the conversion. // object for the conversion.
func (it *SampleRingIterator) AtFloatHistogram(fh *histogram.FloatHistogram) (int64, *histogram.FloatHistogram) { func (it *SampleRingIterator) AtFloatHistogram(fh *histogram.FloatHistogram) (int64, *histogram.FloatHistogram) {
if it.currType != chunkenc.ValHistogram && it.currType != chunkenc.ValFloatHistogram { if it.fh == nil {
panic(fmt.Sprintf("SampleRingIterator: impossible to read a float histogram, current value type is %v", it.currType)) return it.t, it.h.ToFloat(fh)
} }
if it.currType == chunkenc.ValFloatHistogram {
if fh != nil { if fh != nil {
it.fh.CopyTo(fh) it.fh.CopyTo(fh)
return it.t, fh return it.t, fh
} }
return it.t, it.fh.Copy() return it.t, it.fh.Copy()
} }
return it.t, it.h.ToFloat(fh)
}
func (it *SampleRingIterator) AtT() int64 { func (it *SampleRingIterator) AtT() int64 {
return it.t return it.t

Loading…
Cancel
Save