package statsd

import "k8s.io/heapster/metrics/sinks/statsd"

Index ¶

• func DefaultLabelStyle(str string) string
• func NewStatsdClient(host string, numMetricsPerMsg int) (client statsdClient, err error)
• func NewStatsdSink(uri *url.URL) (sink core.DataSink, err error)
• func NewStatsdSinkWithClient(uri *url.URL, client statsdClient) (sink core.DataSink, err error)
• func SnakeToLowerCamel(str string) string
• func SnakeToUpperCamel(str string) string
• type CustomizeLabel
• type EtsystatsdFormatter
• func (formatter *EtsystatsdFormatter) Format(prefix string, name string, labels map[string]string, customizeLabel CustomizeLabel, metricValue core.MetricValue) (res string, err error)
• type Formatter
• func NewEtsystatsdFormatter() Formatter
• func NewFormatter(protocolType string) (formatter Formatter, err error)
• func NewInfluxstatsdFormatter() Formatter
• type InfluxstatsdFormatter
• func (formatter *InfluxstatsdFormatter) Format(prefix string, name string, labels map[string]string, customizeLabel CustomizeLabel, metricValue core.MetricValue) (res string, err error)
• type LabelCustomizer
• func (customizer LabelCustomizer) Customize(label string) string
• type LabelStyle

Functions ¶

func DefaultLabelStyle ¶

func DefaultLabelStyle(str string) string

func NewStatsdClient ¶

func NewStatsdClient(host string, numMetricsPerMsg int) (client statsdClient, err error)

func NewStatsdSink ¶

func NewStatsdSink(uri *url.URL) (sink core.DataSink, err error)

func NewStatsdSinkWithClient ¶

func NewStatsdSinkWithClient(uri *url.URL, client statsdClient) (sink core.DataSink, err error)

func SnakeToLowerCamel ¶

func SnakeToLowerCamel(str string) string

func SnakeToUpperCamel ¶

func SnakeToUpperCamel(str string) string

Types ¶

type CustomizeLabel ¶

type CustomizeLabel func(string) string

type EtsystatsdFormatter ¶

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

func (*EtsystatsdFormatter) Format ¶

func (formatter *EtsystatsdFormatter) Format(prefix string, name string, labels map[string]string, customizeLabel CustomizeLabel, metricValue core.MetricValue) (res string, err error)

type Formatter ¶

type Formatter interface {
	Format(prefix string, name string, labels map[string]string, customizeLabel CustomizeLabel, metricValue core.MetricValue) (res string, err error)
}

func NewEtsystatsdFormatter ¶

func NewEtsystatsdFormatter() Formatter

func NewFormatter ¶

func NewFormatter(protocolType string) (formatter Formatter, err error)

func NewInfluxstatsdFormatter ¶

func NewInfluxstatsdFormatter() Formatter

type InfluxstatsdFormatter ¶

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

func (*InfluxstatsdFormatter) Format ¶

func (formatter *InfluxstatsdFormatter) Format(prefix string, name string, labels map[string]string, customizeLabel CustomizeLabel, metricValue core.MetricValue) (res string, err error)

type LabelCustomizer ¶

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

func (LabelCustomizer) Customize ¶

func (customizer LabelCustomizer) Customize(label string) string

type LabelStyle ¶

type LabelStyle func(string) string

Source Files ¶

driver.go dummy_statsd_client.go etsystatsd_formatter.go formatter.go influxstatsd_formatter.go statsd_client.go