utils

Documentation

Index

• func DedupeMetadata(seriesMeta []block.SeriesMeta) (models.Tags, []block.SeriesMeta)
• func FlattenMetadata(meta block.Metadata, seriesMeta []block.SeriesMeta) []block.SeriesMeta
• func FormatFloat(value float64) string
• func GroupSeries(matchingTags []string, without bool, opName string, metas []block.SeriesMeta) ([][]int, []block.SeriesMeta)
• 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) Peek() (ValueIndexPair, bool)
  • func (fh FloatHeap) Push(value float64, index int)
  • func (fh *FloatHeap) Reset()
• type ValueIndexPair

Functions

func DedupeMetadata

func DedupeMetadata(
	seriesMeta []block.SeriesMeta,
) (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 applies all shared tags from Metadata to each SeriesMeta

func GroupSeries

func GroupSeries(
	matchingTags []string,
	without bool,
	opName string,
	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

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) 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 ValueIndexPair

type ValueIndexPair struct {
	Val   float64
	Index int
}

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