lazyquery

Documentation

Index

• func NewErrSeriesSet(err error) storage.SeriesSet
• func NewLazyQuerier(next storage.Querier) storage.Querier
• func NewLazyQueryable(q storage.Queryable) storage.Queryable
• type LazyQuerier
  • func (l LazyQuerier) Close() error
  • func (l LazyQuerier) Get(ctx context.Context, userID string, from, through model.Time, ...) ([]chunk.Chunk, error)
  • func (l LazyQuerier) LabelNames() ([]string, storage.Warnings, error)
  • func (l LazyQuerier) LabelValues(name string) ([]string, storage.Warnings, error)
  • func (l LazyQuerier) Select(params *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)
  • func (l LazyQuerier) SelectSorted(params *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)
• type LazyQueryable
  • func (lq LazyQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

Functions

func NewErrSeriesSet

func NewErrSeriesSet(err error) storage.SeriesSet

func NewLazyQuerier

func NewLazyQuerier(next storage.Querier) storage.Querier

NewLazyQuerier wraps a storage.Querier, does the Select in the background. Return value cannot be used from more than one goroutine simultaneously.

func NewLazyQueryable

func NewLazyQueryable(q storage.Queryable) storage.Queryable

NewLazyQueryable returns a lazily wrapped queryable

Types

type LazyQuerier

type LazyQuerier struct {
	// contains filtered or unexported fields
}

LazyQuerier is a lazy-loaded adapter for a storage.Querier

func (LazyQuerier) Close

func (l LazyQuerier) Close() error

Close implements Storage.Querier

func (LazyQuerier) Get

func (l LazyQuerier) Get(ctx context.Context, userID string, from, through model.Time, matchers ...*labels.Matcher) ([]chunk.Chunk, error)

Get implements ChunkStore for the chunk tar HTTP handler.

func (LazyQuerier) LabelNames

func (l LazyQuerier) LabelNames() ([]string, storage.Warnings, error)

LabelNames implements Storage.Querier

func (LazyQuerier) LabelValues

func (l LazyQuerier) LabelValues(name string) ([]string, storage.Warnings, error)

LabelValues implements Storage.Querier

func (LazyQuerier) Select

func (l LazyQuerier) Select(params *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

Select implements Storage.Querier

func (LazyQuerier) SelectSorted

func (l LazyQuerier) SelectSorted(params *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

SelectSorted implements Storage.Querier

type LazyQueryable

type LazyQueryable struct {
	// contains filtered or unexported fields
}

LazyQueryable wraps a storage.Queryable

func (LazyQueryable) Querier

func (lq LazyQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

Querier implements storage.Queryable