series

Documentation

Index

• func MatrixToSeriesSet(m model.Matrix) storage.SeriesSet
• func NewConcreteSeriesIterator(series *ConcreteSeries) chunkenc.Iterator
• func NewConcreteSeriesSet(series []storage.Series) storage.SeriesSet
• func NewDeletedSeriesIterator(itr chunkenc.Iterator, deletedIntervals []model.Interval) chunkenc.Iterator
• func NewErrIterator(err error) chunkenc.Iterator
• 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() annotations.Annotations
• type DeletedSeriesIterator
  • func (d DeletedSeriesIterator) At() (t int64, v float64)
  • func (d DeletedSeriesIterator) AtFloatHistogram(*histogram.FloatHistogram) (int64, *histogram.FloatHistogram)
  • func (d DeletedSeriesIterator) AtHistogram(*histogram.Histogram) (int64, *histogram.Histogram)
  • func (d DeletedSeriesIterator) AtT() 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 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 NewDeletedSeriesIterator

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

func NewErrIterator

func NewErrIterator(err error) chunkenc.Iterator

NewErrIterator instantiates an errIterator

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() annotations.Annotations

Warnings implements storage.SeriesSet.

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(*histogram.FloatHistogram) (int64, *histogram.FloatHistogram)

func (DeletedSeriesIterator) AtHistogram

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

TODO(rabenhorst): Needs to be implemented for native histogram support.

func (DeletedSeriesIterator) AtT

func (d DeletedSeriesIterator) AtT() 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

TODO(rabenhorst): Native histogram support needs to be added, float type is hardcoded.