cursors

package
v1.9.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2022 License: MIT Imports: 2 Imported by: 15

Documentation

Index

Constants

View Source 
const DefaultMaxPointsPerBlock = 1000

Variables

This section is empty.

Functions

func StringIteratorToSlice added in v1.7.8 

func StringIteratorToSlice(i StringIterator) []string

StringIteratorToSlice reads the remainder of i into a slice and returns the result.

Types

type BooleanArray 

type BooleanArray struct {
	Timestamps []int64
	Values     []bool
}

func NewBooleanArrayLen 

func NewBooleanArrayLen(sz int) *BooleanArray

func (*BooleanArray) Exclude 

func (a *BooleanArray) Exclude(min, max int64)

Exclude removes the subset of values in [min, max]. The values must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*BooleanArray) FindRange 

func (a *BooleanArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*BooleanArray) Include 

func (a *BooleanArray) Include(min, max int64)

Include returns the subset values between min and max inclusive. The values must be deduplicated and sorted before calling Include or the results are undefined.

func (*BooleanArray) Len 

func (a *BooleanArray) Len() int

func (*BooleanArray) MaxTime 

func (a *BooleanArray) MaxTime() int64

func (*BooleanArray) Merge 

func (a *BooleanArray) Merge(b *BooleanArray)

Merge overlays b to top of a. If two values conflict with the same timestamp, b is used. Both a and b must be sorted in ascending order.

func (*BooleanArray) MinTime 

func (a *BooleanArray) MinTime() int64

func (*BooleanArray) Size 

func (a *BooleanArray) Size() int

type BooleanArrayCursor 

type BooleanArrayCursor interface {
	Cursor
	Next() *BooleanArray
}

type Cursor 

type Cursor interface {
	Close()
	Err() error
	Stats() CursorStats
}

type CursorIterator 

type CursorIterator interface {
	Next(ctx context.Context, r *CursorRequest) (Cursor, error)
	Stats() CursorStats
}

type CursorIterators 

type CursorIterators []CursorIterator

func (CursorIterators) Stats 

func (a CursorIterators) Stats() CursorStats

Stats returns the aggregate stats of all cursor iterators.

type CursorRequest 

type CursorRequest struct {
	// Name is the measurement name a cursor is requested for.
	Name []byte

	// Tags is the set of series tags a cursor is requested for.
	Tags models.Tags

	// Field is the selected field for the cursor that is requested.
	Field string

	// Ascending is whether the cursor should move in an ascending
	// or descending time order.
	Ascending bool

	// StartTime is the start time of the cursor. It is the lower
	// absolute time regardless of the Ascending flag. This value
	// is an inclusive bound.
	StartTime int64

	// EndTime is the end time of the cursor. It is the higher
	// absolute time regardless of the Ascending flag. This value
	// is an inclusive bound.
	EndTime int64
}

CursorRequest is a request to the storage engine for a cursor to be created with the given name, tags, and field for a given direction and time range.

type CursorStats 

type CursorStats struct {
	ScannedValues int // number of values scanned
	ScannedBytes  int // number of uncompressed bytes scanned
}

CursorStats represents stats collected by a cursor.

func (*CursorStats) Add 

func (s *CursorStats) Add(other CursorStats)

Add adds other to s and updates s.

type FloatArray 

type FloatArray struct {
	Timestamps []int64
	Values     []float64
}

func NewFloatArrayLen 

func NewFloatArrayLen(sz int) *FloatArray

func (*FloatArray) Exclude 

func (a *FloatArray) Exclude(min, max int64)

Exclude removes the subset of values in [min, max]. The values must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*FloatArray) FindRange 

func (a *FloatArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*FloatArray) Include 

func (a *FloatArray) Include(min, max int64)

Include returns the subset values between min and max inclusive. The values must be deduplicated and sorted before calling Include or the results are undefined.

func (*FloatArray) Len 

