metrics

package

v1.0.1 Latest Latest Go to latest Published: Aug 19, 2025 License: MIT Imports: 5 Imported by: 0

Details

View Source

const (
	CollectKeyRPCModule  = "ckModule"
	CollectKeyRPCError   = "ckError"
	CollectKeyStatusCode = "ckStatusCode"
)

View Source

var (
	RPC     RpcMetrics
	Monitor MonitorMetrics
	Store   StoreMetrics
	Worker  WorkerMetrics
)

This section is empty.

type Collector interface {
	Collect(key string, val interface{})
	BatchCollect(kvs map[string]interface{})
}

type MonitorMetrics struct{}

Monitor metrics

func (m *MonitorMetrics) ConfirmQps(err error) metrics.Timer

func (m *MonitorMetrics) SyncOnceQps(err error) metrics.Timer

type RpcCollector struct {
	// contains filtered or unexported fields
}

func NewRpcCollector() *RpcCollector

func (c *RpcCollector) BatchCollect(kvs map[string]interface{})

func (c *RpcCollector) Collect(key string, val interface{})

type RpcMetrics struct{}

RPC metrics

func (*RpcMetrics) UpdateWithCollector(c *RpcCollector)

type StoreMetrics struct{}

Store metrics

func (*StoreMetrics) UpsertBillQps(err error) metrics.Timer

type WorkerMetrics struct{}

Worker metrics

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)