utils

Documentation

Index

• func DedupeMetadata(seriesMeta []block.SeriesMeta, tagOptions models.TagOptions) (models.Tags, []block.SeriesMeta)
• func FlattenMetadata(meta block.Metadata, seriesMeta []block.SeriesMeta) []block.SeriesMeta
• func FormatFloat(value float64) string
• func FormatFloatToBytes(value float64) []byte
• func GreaterWithNaNs(i, j float64) bool
• func GroupSeries(matchingTags [][]byte, without bool, opName []byte, metas []block.SeriesMeta) ([][]int, []block.SeriesMeta)
• func LesserWithNaNs(i, j float64) bool
• func UniqueCount(names []string) int
• type FloatHeap
  • func NewFloatHeap(isMaxHeap bool, capacity int) FloatHeap
  • func (fh *FloatHeap) Cap() int
  • func (fh *FloatHeap) Flush() []ValueIndexPair
  • func (fh *FloatHeap) Len() int
  • func (fh *FloatHeap) OrderedFlush() []ValueIndexPair
  • func (fh *FloatHeap) Peek() (ValueIndexPair, bool)
  • func (fh *FloatHeap) Push(value float64, index int)
  • func (fh *FloatHeap) Reset()
• type StaticParams
  • func (s StaticParams) OpType() string
  • func (s StaticParams) String() string
• type ValueIndexPair

Functions

func DedupeMetadata

func DedupeMetadata(
	seriesMeta []block.SeriesMeta,
	tagOptions models.TagOptions,
) (models.Tags, []block.SeriesMeta)

DedupeMetadata applies all shared tags from Metadata to each SeriesMeta

func FlattenMetadata

func FlattenMetadata(
	meta block.Metadata,
	seriesMeta []block.SeriesMeta,
) []block.SeriesMeta

FlattenMetadata applies all shared tags from Metadata to each SeriesMeta

func FormatFloat

func FormatFloat(
	value float64,
) string

FormatFloat converts float values to formatted strings

func FormatFloatToBytes

func FormatFloatToBytes(
	value float64,
) []byte

FormatFloatToBytes converts float values to formatted byte arrays

func GreaterWithNaNs

func GreaterWithNaNs(i, j float64) bool

Compares two float64 values which one is greater with NaNs. NaNs are always sorted away.

func GroupSeries

func GroupSeries(
	matchingTags [][]byte,
	without bool,
	opName []byte,
	metas []block.SeriesMeta,
) ([][]int, []block.SeriesMeta)

GroupSeries groups series by tags. It gives a list of seriesMeta for the grouped series, and a list of corresponding buckets which signify which series are mapped to which grouped outputs

func LesserWithNaNs

func LesserWithNaNs(i, j float64) bool

Compares two float64 values which one is lesser with NaNs. NaNs are always sorted away.

func UniqueCount

func UniqueCount(names []string) int

UniqueCount calculates the number of unique strings in a given slice.

Types

type FloatHeap

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

FloatHeap is a heap that can be given a maximum size

func NewFloatHeap

func NewFloatHeap(isMaxHeap bool, capacity int) FloatHeap

NewFloatHeap builds a new FloatHeap based on first parameter and a capacity given by second parameter. Zero and negative values for maxSize provide an unbounded FloatHeap

func (*FloatHeap) Cap

func (fh *FloatHeap) Cap() int

Cap returns the capacity of the heap

func (*FloatHeap) Flush

func (fh *FloatHeap) Flush() []ValueIndexPair

Flush flushes the float heap and resets it. Does not guarantee order.

func (*FloatHeap) Len

func (fh *FloatHeap) Len() int

Len returns the current length of the heap

func (*FloatHeap) OrderedFlush

func (fh *FloatHeap) OrderedFlush() []ValueIndexPair

OrderedFlush flushes the float heap and returns values in order.

func (*FloatHeap) Peek

func (fh *FloatHeap) Peek() (ValueIndexPair, bool)

Peek reveals the top value of the heap without mutating the heap.

func (*FloatHeap) Push

func (fh *FloatHeap) Push(value float64, index int)

Push pushes a value and index pair to the heap

func (*FloatHeap) Reset

func (fh *FloatHeap) Reset()

Reset resets the heap

type StaticParams

type StaticParams string

StaticParams is a simple string Params implementation, useful for when no data other than OpType is needed.

func (StaticParams) OpType

func (s StaticParams) OpType() string

OpType simply returns s for StaticParams.

func (StaticParams) String

func (s StaticParams) String() string

String simply returns s.

type ValueIndexPair

type ValueIndexPair struct {
	Val   float64
	Index int
}

ValueIndexPair is a pair of float value and index at which it exists