prometheus

Documentation

Index

• func IncCounter(summaryName string)
• func IncCounterWithLabel(counterName string, label prometheus.Labels)
• func IncSummary(summaryName string, val float64)
• func IncSummaryWithLabel(counterName string, val float64, label prometheus.Labels)
• func SetGauge(gaugeName string, val float64)
• func SetGaugeWithLabel(gaugeName string, val float64, label prometheus.Labels)
• type GaugeVecWithSyncMap
• type PrometheusReporter
  • func (reporter *PrometheusReporter) ReportAfterInvocation(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, ...)
  • func (reporter *PrometheusReporter) ReportBeforeInvocation(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation)

Functions

func IncCounter

func IncCounter(summaryName string)

func IncCounterWithLabel

func IncCounterWithLabel(counterName string, label prometheus.Labels)

func IncSummary

func IncSummary(summaryName string, val float64)

func IncSummaryWithLabel

func IncSummaryWithLabel(counterName string, val float64, label prometheus.Labels)

func SetGauge

func SetGauge(gaugeName string, val float64)

func SetGaugeWithLabel

func SetGaugeWithLabel(gaugeName string, val float64, label prometheus.Labels)

Types

type GaugeVecWithSyncMap

type GaugeVecWithSyncMap struct {
	GaugeVec *prometheus.GaugeVec
	SyncMap  *sync.Map // key: labels, value: *atomic.Value
}

type PrometheusReporter

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

PrometheusReporter will collect the data for Prometheus if you want to use this feature, you need to initialize your prometheus. https://prometheus.io/docs/guides/go-application/

func (*PrometheusReporter) ReportAfterInvocation

func (reporter *PrometheusReporter) ReportAfterInvocation(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration, res protocol.Result)

func (*PrometheusReporter) ReportBeforeInvocation

func (reporter *PrometheusReporter) ReportBeforeInvocation(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation)