prometheus

Documentation

Index

• func CreateMetricSink(server *veneur.Server, name string, logger *logrus.Entry, config veneur.Config, ...) (sinks.MetricSink, error)
• func MigrateConfig(conf *veneur.Config)
• func ParseMetricConfig(name string, config interface{}) (veneur.MetricSinkConfig, error)
• type PrometheusMetricSink
  • func (sink *PrometheusMetricSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error
  • func (sink *PrometheusMetricSink) FlushOtherSamples(ctx context.Context, samples []ssf.SSFSample)
  • func (sink *PrometheusMetricSink) Name() string
  • func (sink *PrometheusMetricSink) Start(traceClient *trace.Client) error
• type PrometheusMetricSinkConfig

Functions

func CreateMetricSink

func CreateMetricSink(
	server *veneur.Server, name string, logger *logrus.Entry,
	config veneur.Config, sinkConfig veneur.MetricSinkConfig,
) (sinks.MetricSink, error)

func MigrateConfig

func MigrateConfig(conf *veneur.Config)

func ParseMetricConfig

func ParseMetricConfig(name string, config interface{}) (veneur.MetricSinkConfig, error)

Types

type PrometheusMetricSink

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

In exporting to Prometheus as a metric sink, we are tentatively choosing to use https://github.com/prometheus/statsd_exporter.

func (*PrometheusMetricSink) Flush

func (sink *PrometheusMetricSink) Flush(ctx context.Context, interMetrics []samplers.InterMetric) error

Flush sends metrics to the Statsd Exporter in batches.

func (*PrometheusMetricSink) FlushOtherSamples

func (sink *PrometheusMetricSink) FlushOtherSamples(ctx context.Context, samples []ssf.SSFSample)

FlushOtherSamples sends events to SignalFx. This is a no-op for Prometheus sinks as Prometheus does not support other samples.

func (*PrometheusMetricSink) Name

func (sink *PrometheusMetricSink) Name() string

func (*PrometheusMetricSink) Start

func (sink *PrometheusMetricSink) Start(traceClient *trace.Client) error

type PrometheusMetricSinkConfig

type PrometheusMetricSinkConfig struct {
	RepeaterAddress string `yaml:"repeater_address"`
	NetworkType     string `yaml:"network_type"`
}