querier

Documentation

Overview

Copyright 2018 Iguazio Systems Ltd.

Licensed under the Apache License, Version 2.0 (the "License") with an addition restriction as set forth herein. You may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0.

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

In addition, you may not use the software for any purposes that are illegal under applicable law, and the grant of the foregoing license under the Apache 2.0 license is conditioned upon your compliance with such restriction.

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