NewBlockQuerier returns a querier against the block reader and requested min and max time range.
(b BlockReader, mint, maxt int64)
| 159 | |
| 160 | // NewBlockQuerier returns a querier against the block reader and requested min and max time range. |
| 161 | func NewBlockQuerier(b BlockReader, mint, maxt int64) (storage.Querier, error) { |
| 162 | q, err := newBlockBaseQuerier(b, mint, maxt) |
| 163 | if err != nil { |
| 164 | return nil, err |
| 165 | } |
| 166 | return &blockQuerier{blockBaseQuerier: q}, nil |
| 167 | } |
| 168 | |
| 169 | func (q *blockQuerier) Select(ctx context.Context, sortSeries bool, hints *storage.SelectHints, ms ...*labels.Matcher) storage.SeriesSet { |
| 170 | return selectSeriesSet(ctx, sortSeries, hints, ms, q.index, q.chunks, q.tombstones, q.mint, q.maxt) |
searching dependent graphs…