Skip to content

Commit

Permalink
Update chunkedSeries, chunkedSeriesIterator for new interfaces
Browse files Browse the repository at this point in the history
  • Loading branch information
leizor committed Mar 28, 2024
1 parent 10bb351 commit dd088cc
Showing 1 changed file with 10 additions and 7 deletions.
17 changes: 10 additions & 7 deletions storage/remote/codec.go
Original file line number Diff line number Diff line change
Expand Up @@ -607,15 +607,17 @@ func (s *chunkedSeriesSet) Warnings() annotations.Annotations {
return nil
}

// chunkedSeries implements storage.Series.
type chunkedSeries struct {
labels []prompb.Label
chunks []prompb.Chunk
mint, maxt int64
}

var _ storage.Series = &chunkedSeries{}

func (s *chunkedSeries) Labels() labels.Labels {
return labelProtosToLabels(s.labels)
b := labels.NewScratchBuilder(len(s.labels))
return labelProtosToLabels(&b, s.labels)
}

func (s *chunkedSeries) Iterator(it chunkenc.Iterator) chunkenc.Iterator {
Expand All @@ -627,7 +629,6 @@ func (s *chunkedSeries) Iterator(it chunkenc.Iterator) chunkenc.Iterator {
return newChunkedSeriesIterator(s.chunks, s.mint, s.maxt)
}

// chunkedSeriesIterator implements chunkenc.Iterator.
type chunkedSeriesIterator struct {
chunks []prompb.Chunk
idx int
Expand All @@ -638,6 +639,8 @@ type chunkedSeriesIterator struct {
err error
}

var _ chunkenc.Iterator = &chunkedSeriesIterator{}

func newChunkedSeriesIterator(chunks []prompb.Chunk, mint, maxt int64) *chunkedSeriesIterator {
it := &chunkedSeriesIterator{}
it.reset(chunks, mint, maxt)
Expand Down Expand Up @@ -740,12 +743,12 @@ func (it *chunkedSeriesIterator) At() (ts int64, v float64) {
return it.cur.At()
}

func (it *chunkedSeriesIterator) AtHistogram() (int64, *histogram.Histogram) {
return it.cur.AtHistogram()
func (it *chunkedSeriesIterator) AtHistogram(h *histogram.Histogram) (int64, *histogram.Histogram) {
return it.cur.AtHistogram(h)
}

func (it *chunkedSeriesIterator) AtFloatHistogram() (int64, *histogram.FloatHistogram) {
return it.cur.AtFloatHistogram()
func (it *chunkedSeriesIterator) AtFloatHistogram(fh *histogram.FloatHistogram) (int64, *histogram.FloatHistogram) {
return it.cur.AtFloatHistogram(fh)
}

func (it *chunkedSeriesIterator) AtT() int64 {
Expand Down

0 comments on commit dd088cc

Please sign in to comment.