metrics

Documentation

Index

• Variables
• func MessagesConsumedMetric(priority int) *vmetrics.Counter
• func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter
• func RegisterMetrics(globalLabels map[string]string)
• func Reset()
• type MetricsServer
  • func GetMetricsServer() *MetricsServer
  • func (m *MetricsServer) PrintFinalMetrics()
  • func (m *MetricsServer) PrintMessageRates(ctx context.Context)
  • func (m *MetricsServer) Start()

Variables

var (
	MessagesPublished                        *vmetrics.Counter
	MessagesConsumedNormalPriority           *vmetrics.Counter
	MessagesConsumedHighPriority             *vmetrics.Counter
	MessagesConsumedOutOfOrderNormalPriority *vmetrics.Counter
	MessagesConsumedOutOfOrderHighPriority   *vmetrics.Counter
	PublishingLatency                        *vmetrics.Summary
	EndToEndLatency                          *vmetrics.Summary
)

Functions

func MessagesConsumedMetric

func MessagesConsumedMetric(priority int) *vmetrics.Counter

func MessagesConsumedOutOfOrderMetric

func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter

func RegisterMetrics

func RegisterMetrics(globalLabels map[string]string)

func Reset

func Reset()

Types

type MetricsServer

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

func GetMetricsServer

func GetMetricsServer() *MetricsServer

func (*MetricsServer) PrintFinalMetrics

func (m *MetricsServer) PrintFinalMetrics()

func (*MetricsServer) PrintMessageRates

func (m *MetricsServer) PrintMessageRates(ctx context.Context)

func (*MetricsServer) Start

func (m *MetricsServer) Start()