series

Documentation

Index

• func MatrixToSeriesSet(m model.Matrix) storage.SeriesSet
• 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 NewDeletedSeriesSet(seriesSet storage.SeriesSet, tombstones *purger.TombstonesSet, ...) storage.SeriesSet
• 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
  • 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
  • func (d DeletedSeries) Labels() labels.Labels
• type DeletedSeriesIterator
  • func (d DeletedSeriesIterator) At() (t int64, v float64)
  • func (d DeletedSeriesIterator) Err() error
  • func (d DeletedSeriesIterator) Next() bool
  • func (d DeletedSeriesIterator) Seek(t int64) bool
• type DeletedSeriesSet
  • func (d DeletedSeriesSet) At() storage.Series
  • func (d DeletedSeriesSet) Err() error
  • func (d DeletedSeriesSet) Next() bool
  • func (d DeletedSeriesSet) Warnings() storage.Warnings

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 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 NewDeletedSeriesSet

func NewDeletedSeriesSet(seriesSet storage.SeriesSet, tombstones *purger.TombstonesSet, queryInterval model.Interval) storage.SeriesSet

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

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

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) Err

func (d DeletedSeriesIterator) Err() error

func (DeletedSeriesIterator) Next

func (d DeletedSeriesIterator) Next() bool

func (DeletedSeriesIterator) Seek

func (d DeletedSeriesIterator) Seek(t int64) bool

type DeletedSeriesSet

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

func (DeletedSeriesSet) At

func (d DeletedSeriesSet) At() storage.Series

func (DeletedSeriesSet) Err

func (d DeletedSeriesSet) Err() error

func (DeletedSeriesSet) Next

func (d DeletedSeriesSet) Next() bool

func (DeletedSeriesSet) Warnings

func (d DeletedSeriesSet) Warnings() storage.Warnings