series

package

v3.4.3 Latest Latest Go to latest Published: Apr 3, 2025 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/loki

Links

Open Source Insights

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
type DeletedSeries
- func (d DeletedSeries) Iterator(_ chunkenc.Iterator) chunkenc.Iterator
- func (d DeletedSeries) Labels() labels.Labels
type DeletedSeriesIterator

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

series_set.go

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