tsdbutil

Documentation

Index

• func ChunkFromSamples(s []Sample) chunks.Meta
• func PopulatedChunk(numSamples int, minTime int64) chunks.Meta
• type BufferedSeriesIterator
  • func NewBuffer(it SeriesIterator, delta int64) *BufferedSeriesIterator
  • func (b *BufferedSeriesIterator) At() (int64, float64)
  • func (b *BufferedSeriesIterator) Buffer() SeriesIterator
  • func (b *BufferedSeriesIterator) Err() error
  • func (b *BufferedSeriesIterator) Next() bool
  • func (b *BufferedSeriesIterator) PeekBack() (t int64, v float64, ok bool)
  • func (b *BufferedSeriesIterator) Seek(t int64) bool
• type Sample
• type SeriesIterator

Functions

func ChunkFromSamples

func ChunkFromSamples(s []Sample) chunks.Meta

func PopulatedChunk

func PopulatedChunk(numSamples int, minTime int64) chunks.Meta

PopulatedChunk creates a chunk populated with samples every second starting at minTime

Types

type BufferedSeriesIterator

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

BufferedSeriesIterator wraps an iterator with a look-back buffer.

func NewBuffer

func NewBuffer(it SeriesIterator, delta int64) *BufferedSeriesIterator

NewBuffer returns a new iterator that buffers the values within the time range of the current element and the duration of delta before.

func (*BufferedSeriesIterator) At

func (b *BufferedSeriesIterator) At() (int64, float64)

At returns the current element of the iterator.

func (*BufferedSeriesIterator) Buffer

func (b *BufferedSeriesIterator) Buffer() SeriesIterator

Buffer returns an iterator over the buffered data.

func (*BufferedSeriesIterator) Err

func (b *BufferedSeriesIterator) Err() error

Err returns the last encountered error.

func (*BufferedSeriesIterator) Next

func (b *BufferedSeriesIterator) Next() bool

Next advances the iterator to the next element.

func (*BufferedSeriesIterator) PeekBack

func (b *BufferedSeriesIterator) PeekBack() (t int64, v float64, ok bool)

PeekBack returns the previous element of the iterator. If there is none buffered, ok is false.

func (*BufferedSeriesIterator) Seek

func (b *BufferedSeriesIterator) Seek(t int64) bool

Seek advances the iterator to the element at time t or greater.

type Sample

type Sample interface {
	T() int64
	V() float64
}

type SeriesIterator

type SeriesIterator interface {
	// Seek advances the iterator forward to the given timestamp.
	// If there's no value exactly at t, it advances to the first value
	// after t.
	Seek(t int64) bool
	// At returns the current timestamp/value pair.
	At() (t int64, v float64)
	// Next advances the iterator by one.
	Next() bool
	// Err returns the current error.
	Err() error
}

SeriesIterator iterates over the data of a time series.