series

package

v1.16.0 Latest Latest Go to latest Published: Nov 19, 2023 License: Apache-2.0 Imports: 9 Imported by: 5

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cortexproject/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

func MatrixToSeriesSet(sortSeries bool, m model.Matrix) storage.SeriesSet
func MetricsToSeriesSet(sortSeries bool, ms []metric.Metric) storage.SeriesSet
func NewConcreteSeriesIterator(series *ConcreteSeries) chunkenc.Iterator
func NewConcreteSeriesSet(sortSeries bool, 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 annotations.Annotations) 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() annotations.Annotations
type DeletedSeries
- func (d DeletedSeries) Iterator(it chunkenc.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() annotations.Annotations

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func MatrixToSeriesSet ¶

func MatrixToSeriesSet(sortSeries bool, m model.Matrix) storage.SeriesSet

MatrixToSeriesSet creates a storage.SeriesSet from a model.Matrix Series will be sorted by labels if sortSeries is set.

func MetricsToSeriesSet ¶

func MetricsToSeriesSet(sortSeries bool, 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(sortSeries bool, series []storage.Series) storage.SeriesSet

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

func NewDeletedSeries ¶ added in v1.0.0

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

func NewDeletedSeriesIterator ¶ added in v1.0.0

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

func NewDeletedSeriesSet ¶ added in v1.0.0

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

func NewEmptySeries ¶ added in v1.0.0

func NewEmptySeries(labels labels.Labels) storage.Series

func NewEmptySeriesIterator ¶ added in v1.0.0

func NewEmptySeriesIterator() chunkenc.Iterator

func NewErrIterator ¶

func NewErrIterator(err error) chunkenc.Iterator

NewErrIterator instantiates an errIterator

func NewSeriesSetWithWarnings ¶ added in v1.2.0

func NewSeriesSetWithWarnings(wrapped storage.SeriesSet, warnings annotations.Annotations) 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 ¶ added in v1.2.0

func (c *ConcreteSeriesSet) Warnings() annotations.Annotations

Warnings implements storage.SeriesSet.

type DeletedSeries ¶ added in v1.0.0

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

func (DeletedSeries) Iterator ¶ added in v1.0.0

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

func (DeletedSeries) Labels ¶ added in v1.0.0

func (d DeletedSeries) Labels() labels.Labels

type DeletedSeriesIterator ¶ added in v1.0.0

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

func (DeletedSeriesIterator) At ¶ added in v1.0.0

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

func (DeletedSeriesIterator) Err ¶ added in v1.0.0

func (d DeletedSeriesIterator) Err() error

func (DeletedSeriesIterator) Next ¶ added in v1.0.0

func (d DeletedSeriesIterator) Next() bool

func (DeletedSeriesIterator) Seek ¶ added in v1.0.0

func (d DeletedSeriesIterator) Seek(t int64) bool

type DeletedSeriesSet ¶ added in v1.0.0

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

func (DeletedSeriesSet) At ¶ added in v1.0.0

func (d DeletedSeriesSet) At() storage.Series

func (DeletedSeriesSet) Err ¶ added in v1.0.0

func (d DeletedSeriesSet) Err() error

func (DeletedSeriesSet) Next ¶ added in v1.0.0

func (d DeletedSeriesSet) Next() bool

func (DeletedSeriesSet) Warnings ¶ added in v1.2.0

func (d DeletedSeriesSet) Warnings() annotations.Annotations

Source Files ¶

View all Source files

series_set.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL