proxyquerier

Documentation

Index

• type ProxyQuerier
  • func (h *ProxyQuerier) Close() error
  • func (h *ProxyQuerier) LabelNames() ([]string, storage.Warnings, error)
  • func (h *ProxyQuerier) LabelValues(name string) ([]string, storage.Warnings, error)
  • func (h *ProxyQuerier) Select(selectParams *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)
• type Series
  • func (s *Series) Iterator() storage.SeriesIterator
  • func (s *Series) Labels() labels.Labels
• type SeriesSet
  • func NewSeriesSet(series []storage.Series) *SeriesSet
  • func (s *SeriesSet) At() storage.Series
  • func (s *SeriesSet) Err() error
  • func (s *SeriesSet) Next() bool

Types

type ProxyQuerier

type ProxyQuerier struct {
	Ctx    context.Context
	Start  time.Time
	End    time.Time
	Client promclient.API

	Cfg *proxyconfig.PromxyConfig
}

ProxyQuerier Implements prometheus' Querier interface

func (*ProxyQuerier) Close

func (h *ProxyQuerier) Close() error

Close closes the querier. Behavior for subsequent calls to Querier methods is undefined.

func (*ProxyQuerier) LabelNames

func (h *ProxyQuerier) LabelNames() ([]string, storage.Warnings, error)

LabelNames returns all the unique label names present in the block in sorted order.

func (*ProxyQuerier) LabelValues

func (h *ProxyQuerier) LabelValues(name string) ([]string, storage.Warnings, error)

LabelValues returns all potential values for a label name.

func (*ProxyQuerier) Select

func (h *ProxyQuerier) Select(selectParams *storage.SelectParams, matchers ...*labels.Matcher) (storage.SeriesSet, storage.Warnings, error)

Select returns a set of series that matches the given label matchers.

type Series

type Series struct {
	It *promclient.SeriesIterator
}

Series implements prometheus' Series interface

func (*Series) Iterator

func (s *Series) Iterator() storage.SeriesIterator

Iterator returns an iterator over the series

func (*Series) Labels

func (s *Series) Labels() labels.Labels

Labels for this seris

type SeriesSet

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

SeriesSet implements prometheus' SeriesSet interface

func NewSeriesSet

func NewSeriesSet(series []storage.Series) *SeriesSet

NewSeriesSet returns a SeriesSet for the given series

func (*SeriesSet) At

func (s *SeriesSet) At() storage.Series

At returns the current Series for this iterator

func (*SeriesSet) Err

func (s *SeriesSet) Err() error

Err returns any error found in this iterator

func (*SeriesSet) Next

func (s *SeriesSet) Next() bool

Next will attempt to move the iterator up