Versions in this module Expand all Collapse all v1 v1.7.2 Feb 15, 2018 Changes in this version + var ErrDuplicateSampleForTimestamp = errors.New("duplicate sample for timestamp") + var ErrNotFound = errors.New("not found") + var ErrOutOfBounds = errors.New("out of bounds") + var ErrOutOfOrderSample = errors.New("out of order sample") + type Appender interface + Add func(l labels.Labels, t int64, v float64) (uint64, error) + AddFast func(l labels.Labels, ref uint64, t int64, v float64) error + Commit func() error + Rollback func() error + type BufferedSeriesIterator struct + func NewBuffer(it SeriesIterator, delta int64) *BufferedSeriesIterator + func (b *BufferedSeriesIterator) Buffer() SeriesIterator + func (b *BufferedSeriesIterator) Err() error + func (b *BufferedSeriesIterator) Next() bool + func (b *BufferedSeriesIterator) PeekBack(n int) (t int64, v float64, ok bool) + func (b *BufferedSeriesIterator) Seek(t int64) bool + func (b *BufferedSeriesIterator) Values() (int64, float64) + type Querier interface + Close func() error + LabelValues func(name string) ([]string, error) + Select func(*SelectParams, ...*labels.Matcher) (SeriesSet, error) + func NewMergeQuerier(queriers []Querier) Querier + func NoopQuerier() Querier + type Queryable interface + Querier func(ctx context.Context, mint, maxt int64) (Querier, error) + type QueryableFunc func(ctx context.Context, mint, maxt int64) (Querier, error) + func (f QueryableFunc) Querier(ctx context.Context, mint, maxt int64) (Querier, error) + type SelectParams struct + Func string + Step int64 + type Series interface + Iterator func() SeriesIterator + Labels func() labels.Labels + type SeriesIterator interface + At func() (t int64, v float64) + Err func() error + Next func() bool + Seek func(t int64) bool + type SeriesSet interface + At func() Series + Err func() error + Next func() bool + func NewMergeSeriesSet(sets []SeriesSet) SeriesSet + func NoopSeriesSet() SeriesSet + type Storage interface + Appender func() (Appender, error) + Close func() error + StartTime func() (int64, error) + func NewFanout(logger log.Logger, primary Storage, secondaries ...Storage) Storage