rmetrics

Documentation

Index

• Constants
• func DecreasePendingEvents(tablePrefix, workspace, destType string, value float64)
• func IncreasePendingEvents(tablePrefix, workspace, destType string, value float64)
• func PendingEvents(tablePrefix, workspace, destType string) metric.Gauge
• func PendingEventsMeasurement(tablePrefix, workspace, destType string) metric.Measurement

Constants

const (
	JobsdbPendingEventsCount = "jobsdb_%s_pending_events_count"
	All                      = "ALL"
)

Functions

func DecreasePendingEvents

func DecreasePendingEvents(tablePrefix, workspace, destType string, value float64)

DecreasePendingEvents increments three gauges, the dest & workspace-specific gauge, plus two aggregate (global) gauges

func IncreasePendingEvents

func IncreasePendingEvents(tablePrefix, workspace, destType string, value float64)

IncreasePendingEvents increments three gauges, the dest & workspace-specific gauge, plus two aggregate (global) gauges

func PendingEvents

func PendingEvents(tablePrefix, workspace, destType string) metric.Gauge

PendingEvents gets the measurement for pending events metric

func PendingEventsMeasurement

func PendingEventsMeasurement(tablePrefix, workspace, destType string) metric.Measurement