|
|
@ -3,9 +3,11 @@ package metric |
|
|
|
import( |
|
|
|
import( |
|
|
|
"fmt" |
|
|
|
"fmt" |
|
|
|
"redis-shake/base" |
|
|
|
"redis-shake/base" |
|
|
|
|
|
|
|
"redis-shake/common" |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
type MetricRest struct { |
|
|
|
type MetricRest struct { |
|
|
|
|
|
|
|
StartTime interface{} |
|
|
|
PullCmdCount interface{} |
|
|
|
PullCmdCount interface{} |
|
|
|
PullCmdCountTotal interface{} |
|
|
|
PullCmdCountTotal interface{} |
|
|
|
BypassCmdCount interface{} |
|
|
|
BypassCmdCount interface{} |
|
|
@ -39,6 +41,7 @@ func NewMetricRest() *MetricRest { |
|
|
|
sourceDbOffset := detailedInfo[3] |
|
|
|
sourceDbOffset := detailedInfo[3] |
|
|
|
|
|
|
|
|
|
|
|
return &MetricRest{ |
|
|
|
return &MetricRest{ |
|
|
|
|
|
|
|
StartTime: utils.StartTime, |
|
|
|
PullCmdCount: MetricVar.GetPullCmdCount(), |
|
|
|
PullCmdCount: MetricVar.GetPullCmdCount(), |
|
|
|
PullCmdCountTotal: MetricVar.GetPullCmdCountTotal(), |
|
|
|
PullCmdCountTotal: MetricVar.GetPullCmdCountTotal(), |
|
|
|
BypassCmdCount: MetricVar.GetBypassCmdCount(), |
|
|
|
BypassCmdCount: MetricVar.GetBypassCmdCount(), |
|
|
|