MCPcopy
hub / github.com/prometheus/prometheus / createFakeReaderAndIterables

Function createFakeReaderAndIterables

tsdb/querier_test.go:751–773  ·  view source on GitHub ↗

Samples in each slice are assumed to be sorted.

(s ...[]chunks.Sample)

Source from the content-addressed store, hash-verified

749
750// Samples in each slice are assumed to be sorted.
751func createFakeReaderAndIterables(s ...[]chunks.Sample) (*fakeChunksReader, []chunks.Meta) {
752 f := &fakeChunksReader{
753 chks: map[chunks.ChunkRef]chunkenc.Chunk{},
754 iterables: map[chunks.ChunkRef]chunkenc.Iterable{},
755 }
756 chks := make([]chunks.Meta, 0, len(s))
757
758 for ref, samples := range s {
759 f.iterables[chunks.ChunkRef(ref)] = &mockIterable{s: samples}
760
761 var minTime, maxTime int64
762 if len(samples) > 0 {
763 minTime = samples[0].T()
764 maxTime = samples[len(samples)-1].T()
765 }
766 chks = append(chks, chunks.Meta{
767 Ref: chunks.ChunkRef(ref),
768 MinTime: minTime,
769 MaxTime: maxTime,
770 })
771 }
772 return f, chks
773}
774
775func (r *fakeChunksReader) ChunkOrIterable(meta chunks.Meta) (chunkenc.Chunk, chunkenc.Iterable, error) {
776 if chk, ok := r.chks[meta.Ref]; ok {

Calls 2

ChunkRefTypeAlias · 0.92
TMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…