Versions in this module Expand all Collapse all v2 v2.13.1 Oct 8, 2023 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") + var NoopSeriesIt = noopSeriesIterator + 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(delta int64) *BufferedSeriesIterator + func NewBufferIterator(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) ReduceDelta(delta int64) bool + func (b *BufferedSeriesIterator) Reset(it SeriesIterator) + func (b *BufferedSeriesIterator) Seek(t int64) bool + func (b *BufferedSeriesIterator) Values() (int64, float64) + type Querier interface + Close func() error + LabelNames func() ([]string, Warnings, error) + LabelValues func(name string) ([]string, Warnings, error) + Select func(*SelectParams, ...*labels.Matcher) (SeriesSet, Warnings, error) + func NewMergeQuerier(primaryQuerier Querier, 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 + End int64 + Func string + Start int64 + 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, querier *mergeQuerier) 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 + type Warnings []error Other modules containing this package github.com/zpascal/prometheus