func (a *FloatArray) Len() int

func (*FloatArray) MaxTime 

func (a *FloatArray) MaxTime() int64

func (*FloatArray) Merge 

func (a *FloatArray) Merge(b *FloatArray)

Merge overlays b to top of a. If two values conflict with the same timestamp, b is used. Both a and b must be sorted in ascending order.

func (*FloatArray) MinTime 

func (a *FloatArray) MinTime() int64

func (*FloatArray) Size 

func (a *FloatArray) Size() int

type FloatArrayCursor 

type FloatArrayCursor interface {
	Cursor
	Next() *FloatArray
}

type IntegerArray 

type IntegerArray struct {
	Timestamps []int64
	Values     []int64
}

func NewIntegerArrayLen 

func NewIntegerArrayLen(sz int) *IntegerArray

func (*IntegerArray) Exclude 

func (a *IntegerArray) Exclude(min, max int64)

Exclude removes the subset of values in [min, max]. The values must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*IntegerArray) FindRange 

func (a *IntegerArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*IntegerArray) Include 

func (a *IntegerArray) Include(min, max int64)

Include returns the subset values between min and max inclusive. The values must be deduplicated and sorted before calling Include or the results are undefined.

func (*IntegerArray) Len 

func (a *IntegerArray) Len() int

func (*IntegerArray) MaxTime 

func (a *IntegerArray) MaxTime() int64

func (*IntegerArray) Merge 

func (a *IntegerArray) Merge(b *IntegerArray)

Merge overlays b to top of a. If two values conflict with the same timestamp, b is used. Both a and b must be sorted in ascending order.

func (*IntegerArray) MinTime 

func (a *IntegerArray) MinTime() int64

func (*IntegerArray) Size 

func (a *IntegerArray) Size() int

type IntegerArrayCursor 

type IntegerArrayCursor interface {
	Cursor
	Next() *IntegerArray
}

type MeanCountArray added in v1.9.0 

type MeanCountArray struct {
	Timestamps []int64
	Values0    []float64
	Values1    []int64
}

func NewMeanCountArrayLen added in v1.9.0 

func NewMeanCountArrayLen(sz int) *MeanCountArray

func (*MeanCountArray) Len added in v1.9.0 

func (a *MeanCountArray) Len() int

func (*MeanCountArray) MaxTime added in v1.9.0 

func (a *MeanCountArray) MaxTime() int64

func (*MeanCountArray) MinTime added in v1.9.0 

func (a *MeanCountArray) MinTime() int64

func (*MeanCountArray) Size added in v1.9.0 

func (a *MeanCountArray) Size() int

type MeanCountArrayCursor added in v1.9.0 

type MeanCountArrayCursor interface {
	Cursor
	Next() *MeanCountArray
}

type StringArray 

type StringArray struct {
	Timestamps []int64
	Values     []string
}

func NewStringArrayLen 

func NewStringArrayLen(sz int) *StringArray

func (*StringArray) Exclude 

func (a *StringArray) Exclude(min, max int64)

Exclude removes the subset of values in [min, max]. The values must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*StringArray) FindRange 

func (a *StringArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*StringArray) Include 

func (a *StringArray) Include(min, max int64)

Include returns the subset values between min and max inclusive. The values must be deduplicated and sorted before calling Include or the results are undefined.

func (*StringArray) Len 

func (a *StringArray) Len() int

func (*StringArray) MaxTime 

func (a *StringArray) MaxTime() int64

func (*StringArray) Merge 

func (a *StringArray) Merge(b *StringArray)

Merge overlays b to top of a. If two values conflict with the same timestamp, b is used. Both a and b must be sorted in ascending order.

func (*StringArray) MinTime 

func (a *StringArray) MinTime() int64

func (*StringArray) Size 

func (a *StringArray) Size() int

type StringArrayCursor 

type StringArrayCursor interface {
	Cursor
	Next() *StringArray
}

