monitoring

Documentation

Index

• Variables
• func GetPerfCtrGauge(flowgraphName string, blockName string, counterName string) (prometheus.Gauge, error)
• type Exporter
  • func NewExporter(address string, l *zap.SugaredLogger) (*Exporter, error)
  • func (e *Exporter) Close() error
• type Metrics
  • func NewMetrics() *Metrics

Variables

var PerformanceCountersToCollect = []string{
	"pc_work_time_total",
	"pc_work_time_avg",
	"pc_work_time",
	"pc_work_time_var",
	"pc_throughput_avg",
	"pc_nproduced",
	"pc_nproduced_avg",
	"pc_nproduced_var",
}

Functions

func GetPerfCtrGauge

func GetPerfCtrGauge(flowgraphName string, blockName string, counterName string) (prometheus.Gauge, error)

Registers a new gauge. If gauge already exists, returns that.

Types

type Exporter

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

func NewExporter

func NewExporter(address string, l *zap.SugaredLogger) (*Exporter, error)

func (*Exporter) Close

func (e *Exporter) Close() error

type Metrics

type Metrics struct {
	FlowgraphCount prometheus.Gauge
}

func NewMetrics

func NewMetrics() *Metrics