series

Documentation

Index

• 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
• 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 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(*histogram.FloatHistogram) (int64, *histogram.FloatHistogram)
  • func (d DeletedSeriesIterator) AtHistogram(*histogram.Histogram) (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 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

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

func (DeletedSeriesIterator) AtHistogram

func (d DeletedSeriesIterator) AtHistogram(*histogram.Histogram) (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