Documentation
¶
Index ¶
Constants ¶
View Source
const ( LblType = "type" LblStatusType = "status" LblRuleIDType = "rule" LblOpIDType = "op" LblIOType = "io" LBlRuleRunning = "running" LblRuleStop = "stop" LblSourceIO = "source" LblSinkIO = "sink" LblException = "err" LblSuccess = "success" )
Variables ¶
View Source
var ( IOCounter = prometheus.NewCounterVec(prometheus.CounterOpts{ Namespace: "kuiper", Subsystem: "io", Name: "counter", Help: "counter of IO", }, []string{LblType, LblIOType, LblStatusType, LblRuleIDType, LblOpIDType}) IODurationHist = prometheus.NewHistogramVec(prometheus.HistogramOpts{ Namespace: "kuiper", Subsystem: "io", Name: "duration_hist", Help: "Historgram Duration of IO", Buckets: prometheus.ExponentialBuckets(10, 2, 20), }, []string{LblType, LblIOType, LblRuleIDType, LblOpIDType}) )
View Source
var ( RuleStatusCountGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "kuiper", Subsystem: "rule", Name: "count", Help: "gauge of rule status count", }, []string{LblStatusType}) RuleStatusGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "kuiper", Subsystem: "rule", Name: "status", Help: "gauge of rule status", }, []string{LblRuleIDType}) RuleCPUUsageGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "kuiper", Subsystem: "rule", Name: "cpu_ms", Help: "gauge of rule CPU usage", }, []string{LblRuleIDType}) )
View Source
var ( SyncCacheHist = prometheus.NewHistogramVec(prometheus.HistogramOpts{ Namespace: "kuiper", Subsystem: "sync_cache", Name: "duration", Buckets: prometheus.ExponentialBuckets(10, 2, 20), Help: "hist of sync cache", }, []string{LblType, LblRuleIDType, LblOpIDType}) SyncCacheCounter = prometheus.NewCounterVec(prometheus.CounterOpts{ Namespace: "kuiper", Subsystem: "sync_cache", Name: "counter", Help: "counter of sync cache", }, []string{LblType, LblRuleIDType, LblOpIDType}) SyncCacheGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "kuiper", Subsystem: "sync_cache", Name: "gauge", Help: "gauge of sync cache", }, []string{LblType, LblRuleIDType, LblOpIDType}) )
Functions ¶
func GetStatusValue ¶
func RegisterSyncCache ¶
func RegisterSyncCache()
func RemoveRuleStatus ¶
func RemoveRuleStatus(ruleID string)
func SetRuleCPUUsageGauge ¶
func SetRuleStatus ¶
func SetRuleStatusCountGauge ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.