series

Documentation

Index

• func MatrixToSeriesSet(m model.Matrix) storage.SeriesSet
• func MetricToLabels(m model.Metric) labels.Labels
• func MetricsToSeriesSet(ms []metric.Metric) storage.SeriesSet
• func NewConcreteSeriesIterator(series *ConcreteSeries) chunkenc.Iterator
• func NewConcreteSeriesSet(series []storage.Series) storage.SeriesSet
• func NewDeletedSeries(series storage.Series, deletedIntervals []model.Interval) storage.Series
• func NewDeletedSeriesIterator(itr chunkenc.Iterator, deletedIntervals []model.Interval) chunkenc.Iterator
• func NewEmptySeries(labels labels.Labels) storage.Series
• func NewEmptySeriesIterator() chunkenc.Iterator
• func NewErrIterator(err error) chunkenc.Iterator
• func NewSeriesSetWithWarnings(wrapped storage.SeriesSet, warnings storage.Warnings) storage.SeriesSet
• type ConcreteSeries
  • func NewConcreteSeries(ls labels.Labels, samples []model.SamplePair) *ConcreteSeries
  • func (c *ConcreteSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator
  • func (c *ConcreteSeries) Labels() labels.Labels
• type ConcreteSeriesSet
  • func (c *ConcreteSeriesSet) At() storage.Series
  • func (c *ConcreteSeriesSet) Err() error
  • func (c *ConcreteSeriesSet) Next() bool
  • func (c *ConcreteSeriesSet) Warnings() storage.Warnings
• type DeletedSeries
  • func (d DeletedSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator
  • func (d DeletedSeries) Labels() labels.Labels
• type DeletedSeriesIterator
  • func (d DeletedSeriesIterator) At() (t int64, v float64)
  • func (d DeletedSeriesIterator) AtFloatHistogram() (int64, *histogram.FloatHistogram)
  • func (d DeletedSeriesIterator) AtHistogram() (int64, *histogram.Histogram)
  • func (d DeletedSeriesIterator) AtT() (t int64)
  • func (d DeletedSeriesIterator) Err() error
  • func (d DeletedSeriesIterator) Next() chunkenc.ValueType
  • func (d DeletedSeriesIterator) Seek(t int64) chunkenc.ValueType

Functions

func MatrixToSeriesSet

func MatrixToSeriesSet(m model.Matrix) storage.SeriesSet

MatrixToSeriesSet creates a storage.SeriesSet from a model.Matrix Series will be sorted by labels.

func MetricToLabels

func MetricToLabels(m model.Metric) labels.Labels

func MetricsToSeriesSet

func MetricsToSeriesSet(ms []metric.Metric) storage.SeriesSet

MetricsToSeriesSet creates a storage.SeriesSet from a []metric.Metric

func NewConcreteSeriesIterator

func NewConcreteSeriesIterator(series *ConcreteSeries) chunkenc.Iterator

NewConcreteSeriesIterator instaniates an in memory chunkenc.Iterator

func NewConcreteSeriesSet

func NewConcreteSeriesSet(series []storage.Series) storage.SeriesSet

NewConcreteSeriesSet instantiates an in-memory series set from a series Series will be sorted by labels.

func NewDeletedSeries

func NewDeletedSeries(series storage.Series, deletedIntervals []model.Interval) storage.Series

func NewDeletedSeriesIterator

func NewDeletedSeriesIterator(itr chunkenc.Iterator, deletedIntervals []model.Interval) chunkenc.Iterator

func NewEmptySeries

func NewEmptySeries(labels labels.Labels) storage.Series

func NewEmptySeriesIterator

func NewEmptySeriesIterator() chunkenc.Iterator

func NewErrIterator

func NewErrIterator(err error) chunkenc.Iterator

NewErrIterator instantiates an errIterator

func NewSeriesSetWithWarnings

func NewSeriesSetWithWarnings(wrapped storage.SeriesSet, warnings storage.Warnings) storage.SeriesSet

Types

type ConcreteSeries

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

ConcreteSeries implements storage.Series.

func NewConcreteSeries

func NewConcreteSeries(ls labels.Labels, samples []model.SamplePair) *ConcreteSeries

NewConcreteSeries instantiates an in memory series from a list of samples & labels

func (*ConcreteSeries) Iterator

func (c *ConcreteSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator

Iterator implements storage.Series

func (*ConcreteSeries) Labels

func (c *ConcreteSeries) Labels() labels.Labels

Labels implements storage.Series

type ConcreteSeriesSet

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

ConcreteSeriesSet implements storage.SeriesSet.

func (*ConcreteSeriesSet) At

func (c *ConcreteSeriesSet) At() storage.Series

At returns the current series and implements storage.SeriesSet.

func (*ConcreteSeriesSet) Err

func (c *ConcreteSeriesSet) Err() error

Err implements storage.SeriesSet.

func (*ConcreteSeriesSet) Next

func (c *ConcreteSeriesSet) Next() bool

Next iterates through a series set and implements storage.SeriesSet.

func (*ConcreteSeriesSet) Warnings

func (c *ConcreteSeriesSet) Warnings() storage.Warnings

Warnings implements storage.SeriesSet.

type DeletedSeries

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

func (DeletedSeries) Iterator

func (d DeletedSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator

func (DeletedSeries) Labels

func (d DeletedSeries) Labels() labels.Labels

type DeletedSeriesIterator

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

func (DeletedSeriesIterator) At

func (d DeletedSeriesIterator) At() (t int64, v float64)

func (DeletedSeriesIterator) AtFloatHistogram

func (d DeletedSeriesIterator) AtFloatHistogram() (int64, *histogram.FloatHistogram)

func (DeletedSeriesIterator) AtHistogram

func (d DeletedSeriesIterator) AtHistogram() (int64, *histogram.Histogram)

func (DeletedSeriesIterator) AtT

func (d DeletedSeriesIterator) AtT() (t int64)

func (DeletedSeriesIterator) Err

func (d DeletedSeriesIterator) Err() error

func (DeletedSeriesIterator) Next

func (d DeletedSeriesIterator) Next() chunkenc.ValueType

func (DeletedSeriesIterator) Seek

func (d DeletedSeriesIterator) Seek(t int64) chunkenc.ValueType