metrics

Documentation

Index

• func Measure(e zapcore.Entry) error
• func MetricsHandle()
• func RegisterSDKMetrics()
• type Metrics
  • func GetMetrics() *Metrics
• type Server
  • func NewServer(config *conf.Status) *Server
  • func (s *Server) GracefulStop() error
  • func (s *Server) ListenAndServe(addr string) error
  • func (s *Server) Serve(lis net.Listener) error
  • func (s *Server) Stop() error

Functions

func Measure

func Measure(e zapcore.Entry) error

Measure logger level rate

func MetricsHandle

func MetricsHandle()

MetricsHandle register the metrics handle

func RegisterSDKMetrics

func RegisterSDKMetrics()

Types

type Metrics

type Metrics struct {
	//biz
	ConnectionOnlineGaugeVec *prometheus.GaugeVec

	//command
	ZTInfoCounterVec    *prometheus.CounterVec
	IsLeaderGaugeVec    *prometheus.GaugeVec
	LRangeSeekHistogram prometheus.Histogram
	GCKeysCounterVec    *prometheus.CounterVec

	//expire
	ExpireKeysTotal *prometheus.CounterVec

	//tikvGC
	TiKVGCTotal *prometheus.CounterVec

	//command biz
	CommandCallHistogramVec     *prometheus.HistogramVec
	TxnBeginHistogramVec        *prometheus.HistogramVec
	CommandFuncDoneHistogramVec *prometheus.HistogramVec
	TxnCommitHistogramVec       *prometheus.HistogramVec
	ReplyFuncDoneHistogramVec   *prometheus.HistogramVec
	CommandArgsNumHistogramVec  *prometheus.HistogramVec
	TxnRetriesCounterVec        *prometheus.CounterVec
	TxnConflictsCounterVec      *prometheus.CounterVec
	TxnFailuresCounterVec       *prometheus.CounterVec
	MultiCommandHistogramVec    *prometheus.HistogramVec

	//logger
	LogMetricsCounterVec *prometheus.CounterVec
}

Metrics prometheus statistics

func GetMetrics

func GetMetrics() *Metrics

GetMetrics return metrics object

type Server

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

Server status server

func NewServer

func NewServer(config *conf.Status) *Server

NewServer creat status server

func (*Server) GracefulStop

func (s *Server) GracefulStop() error

GracefulStop serve graceful stop

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(addr string) error

ListenAndServe start the service by address

func (*Server) Serve

func (s *Server) Serve(lis net.Listener) error

Serve accepts incoming connections on the Listener l

func (*Server) Stop

func (s *Server) Stop() error

Stop Close serve fd