promtsdb

Documentation

Index

• type Labels
  • func (l Labels) GetExpr() string
  • func (l Labels) GetKey() (string, string, uint64)
• type V3ioPromAdapter
  • func NewV3ioProm(cfg *config.V3ioConfig, container *v3io.Container, logger logger.Logger) (*V3ioPromAdapter, error)
  • func (a *V3ioPromAdapter) Appender() (storage.Appender, error)
  • func (a *V3ioPromAdapter) Close() error
  • func (a *V3ioPromAdapter) Querier(_ context.Context, mint, maxt int64) (storage.Querier, error)
  • func (a *V3ioPromAdapter) StartTime() (int64, error)
• type V3ioPromQuerier
  • func (q *V3ioPromQuerier) Close() error
  • func (q *V3ioPromQuerier) LabelValues(name string) ([]string, error)
  • func (q *V3ioPromQuerier) Select(params *storage.SelectParams, oms ...*labels.Matcher) (storage.SeriesSet, error)
• type V3ioPromSeries
  • func (s *V3ioPromSeries) Iterator() storage.SeriesIterator
  • func (s *V3ioPromSeries) Labels() labels.Labels
• type V3ioPromSeriesIterator
  • func (s *V3ioPromSeriesIterator) At() (t int64, v float64)
  • func (s *V3ioPromSeriesIterator) Err() error
  • func (s *V3ioPromSeriesIterator) Next() bool
  • func (s *V3ioPromSeriesIterator) Seek(t int64) bool
• type V3ioPromSeriesSet
  • func (s *V3ioPromSeriesSet) At() storage.Series
  • func (s *V3ioPromSeriesSet) Err() error
  • func (s *V3ioPromSeriesSet) Next() bool

Types

type Labels

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

func (Labels) GetExpr

func (l Labels) GetExpr() string

create update expression

func (Labels) GetKey

func (l Labels) GetKey() (string, string, uint64)

convert Label set to a string in the form key1=v1,key2=v2.. + name + hash

type V3ioPromAdapter

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

func NewV3ioProm

func NewV3ioProm(cfg *config.V3ioConfig, container *v3io.Container, logger logger.Logger) (*V3ioPromAdapter, error)

func (*V3ioPromAdapter) Appender

func (a *V3ioPromAdapter) Appender() (storage.Appender, error)

func (*V3ioPromAdapter) Close

func (a *V3ioPromAdapter) Close() error

func (*V3ioPromAdapter) Querier

func (a *V3ioPromAdapter) Querier(_ context.Context, mint, maxt int64) (storage.Querier, error)

func (*V3ioPromAdapter) StartTime

func (a *V3ioPromAdapter) StartTime() (int64, error)

type V3ioPromQuerier

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

func (*V3ioPromQuerier) Close

func (q *V3ioPromQuerier) Close() error

Close releases the resources of the Querier.

func (*V3ioPromQuerier) LabelValues

func (q *V3ioPromQuerier) LabelValues(name string) ([]string, error)

LabelValues returns all potential values for a label name.

func (*V3ioPromQuerier) Select

func (q *V3ioPromQuerier) Select(params *storage.SelectParams, oms ...*labels.Matcher) (storage.SeriesSet, error)

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

type V3ioPromSeries

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

Series represents a single time series.

func (*V3ioPromSeries) Iterator

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

Iterator returns a new iterator of the data of the series.

func (*V3ioPromSeries) Labels

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

Labels returns the complete set of labels identifying the series.

type V3ioPromSeriesIterator

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

SeriesIterator iterates over the data of a time series.

func (*V3ioPromSeriesIterator) At

func (s *V3ioPromSeriesIterator) At() (t int64, v float64)

At returns the current timestamp/value pair.

func (*V3ioPromSeriesIterator) Err

func (s *V3ioPromSeriesIterator) Err() error

Err returns the current error.

func (*V3ioPromSeriesIterator) Next

func (s *V3ioPromSeriesIterator) Next() bool

Next advances the iterator by one.

func (*V3ioPromSeriesIterator) Seek

func (s *V3ioPromSeriesIterator) Seek(t int64) bool

Seek advances the iterator forward to the given timestamp. If there's no value exactly at t, it advances to the first value after t.

type V3ioPromSeriesSet

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

func (*V3ioPromSeriesSet) At

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

func (*V3ioPromSeriesSet) Err

func (s *V3ioPromSeriesSet) Err() error

func (*V3ioPromSeriesSet) Next

func (s *V3ioPromSeriesSet) Next() bool