Documentation
¶
Index ¶
- Constants
- Variables
- func Dec(metric string)
- func Inc(metric string)
- func InitMetrics(sink xstream.Sink)
- func Log(freq time.Duration, fn PrintFun)
- func LogScaled(r Registry, freq time.Duration, scale time.Duration, fn PrintFun)
- func MetricName(userID, key, MetricType string) string
- func Register(name string, i interface{}) error
- type Counter
- type Gauge
- type GaugeFloat64
- type Healthcheck
- type Histogram
- type Logger
- type Meter
- type PrintFun
- type Registry
- type Timer
Constants ¶
View Source
const ( MtcMessageUp = "pub" MtcMessageDown = "sub" MtcMessageAPIDown = "api" MtcRouteMessage = "route" MtcRule = "rule" MtcRuleInvoke = "rule_invoke" MtcRuleOK = "rule_ok" MtcRuleFAIL = "rule_fail" MtcRuleAction = "rule_action" MtcRuleActionOK = "rule_action_ok" MtcRuleActionFAIL = "rule_action_fail" )
1 消息上行 pub 当前用户ID 设备ID 2 消息下行 sub 当前用户ID 设备ID 3 通过API下行 api 当前用户ID 设备ID 4 规则引擎 rule 当前用户ID 规则ID 5 规则引擎-处理成功 rule_ok 当前用户ID 规则ID 6 规则引擎-处理失败 rule_fail 当前用户ID 规则ID 7 规则引擎-动作处理 rule_action 当前用户ID 规则ID 8 规则引擎-动作处理-成功 rule_action_ok 当前用户ID 规则ID 9 规则引擎-动作处理-失败 rule_action_fail 当前用户ID 规则ID
Variables ¶
View Source
var ( RuleMetrics = gometrics.NewMeter() MsgMetrics = gometrics.NewMeter() )
Functions ¶
func InitMetrics ¶
func LogScaled ¶
Output each metric in the given registry periodically using the given logger. Print timings in `scale` units (eg time.Millisecond) rather than nanos.
func MetricName ¶
Types ¶
type GaugeFloat64 ¶
type GaugeFloat64 gometrics.GaugeFloat64
func NewGaugeFloat64 ¶
func NewGaugeFloat64() GaugeFloat64
NewCounter constructs a new StandardCounter.
type Healthcheck ¶
type Healthcheck gometrics.Healthcheck
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.