metrics

Documentation

Index

• Variables
• func MessagesConsumedMetric(priority int) *vmetrics.Counter
• func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter
• type MetricsServer
  • func Start(ctx context.Context, cfg config.Config) *MetricsServer
  • func (m MetricsServer) PrintAll()
  • func (m *MetricsServer) PrintSummary()
  • func (m *MetricsServer) StartTime(t time.Time)
  • func (m *MetricsServer) Stop()

Variables

var (
	CommandLineArgs                          *vmetrics.Gauge
	MessagesPublished                        *vmetrics.Counter
	MessagesConfirmed                        *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

Types

type MetricsServer

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

func Start

func Start(ctx context.Context, cfg config.Config) *MetricsServer

func (MetricsServer) PrintAll

func (m MetricsServer) PrintAll()

func (*MetricsServer) PrintSummary

func (m *MetricsServer) PrintSummary()

func (*MetricsServer) StartTime

func (m *MetricsServer) StartTime(t time.Time)

func (*MetricsServer) Stop

func (m *MetricsServer) Stop()