Versions in this module Expand all Collapse all v0 v0.0.3 Jul 5, 2024 v0.0.2 Jun 10, 2024 Changes in this version + var InfuraRegistry = metrics.DefaultRegistry + 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 Init() + func NewHistogram() metrics.Histogram + type InputBlockMetric struct + func (metric *InputBlockMetric) Update1(blockNum *types.BlockNumber, method string, eth *client.RpcEthClient) + func (metric *InputBlockMetric) Update2(blockNumOrHash *types.BlockNumberOrHash, method string, ...) + type InputEpochMetric struct + func (metric *InputEpochMetric) Update(epoch *types.Epoch, method string, cfx sdk.ClientOperator) + type Metrics struct + Nodes NodeManagerMetrics + PubSub PubSubMetrics + RPC RpcMetrics + Store StoreMetrics + Sync SyncMetrics + var Registry Metrics + type NodeManagerMetrics struct + func (*NodeManagerMetrics) NodeAvailability(space, group, node string) string + func (*NodeManagerMetrics) NodeLatency(space, group, node string) string + func (*NodeManagerMetrics) Routes(space, group, node string) metrics.Meter + type Percentage interface + Mark func(marked bool) + Value func() float64 + 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 PubSubMetrics struct + func (*PubSubMetrics) InputLogFilter(space string) Percentage + func (*PubSubMetrics) Sessions(space, topic, node string) metrics.Gauge + type RpcMetrics struct + func (*RpcMetrics) BatchLatency() metrics.Histogram + func (*RpcMetrics) BatchSize() metrics.Histogram + func (*RpcMetrics) FullnodeErrorRate(node ...string) Percentage + func (*RpcMetrics) FullnodeNonRpcErrorRate(node ...string) Percentage + func (*RpcMetrics) FullnodeQps(space, method string, err error) metrics.Timer + func (*RpcMetrics) InputBlock(method, block string) Percentage + func (*RpcMetrics) InputBlockGap(method string) metrics.Histogram + func (*RpcMetrics) InputEpoch(method, epoch string) Percentage + func (*RpcMetrics) InputEpochGap(method string) metrics.Histogram + func (*RpcMetrics) Percentage(method, name string) Percentage + func (*RpcMetrics) StoreHit(method, storeName string) Percentage + func (*RpcMetrics) UpdateDuration(method string, err error, start time.Time) + type StoreMetrics struct + func (*StoreMetrics) GetLogs() TimerUpdater + func (*StoreMetrics) Pop(storeName string) TimerUpdater + func (*StoreMetrics) Push(storeName string) TimerUpdater + type SyncMetrics struct + func (*SyncMetrics) QueryEpochData(space string) TimerUpdater + func (*SyncMetrics) QueryEpochDataAvailability(space string) Percentage + func (*SyncMetrics) SyncOnceQps(space, storeName string, err error) metrics.Timer + func (*SyncMetrics) SyncOnceSize(space, storeName string) metrics.Histogram + type TimerUpdater struct + func NewTimerUpdater(timer metrics.Timer) TimerUpdater + func NewTimerUpdaterByName(name string) TimerUpdater + func (updater *TimerUpdater) Update() + func (updater *TimerUpdater) UpdateDuration(duration time.Duration)
Go to main page