querier

Documentation

Index

• func NewSeries(set *V3ioSeriesSet) utils.Series
• func NewSetSorter(set utils.SeriesSet) (utils.SeriesSet, error)
• type IterSortMerger
  • func (im *IterSortMerger) At() utils.Series
  • func (im *IterSortMerger) Err() error
  • func (im *IterSortMerger) Next() bool
• type SelectParams
• type V3ioQuerier
  • func NewV3ioQuerier(container v3io.Container, logger logger.Logger, mint, maxt int64, ...) *V3ioQuerier
  • func (q *V3ioQuerier) Close() error
  • func (q *V3ioQuerier) LabelNames() ([]string, error)
  • func (q *V3ioQuerier) LabelValues(labelKey string) (result []string, err error)
  • func (q *V3ioQuerier) Select(name, functions string, step int64, filter string) (utils.SeriesSet, error)
  • func (q *V3ioQuerier) SelectOverlap(name, functions string, step int64, windows []int, filter string) (utils.SeriesSet, error)
  • func (q *V3ioQuerier) SelectProm(name, functions string, step int64, filter string, noAggr bool) (utils.SeriesSet, error)
• type V3ioSeries
  • func NewAggrSeries(set *V3ioSeriesSet, aggr aggregate.AggrType) *V3ioSeries
  • func (s *V3ioSeries) GetKey() uint64
  • func (s *V3ioSeries) Iterator() utils.SeriesIterator
  • func (s *V3ioSeries) Labels() utils.Labels
• type V3ioSeriesSet
  • func (s *V3ioSeriesSet) At() utils.Series
  • func (s *V3ioSeriesSet) Err() error
  • func (s *V3ioSeriesSet) Next() bool

Functions

func NewSeries

func NewSeries(set *V3ioSeriesSet) utils.Series

Create a new series from chunks

func NewSetSorter

func NewSetSorter(set utils.SeriesSet) (utils.SeriesSet, error)

Types

type IterSortMerger

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

func (*IterSortMerger) At

func (im *IterSortMerger) At() utils.Series

Return the current key and a list of iterators containing this key

func (*IterSortMerger) Err

func (im *IterSortMerger) Err() error

func (*IterSortMerger) Next

func (im *IterSortMerger) Next() bool

type SelectParams

type SelectParams struct {
	Name      string
	Functions string
	Step      int64
	Windows   []int
	Filter    string
	// contains filtered or unexported fields
}

type V3ioQuerier

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

func NewV3ioQuerier

func NewV3ioQuerier(container v3io.Container, logger logger.Logger, mint, maxt int64,
	cfg *config.V3ioConfig, partMngr *partmgr.PartitionManager) *V3ioQuerier

Create a new Querier interface

func (*V3ioQuerier) Close

func (q *V3ioQuerier) Close() error

func (*V3ioQuerier) LabelNames

func (q *V3ioQuerier) LabelNames() ([]string, error)

func (*V3ioQuerier) LabelValues

func (q *V3ioQuerier) LabelValues(labelKey string) (result []string, err error)

Return the current metric names

func (*V3ioQuerier) Select

func (q *V3ioQuerier) Select(name, functions string, step int64, filter string) (utils.SeriesSet, error)

Standard Time Series Query, return a set of series which match the condition

func (*V3ioQuerier) SelectOverlap

func (q *V3ioQuerier) SelectOverlap(name, functions string, step int64, windows []int, filter string) (utils.SeriesSet, error)

Overlapping windows time-series query - return a set of series each with a list of aggregated results per window For example, get the last 1h, 6h, and 24h stats per metric (specify a 1h aggregation interval (step) of 3600*1000 (=1h), windows 1, 6, and 24, and an end (max) time).

func (*V3ioQuerier) SelectProm

func (q *V3ioQuerier) SelectProm(name, functions string, step int64, filter string, noAggr bool) (utils.SeriesSet, error)

Prometheus time-series query - return a set of time series that match the specified conditions

type V3ioSeries

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

func NewAggrSeries

func NewAggrSeries(set *V3ioSeriesSet, aggr aggregate.AggrType) *V3ioSeries

func (*V3ioSeries) GetKey

func (s *V3ioSeries) GetKey() uint64

Get the unique series key for sorting

func (*V3ioSeries) Iterator

func (s *V3ioSeries) Iterator() utils.SeriesIterator

func (*V3ioSeries) Labels

func (s *V3ioSeries) Labels() utils.Labels

type V3ioSeriesSet

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

holds the query result set

func (*V3ioSeriesSet) At

func (s *V3ioSeriesSet) At() utils.Series

Return a series iterator

func (*V3ioSeriesSet) Err

func (s *V3ioSeriesSet) Err() error

Return the current error

func (*V3ioSeriesSet) Next

func (s *V3ioSeriesSet) Next() bool

Advance to the next series