transform

Documentation

Index

• Variables
• func ConvertLabels(point *rpc.Point) labels.Labels
• func DurationToNanoseconds(t time.Duration) int64
• func DurationToSeconds(t time.Duration) float64
• func IsValidFloat(value float64) bool
• func MillisecondsToNanoseconds(ms int64) int64
• func MillisecondsToString(ms int64) string
• func MillisecondsToTime(ms int64) time.Time
• func NanosecondsToMilliseconds(ns int64) int64
• func NanosecondsToSeconds(ns int64) float64
• func SanitizeLabelName(name string) string
• func SanitizeMetricName(name string) string
• func SecondsToMilliseconds(s int64) int64
• func ToInfluxFilter(matcher *labels.Matcher) (*influxql.BinaryExpr, error)
• func ToInfluxFilters(matchers []*labels.Matcher) (influxql.Expr, error)
• func ToInfluxPoints(points []*rpc.Point) []models.Point
• type SeriesSetBuilder
  • func NewSeriesBuilder() *SeriesSetBuilder
  • func (b *SeriesSetBuilder) AddSeriesPoints(seriesLabels labels.Labels, points []*query.FloatPoint)
  • func (b *SeriesSetBuilder) Len() int
  • func (b *SeriesSetBuilder) SeriesSet() storage.SeriesSet

Variables

var UNINDEXED_LABELS = map[string]bool{
	"uri":            true,
	"content_length": true,
	"user_agent":     true,
	"request_id":     true,
	"forwarded":      true,
	"remote_address": true,
}

Functions

func ConvertLabels

func ConvertLabels(point *rpc.Point) labels.Labels

func DurationToNanoseconds

func DurationToNanoseconds(t time.Duration) int64

func DurationToSeconds

func DurationToSeconds(t time.Duration) float64

func IsValidFloat

func IsValidFloat(value float64) bool

func MillisecondsToNanoseconds

func MillisecondsToNanoseconds(ms int64) int64

func MillisecondsToString

func MillisecondsToString(ms int64) string

func MillisecondsToTime

func MillisecondsToTime(ms int64) time.Time

func NanosecondsToMilliseconds

func NanosecondsToMilliseconds(ns int64) int64

func NanosecondsToSeconds

func NanosecondsToSeconds(ns int64) float64

func SanitizeLabelName

func SanitizeLabelName(name string) string

PromQL Label Name Sanitization From: https://prometheus.io/docs/concepts/data_model/#metric-names-and-labels First character: Match if it's NOT A-z or underscore [^A-z_] All others: Match if they're NOT alphanumeric or underscore [\w_]+?

func SanitizeMetricName

func SanitizeMetricName(name string) string

PromQL Metric Name Sanitization https://prometheus.io/docs/concepts/data_model/#metric-names-and-labels First character: Match if it's NOT A-z, underscore, or colon [^A-z_:] All others: Match if they're NOT alphanumeric, underscore, or colon [\w_:]+?

func SecondsToMilliseconds

func SecondsToMilliseconds(s int64) int64

func ToInfluxFilter

func ToInfluxFilter(matcher *labels.Matcher) (*influxql.BinaryExpr, error)

func ToInfluxFilters

func ToInfluxFilters(matchers []*labels.Matcher) (influxql.Expr, error)

func ToInfluxPoints

func ToInfluxPoints(points []*rpc.Point) []models.Point

Types

type SeriesSetBuilder

type SeriesSetBuilder struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSeriesBuilder

func NewSeriesBuilder() *SeriesSetBuilder

func (*SeriesSetBuilder) AddSeriesPoints

func (b *SeriesSetBuilder) AddSeriesPoints(seriesLabels labels.Labels, points []*query.FloatPoint)

func (*SeriesSetBuilder) Len

func (b *SeriesSetBuilder) Len() int

func (*SeriesSetBuilder) SeriesSet

func (b *SeriesSetBuilder) SeriesSet() storage.SeriesSet