Documentation ¶
Index ¶
- Constants
- func StringIteratorToSlice(i StringIterator) []string
- type BooleanArray
- func (a *BooleanArray) Exclude(min, max int64)
- func (a *BooleanArray) FindRange(min, max int64) (int, int)
- func (a *BooleanArray) Include(min, max int64)
- func (a *BooleanArray) Len() int
- func (a *BooleanArray) MaxTime() int64
- func (a *BooleanArray) Merge(b *BooleanArray)
- func (a *BooleanArray) MinTime() int64
- func (a *BooleanArray) Size() int
- type BooleanArrayCursor
- type Cursor
- type CursorIterator
- type CursorIterators
- type CursorRequest
- type CursorStats
- type FloatArray
- func (a *FloatArray) Exclude(min, max int64)
- func (a *FloatArray) FindRange(min, max int64) (int, int)
- func (a *FloatArray) Include(min, max int64)
- func (a *FloatArray) Len() int
- func (a *FloatArray) MaxTime() int64
- func (a *FloatArray) Merge(b *FloatArray)
- func (a *FloatArray) MinTime() int64
- func (a *FloatArray) Size() int
- type FloatArrayCursor
- type IntegerArray
- func (a *IntegerArray) Exclude(min, max int64)
- func (a *IntegerArray) FindRange(min, max int64) (int, int)
- func (a *IntegerArray) Include(min, max int64)
- func (a *IntegerArray) Len() int
- func (a *IntegerArray) MaxTime() int64
- func (a *IntegerArray) Merge(b *IntegerArray)
- func (a *IntegerArray) MinTime() int64
- func (a *IntegerArray) Size() int
- type IntegerArrayCursor
- type MeanCountArray
- type MeanCountArrayCursor
- type StringArray
- func (a *StringArray) Exclude(min, max int64)
- func (a *StringArray) FindRange(min, max int64) (int, int)
- func (a *StringArray) Include(min, max int64)
- func (a *StringArray) Len() int
- func (a *StringArray) MaxTime() int64
- func (a *StringArray) Merge(b *StringArray)
- func (a *StringArray) MinTime() int64
- func (a *StringArray) Size() int
- type StringArrayCursor
- type StringIterator
- type StringSliceIterator
- type TimestampArray
- type UnsignedArray
- func (a *UnsignedArray) Exclude(min, max int64)
- func (a *UnsignedArray) FindRange(min, max int64) (int, int)
- func (a *UnsignedArray) Include(min, max int64)
- func (a *UnsignedArray) Len() int
- func (a *UnsignedArray) MaxTime() int64
- func (a *UnsignedArray) Merge(b *UnsignedArray)
- func (a *UnsignedArray) MinTime() int64
- func (a *UnsignedArray) Size() int
- type UnsignedArrayCursor
Constants ¶
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 ¶
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 ¶
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 ¶
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
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 ¶
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 ¶
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 }