type StringIterator added in v1.7.8 

type StringIterator interface {
	// Next advances the StringIterator to the next value. It returns false
	// when there are no more values.
	Next() bool

	// Value returns the current value.
	Value() string

	Stats() CursorStats
}

StringIterator describes the behavior for enumerating a sequence of string values. 

var EmptyStringIterator StringIterator = &stringIterator{}

EmptyStringIterator is an implementation of StringIterator that returns no values.

type StringSliceIterator added in v1.7.8 

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

func NewStringSliceIterator added in v1.7.8 

func NewStringSliceIterator(s []string) *StringSliceIterator

func NewStringSliceIteratorWithStats added in v1.7.8 

func NewStringSliceIteratorWithStats(s []string, stats CursorStats) *StringSliceIterator

func (*StringSliceIterator) Next added in v1.7.8 

func (s *StringSliceIterator) Next() bool

func (*StringSliceIterator) Stats added in v1.7.8 

func (s *StringSliceIterator) Stats() CursorStats

func (*StringSliceIterator) Value added in v1.7.8 

func (s *StringSliceIterator) Value() string

type TimestampArray added in v1.7.8 

type TimestampArray struct {
	Timestamps []int64
}

func NewTimestampArrayLen added in v1.7.8 

func NewTimestampArrayLen(sz int) *TimestampArray

func (*TimestampArray) Contains added in v1.7.8 

func (a *TimestampArray) Contains(min, max int64) bool

Contains returns true if values exist between min and max inclusive. The values must be sorted before calling Contains or the results are undefined.

func (*TimestampArray) Exclude added in v1.7.8 

func (a *TimestampArray) Exclude(min, max int64)

Exclude removes the subset of timestamps in [min, max]. The timestamps must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*TimestampArray) FindRange added in v1.7.8 

func (a *TimestampArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*TimestampArray) Len added in v1.7.8 

func (a *TimestampArray) Len() int

func (*TimestampArray) MaxTime added in v1.7.8 

func (a *TimestampArray) MaxTime() int64

func (*TimestampArray) MinTime added in v1.7.8 

func (a *TimestampArray) MinTime() int64

type UnsignedArray 

type UnsignedArray struct {
	Timestamps []int64
	Values     []uint64
}

func NewUnsignedArrayLen 

func NewUnsignedArrayLen(sz int) *UnsignedArray

func (*UnsignedArray) Exclude 

func (a *UnsignedArray) Exclude(min, max int64)

Exclude removes the subset of values in [min, max]. The values must be deduplicated and sorted before calling Exclude or the results are undefined.

func (*UnsignedArray) FindRange 

func (a *UnsignedArray) FindRange(min, max int64) (int, int)

FindRange returns the positions where min and max would be inserted into the array. If a[0].UnixNano() > max or a[len-1].UnixNano() < min then FindRange returns (-1, -1) indicating the array is outside the [min, max]. The values must be deduplicated and sorted before calling FindRange or the results are undefined.

func (*UnsignedArray) Include 

func (a *UnsignedArray) Include(min, max int64)

Include returns the subset values between min and max inclusive. The values must be deduplicated and sorted before calling Include or the results are undefined.

func (*UnsignedArray) Len 

func (a *UnsignedArray) Len() int

func (*UnsignedArray) MaxTime 

func (a *UnsignedArray) MaxTime() int64

func (*UnsignedArray) Merge 

func (a *UnsignedArray) Merge(b *UnsignedArray)

Merge overlays b to top of a. If two values conflict with the same timestamp, b is used. Both a and b must be sorted in ascending order.

func (*UnsignedArray) MinTime 

func (a *UnsignedArray) MinTime() int64

func (*UnsignedArray) Size 

func (a *UnsignedArray) Size() int

type UnsignedArrayCursor 

type UnsignedArrayCursor interface {
	Cursor
	Next() *UnsignedArray
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.