Documentation ¶
Index ¶
- func CreateMetric(r base.Runner)
- type Combine
- type Delta
- type Metric
- func (m *Metric) AddBypassCmdCount(val uint64)
- func (m *Metric) AddDelay(val uint64)
- func (m *Metric) AddFailCmdCount(val uint64)
- func (m *Metric) AddNetworkFlow(val uint64)
- func (m *Metric) AddPullCmdCount(val uint64)
- func (m *Metric) AddPushCmdCount(val uint64)
- func (m *Metric) AddSuccessCmdCount(val uint64)
- func (m *Metric) GetAvgDelay() interface{}
- func (m *Metric) GetBypassCmdCount() interface{}
- func (m *Metric) GetBypassCmdCountTotal() interface{}
- func (m *Metric) GetDelay() interface{}
- func (m *Metric) GetFailCmdCount() interface{}
- func (m *Metric) GetFailCmdCountTotal() interface{}
- func (m *Metric) GetFullSyncProgress() interface{}
- func (m *Metric) GetNetworkFlow() interface{}
- func (m *Metric) GetNetworkFlowTotal() interface{}
- func (m *Metric) GetPullCmdCount() interface{}
- func (m *Metric) GetPullCmdCountTotal() interface{}
- func (m *Metric) GetPushCmdCount() interface{}
- func (m *Metric) GetPushCmdCountTotal() interface{}
- func (m *Metric) GetSuccessCmdCount() interface{}
- func (m *Metric) GetSuccessCmdCountTotal() interface{}
- func (m *Metric) SetFullSyncProgress(val uint64)
- type MetricRest
- type Op
- type Percent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateMetric ¶
Types ¶
type Metric ¶
type Metric struct { PullCmdCount Combine BypassCmdCount Combine PushCmdCount Combine SuccessCmdCount Combine FailCmdCount Combine Delay Percent // ms AvgDelay Percent // ms NetworkFlow Combine // +speed FullSyncProgress uint64 }
main struct
var (
MetricVar *Metric
)
func (*Metric) AddBypassCmdCount ¶
func (*Metric) AddFailCmdCount ¶
func (*Metric) AddNetworkFlow ¶
func (*Metric) AddPullCmdCount ¶
func (*Metric) AddPushCmdCount ¶
func (*Metric) AddSuccessCmdCount ¶
func (*Metric) GetAvgDelay ¶
func (m *Metric) GetAvgDelay() interface{}
func (*Metric) GetBypassCmdCount ¶
func (m *Metric) GetBypassCmdCount() interface{}
func (*Metric) GetBypassCmdCountTotal ¶
func (m *Metric) GetBypassCmdCountTotal() interface{}
func (*Metric) GetFailCmdCount ¶
func (m *Metric) GetFailCmdCount() interface{}
func (*Metric) GetFailCmdCountTotal ¶
func (m *Metric) GetFailCmdCountTotal() interface{}
func (*Metric) GetFullSyncProgress ¶
func (m *Metric) GetFullSyncProgress() interface{}
func (*Metric) GetNetworkFlow ¶
func (m *Metric) GetNetworkFlow() interface{}
func (*Metric) GetNetworkFlowTotal ¶
func (m *Metric) GetNetworkFlowTotal() interface{}
func (*Metric) GetPullCmdCount ¶
func (m *Metric) GetPullCmdCount() interface{}
func (*Metric) GetPullCmdCountTotal ¶
func (m *Metric) GetPullCmdCountTotal() interface{}
func (*Metric) GetPushCmdCount ¶
func (m *Metric) GetPushCmdCount() interface{}
func (*Metric) GetPushCmdCountTotal ¶
func (m *Metric) GetPushCmdCountTotal() interface{}
func (*Metric) GetSuccessCmdCount ¶
func (m *Metric) GetSuccessCmdCount() interface{}
func (*Metric) GetSuccessCmdCountTotal ¶
func (m *Metric) GetSuccessCmdCountTotal() interface{}
func (*Metric) SetFullSyncProgress ¶
type MetricRest ¶
type MetricRest struct { StartTime interface{} PullCmdCount interface{} PullCmdCountTotal interface{} BypassCmdCount interface{} BypassCmdCountTotal interface{} PushCmdCount interface{} PushCmdCountTotal interface{} SuccessCmdCount interface{} SuccessCmdCountTotal interface{} FailCmdCount interface{} FailCmdCountTotal interface{} Delay interface{} AvgDelay interface{} NetworkSpeed interface{} // network speed NetworkFlowTotal interface{} // total network speed FullSyncProgress interface{} Status interface{} SenderBufCount interface{} // length of sender buffer ProcessingCmdCount interface{} // length of delay channel TargetDBOffset interface{} // target redis offset SourceDBOffset interface{} // source redis offset }
func NewMetricRest ¶
func NewMetricRest() *MetricRest
Click to show internal directories.
Click to hide internal directories.