series

Documentation

Index

• func MatrixToSeriesSet(m model.Matrix) storage.SeriesSet
• func MetricsToSeriesSet(ms []metric.Metric) storage.SeriesSet
• func NewConcreteSeriesIterator(series *ConcreteSeries) storage.SeriesIterator
• func NewConcreteSeriesSet(series []storage.Series) storage.SeriesSet
• func NewDeletedSeries(series storage.Series, deletedIntervals []model.Interval) storage.Series
• func NewDeletedSeriesIterator(itr storage.SeriesIterator, deletedIntervals []model.Interval) storage.SeriesIterator
• func NewDeletedSeriesSet(seriesSet storage.SeriesSet, tombstones *purger.TombstonesSet, ...) storage.SeriesSet
• func NewEmptySeries(labels labels.Labels) storage.Series
• func NewEmptySeriesIterator() storage.SeriesIterator
• func NewEmptySeriesSet() storage.SeriesSet
• func NewErrIterator(err error) storage.SeriesIterator
• type ConcreteSeries
  • func NewConcreteSeries(ls labels.Labels, samples []model.SamplePair) *ConcreteSeries
  • func (c *ConcreteSeries) Iterator() storage.SeriesIterator
  • func (c *ConcreteSeries) Labels() labels.Labels
• type ConcreteSeriesSet
  • func (c *ConcreteSeriesSet) At() storage.Series
  • func (c *ConcreteSeriesSet) Err() error
  • func (c *ConcreteSeriesSet) Next() bool
• type DeletedSeries
  • func (d DeletedSeries) Iterator() storage.SeriesIterator
  • 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

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) storage.SeriesIterator

NewConcreteSeriesIterator instaniates an in memory storage.SeriesIterator

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 storage.SeriesIterator, deletedIntervals []model.Interval) storage.SeriesIterator

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() storage.SeriesIterator

func NewEmptySeriesSet

func NewEmptySeriesSet() storage.SeriesSet

NewEmptySeriesSet returns a new series set that contains no series.

func NewErrIterator

func NewErrIterator(err error) storage.SeriesIterator

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() storage.SeriesIterator

Iterator impls storage.Series

func (*ConcreteSeries) Labels

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

Labels impls 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 impls storage.SeriesSet

func (*ConcreteSeriesSet) Err

func (c *ConcreteSeriesSet) Err() error

Err impls storage.SeriesSet

func (*ConcreteSeriesSet) Next

func (c *ConcreteSeriesSet) Next() bool

Next iterates through a series set and impls storage.SeriesSet

type DeletedSeries

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

func (DeletedSeries) Iterator

func (d DeletedSeries) Iterator() storage.SeriesIterator

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