transform

package

v1.1.2 Latest Latest Go to latest Published: Apr 22, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudfoundry/metric-store-release

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func MillisecondsToNanoseconds(ms int64) int64
func MillisecondsToString(ms int64) string
func MillisecondsToTime(ms int64) time.Time
func NanosecondsToMilliseconds(ns int64) int64
func SanitizeLabelName(name string) string
func SanitizeMetricName(name string) string
func SecondsToMilliseconds(s int64) int64
func SeriesDataFromInfluxPoint(influxPoint *query.FloatPoint, fields []string) (seriesSample, map[string]string)
func SeriesDataFromPromQLSample(promQLSample *rpc.PromQL_Sample) (seriesSample, map[string]string)
func SeriesDataFromPromQLSeries(promQLSeries *rpc.PromQL_Series) ([]seriesSample, map[string]string)
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

Constants ¶

View Source

const (
	MEASUREMENT_NAME = "__name__"
)

Variables ¶

View Source

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

Functions ¶

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 SanitizeLabelName ¶

func SanitizeLabelName(name string) string

func SanitizeMetricName ¶

func SanitizeMetricName(name string) string

func SecondsToMilliseconds ¶

func SecondsToMilliseconds(s int64) int64

func SeriesDataFromInfluxPoint ¶

func SeriesDataFromInfluxPoint(influxPoint *query.FloatPoint, fields []string) (seriesSample, map[string]string)

func SeriesDataFromPromQLSample ¶

func SeriesDataFromPromQLSample(promQLSample *rpc.PromQL_Sample) (seriesSample, map[string]string)

func SeriesDataFromPromQLSeries ¶

func SeriesDataFromPromQLSeries(promQLSeries *rpc.PromQL_Series) ([]seriesSample, map[string]string)

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 {
	// contains filtered or unexported fields
}

func NewSeriesBuilder ¶

func NewSeriesBuilder() *SeriesSetBuilder

func (*SeriesSetBuilder) AddInfluxPoint ¶

func (b *SeriesSetBuilder) AddInfluxPoint(point *query.FloatPoint, fields []string)

func (*SeriesSetBuilder) AddPromQLSample ¶

func (b *SeriesSetBuilder) AddPromQLSample(sample *rpc.PromQL_Sample)

func (*SeriesSetBuilder) AddPromQLSeries ¶

func (b *SeriesSetBuilder) AddPromQLSeries(series *rpc.PromQL_Series)

func (*SeriesSetBuilder) Len ¶

func (builder *SeriesSetBuilder) Len() int

func (*SeriesSetBuilder) SeriesSet ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL