lazyquery

Documentation

Index

• 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(matchers ...*labels.Matcher) ([]string, storage.Warnings, error)
  • func (l LazyQuerier) LabelValues(name string, matchers ...*labels.Matcher) ([]string, storage.Warnings, error)
  • func (l LazyQuerier) Select(selectSorted bool, params *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet
• type LazyQueryable
  • func (lq LazyQueryable) Querier(ctx context.Context, mint, maxt int64) (storage.Querier, error)

Functions

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 chunk.Store for the chunk tar HTTP handler.

func (LazyQuerier) LabelNames

func (l LazyQuerier) LabelNames(matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

LabelNames implements Storage.Querier

func (LazyQuerier) LabelValues

func (l LazyQuerier) LabelValues(name string, matchers ...*labels.Matcher) ([]string, storage.Warnings, error)

LabelValues implements Storage.Querier

func (LazyQuerier) Select

func (l LazyQuerier) Select(selectSorted bool, params *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet

Select 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