Documentation
¶
Index ¶
- Constants
- Variables
- func GetOrRegisterCounter(nameFormat string, nameArgs ...interface{}) metrics.Counter
- func GetOrRegisterGauge(nameFormat string, nameArgs ...interface{}) metrics.Gauge
- func GetOrRegisterGaugeFloat64(nameFormat string, nameArgs ...interface{}) metrics.GaugeFloat64
- func GetOrRegisterHistogram(nameFormat string, nameArgs ...interface{}) metrics.Histogram
- func GetOrRegisterMeter(nameFormat string, nameArgs ...interface{}) metrics.Meter
- func GetOrRegisterTimer(nameFormat string, nameArgs ...interface{}) metrics.Timer
- func NewHistogram() metrics.Histogram
- type Collector
- type MonitorMetrics
- type Percentage
- func GetOrRegisterPercentage(name string, args ...interface{}) Percentage
- func GetOrRegisterTimeWindowPercentage(slotInterval time.Duration, numSlots int, name string, args ...interface{}) Percentage
- func GetOrRegisterTimeWindowPercentageDefault(name string, args ...interface{}) Percentage
- func NewPercentage() Percentage
- func NewTimeWindowPercentage(slotInterval time.Duration, numSlots int) Percentage
- type RpcCollector
- type RpcMetrics
- type StoreMetrics
- type TimerUpdater
- type WorkerMetrics
- func (m *WorkerMetrics) ConfirmOnceQps() metrics.Timer
- func (m *WorkerMetrics) PollOnceQps(err error) metrics.Timer
- func (m *WorkerMetrics) PollOnceSize() metrics.Histogram
- func (m *WorkerMetrics) SettleOnceQps() metrics.Timer
- func (m *WorkerMetrics) UpdateConfirmOnceSize(total, success, retry, reconfirm int)
- func (m *WorkerMetrics) UpdateSettleOnceSize(total, success, failure int)
Constants ¶
View Source
const ( CollectKeyRPCModule = "ckModule" CollectKeyRPCError = "ckError" CollectKeyStatusCode = "ckStatusCode" )
Variables ¶
View Source
var ( RPC RpcMetrics Monitor MonitorMetrics Store StoreMetrics Worker WorkerMetrics )
Functions ¶
func GetOrRegisterCounter ¶
func GetOrRegisterGauge ¶
func GetOrRegisterGaugeFloat64 ¶
func GetOrRegisterGaugeFloat64(nameFormat string, nameArgs ...interface{}) metrics.GaugeFloat64
func GetOrRegisterHistogram ¶
func GetOrRegisterMeter ¶
func GetOrRegisterTimer ¶
func NewHistogram ¶
Types ¶
type MonitorMetrics ¶
type MonitorMetrics struct{}
Monitor metrics
func (*MonitorMetrics) ConfirmQps ¶
func (m *MonitorMetrics) ConfirmQps(err error) metrics.Timer
func (*MonitorMetrics) SyncOnceQps ¶
func (m *MonitorMetrics) SyncOnceQps(err error) metrics.Timer
type Percentage ¶
Percentage implements the GaugeFloat64 interface for percentage statistic.
func GetOrRegisterPercentage ¶
func GetOrRegisterPercentage(name string, args ...interface{}) Percentage
GetOrRegisterPercentage returns an existing Percentage or constructs and registers a new standard Percentage.
func GetOrRegisterTimeWindowPercentage ¶
func GetOrRegisterTimeWindowPercentage( slotInterval time.Duration, numSlots int, name string, args ...interface{}, ) Percentage
GetOrRegisterTimeWindowPercentage returns an existing Percentage or constructs and registers a new time window Percentage.
func GetOrRegisterTimeWindowPercentageDefault ¶
func GetOrRegisterTimeWindowPercentageDefault(name string, args ...interface{}) Percentage
GetOrRegisterTimeWindowPercentageDefault returns an existing Percentage or constructs and registers a new time window Percentage.
func NewPercentage ¶
func NewPercentage() Percentage
NewPercentage constructs a new standard percentage metric.
func NewTimeWindowPercentage ¶
func NewTimeWindowPercentage(slotInterval time.Duration, numSlots int) Percentage
NewTimeWindowPercentage constructs a new time window Percentage.
type RpcCollector ¶
type RpcCollector struct {
// contains filtered or unexported fields
}
func NewRpcCollector ¶
func NewRpcCollector() *RpcCollector
func (*RpcCollector) BatchCollect ¶
func (c *RpcCollector) BatchCollect(kvs map[string]interface{})
func (*RpcCollector) Collect ¶
func (c *RpcCollector) Collect(key string, val interface{})
type RpcMetrics ¶
type RpcMetrics struct{}
RPC metrics
func (*RpcMetrics) UpdateWithCollector ¶
func (*RpcMetrics) UpdateWithCollector(c *RpcCollector)
type StoreMetrics ¶
type StoreMetrics struct{}
Store metrics
func (*StoreMetrics) UpsertBillQps ¶
func (*StoreMetrics) UpsertBillQps(err error) metrics.Timer
type TimerUpdater ¶
type TimerUpdater struct {
// contains filtered or unexported fields
}
TimerUpdater is used to update timer metric with native defer syntax.
func NewTimerUpdater ¶
func NewTimerUpdater(timer metrics.Timer) TimerUpdater
NewTimerUpdater creates an instance to update timer metric.
func NewTimerUpdaterByName ¶
func NewTimerUpdaterByName(name string) TimerUpdater
NewTimerUpdaterByName creates an instance to update timer metric of specified name.
func (*TimerUpdater) Update ¶
func (updater *TimerUpdater) Update()
Update updates the underlying timer metric.
func (*TimerUpdater) UpdateDuration ¶
func (updater *TimerUpdater) UpdateDuration(duration time.Duration)
Update updates the underlying timer metric with duration.
type WorkerMetrics ¶
type WorkerMetrics struct{}
Worker metrics
func (*WorkerMetrics) ConfirmOnceQps ¶
func (m *WorkerMetrics) ConfirmOnceQps() metrics.Timer
func (*WorkerMetrics) PollOnceQps ¶
func (m *WorkerMetrics) PollOnceQps(err error) metrics.Timer
func (*WorkerMetrics) PollOnceSize ¶
func (m *WorkerMetrics) PollOnceSize() metrics.Histogram
func (*WorkerMetrics) SettleOnceQps ¶
func (m *WorkerMetrics) SettleOnceQps() metrics.Timer
func (*WorkerMetrics) UpdateConfirmOnceSize ¶
func (m *WorkerMetrics) UpdateConfirmOnceSize(total, success, retry, reconfirm int)
func (*WorkerMetrics) UpdateSettleOnceSize ¶
func (m *WorkerMetrics) UpdateSettleOnceSize(total, success, failure int)
Source Files
Click to show internal directories.
Click to hide internal directories.