|
@@ -190,7 +190,8 @@ func (e *EventHandler) JudgeInterval(chdb *gorm.DB) *EventHandler {
|
|
|
|
|
|
func (e *EventHandler) SetUID() *EventHandler {
|
|
func (e *EventHandler) SetUID() *EventHandler {
|
|
// logger.Debug("UUUUUUid: ", fmt.Sprintf("%s_%s_%s", e.RP.AppAlias, e.RP.RuleMonitorAlias, e.RP.Policy))
|
|
// logger.Debug("UUUUUUid: ", fmt.Sprintf("%s_%s_%s", e.RP.AppAlias, e.RP.RuleMonitorAlias, e.RP.Policy))
|
|
- e.JR.UID = fmt.Sprintf("%s_%d", e.RP.AppAlias, e.RP.Id)
|
|
|
|
|
|
+ // e.JR.UID = fmt.Sprintf("%s_%d", e.RP.AppAlias, e.RP.Id)
|
|
|
|
+ e.JR.UID = fmt.Sprintf("%s", e.RP.AppAlias)
|
|
return e
|
|
return e
|
|
}
|
|
}
|
|
|
|
|
|
@@ -202,6 +203,7 @@ func (e *EventHandler) RegisterPrometheusGauge() *EventHandler {
|
|
if err := prometheus.Register(gauge); err != nil {
|
|
if err := prometheus.Register(gauge); err != nil {
|
|
if err.Error() == "duplicate metrics collector registration attempted" {
|
|
if err.Error() == "duplicate metrics collector registration attempted" {
|
|
logger.Errorf("Failed to register gauge: %v", err)
|
|
logger.Errorf("Failed to register gauge: %v", err)
|
|
|
|
+ logger.Infof("promMap: %v", e.promMap)
|
|
return e
|
|
return e
|
|
} else {
|
|
} else {
|
|
log.Fatalf("Failed to register gauge: %v", err)
|
|
log.Fatalf("Failed to register gauge: %v", err)
|
|
@@ -216,7 +218,7 @@ func (e *EventHandler) SetPromKV() *EventHandler {
|
|
e.GetRegisteredGauge(e.RP.RuleMonitorAlias).WithLabelValues(
|
|
e.GetRegisteredGauge(e.RP.RuleMonitorAlias).WithLabelValues(
|
|
e.RP.AppAlias, e.RP.RuleKind, e.JR.UID,
|
|
e.RP.AppAlias, e.RP.RuleKind, e.JR.UID,
|
|
).Set(float64(e.JR.RowGaugeResult))
|
|
).Set(float64(e.JR.RowGaugeResult))
|
|
- logger.Debugf("e.JR.RowGaugeResult", e.JR.RowGaugeResult)
|
|
|
|
|
|
+ logger.Debug("e.JR.RowGaugeResult", e.JR.RowGaugeResult)
|
|
return e
|
|
return e
|
|
}
|
|
}
|
|
|
|
|