MCPcopy
hub / github.com/prometheus/prometheus / NewReader

Function NewReader

tsdb/wlog/reader.go:41–43  ·  view source on GitHub ↗

NewReader returns a new reader.

(r io.Reader)

Source from the content-addressed store, hash-verified

39
40// NewReader returns a new reader.
41func NewReader(r io.Reader) *Reader {
42 return &Reader{rdr: r, decBuf: compression.NewSyncDecodeBuffer()}
43}
44
45// Next advances the reader to the next records and returns true if it exists.
46// It must not be called again after it returned false.

Callers 15

InitMethod · 0.92
loadChunkSnapshotMethod · 0.92
findLastSeriesIDMethod · 0.92
testOOOWALWriteFunction · 0.92
testWBLAndMmapReplayFunction · 0.92
readTestWALFunction · 0.92

Calls 1

NewSyncDecodeBufferFunction · 0.92

Used in the wild real call sites across dependent graphs

searching dependent graphs…