metrics

Documentation

Index

• Variables
• type CallMetrics
  • func (m *CallMetrics) IncComplete()
  • func (m *CallMetrics) IncCount()
  • func (m *CallMetrics) IncFailed()
  • func (m *CallMetrics) LoadAll() int64
  • func (m *CallMetrics) LoadComplete() int64
  • func (m *CallMetrics) LoadCount() int64
  • func (m *CallMetrics) LoadFailed() int64
• type ClientMetricsPlugin
  • func (c *ClientMetricsPlugin) OnCall(msg *protocol.Message, args *[]interface{}) error
  • func (c *ClientMetricsPlugin) OnReceiveMessage(msg *protocol.Message, bytes *[]byte) error
  • func (c *ClientMetricsPlugin) OnResult(msg *protocol.Message, results *[]interface{}, err error)
  • func (c *ClientMetricsPlugin) OnSendMessage(msg *protocol.Message, bytes *[]byte) error
• type Gauge
  • func (g *Gauge) Add(v int64)
  • func (g *Gauge) Dec()
  • func (g *Gauge) Inc()
  • func (g *Gauge) Load() int64
  • func (g *Gauge) Set(v int64)
  • func (g *Gauge) Sub(v int64)
• type ServerMetricsPlugin
  • func (s *ServerMetricsPlugin) OnCallBefore(msg *protocol.Message, args *[]reflect.Value, err error) error
  • func (s *ServerMetricsPlugin) OnCallResult(msg *protocol.Message, results *[]reflect.Value) error
  • func (s *ServerMetricsPlugin) OnComplete(msg *protocol.Message, err error) error
  • func (s *ServerMetricsPlugin) OnMessage(msg *protocol.Message, bytes *[]byte) error
  • func (s *ServerMetricsPlugin) OnReplyMessage(msg *protocol.Message, bytes *[]byte, err error) error
• type TrafficMetrics

Variables

var (
	ClientCallMetrics            = &CallMetrics{}
	ClientUploadTrafficMetrics   = &TrafficMetrics{}
	ClientDownloadTrafficMetrics = &TrafficMetrics{}
)

var (
	ServerCallMetrics            = &CallMetrics{}
	ServerUploadTrafficMetrics   = &TrafficMetrics{}
	ServerDownloadTrafficMetrics = &TrafficMetrics{}
)

Types

type CallMetrics

type CallMetrics struct {
	// 用于即未成功也未失败的计数, 可能由阻塞等原因引起
	Count    int64
	Complete int64
	Failed   int64
}

func (*CallMetrics) IncComplete

func (m *CallMetrics) IncComplete()

func (*CallMetrics) IncCount

func (m *CallMetrics) IncCount()

func (*CallMetrics) IncFailed

func (m *CallMetrics) IncFailed()

func (*CallMetrics) LoadAll

func (m *CallMetrics) LoadAll() int64

func (*CallMetrics) LoadComplete

func (m *CallMetrics) LoadComplete() int64

func (*CallMetrics) LoadCount

func (m *CallMetrics) LoadCount() int64

func (*CallMetrics) LoadFailed

func (m *CallMetrics) LoadFailed() int64

type ClientMetricsPlugin

type ClientMetricsPlugin struct {
}

func (*ClientMetricsPlugin) OnCall

func (c *ClientMetricsPlugin) OnCall(msg *protocol.Message, args *[]interface{}) error

func (*ClientMetricsPlugin) OnReceiveMessage

func (c *ClientMetricsPlugin) OnReceiveMessage(msg *protocol.Message, bytes *[]byte) error

func (*ClientMetricsPlugin) OnResult

func (c *ClientMetricsPlugin) OnResult(msg *protocol.Message, results *[]interface{}, err error)

func (*ClientMetricsPlugin) OnSendMessage

func (c *ClientMetricsPlugin) OnSendMessage(msg *protocol.Message, bytes *[]byte) error

type Gauge

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

func (*Gauge) Add

func (g *Gauge) Add(v int64)

func (*Gauge) Dec

func (g *Gauge) Dec()

func (*Gauge) Inc

func (g *Gauge) Inc()

func (*Gauge) Load

func (g *Gauge) Load() int64

func (*Gauge) Set

func (g *Gauge) Set(v int64)

func (*Gauge) Sub

func (g *Gauge) Sub(v int64)

type ServerMetricsPlugin

type ServerMetricsPlugin struct {
}

func (*ServerMetricsPlugin) OnCallBefore

func (s *ServerMetricsPlugin) OnCallBefore(msg *protocol.Message, args *[]reflect.Value, err error) error

func (*ServerMetricsPlugin) OnCallResult

func (s *ServerMetricsPlugin) OnCallResult(msg *protocol.Message, results *[]reflect.Value) error

func (*ServerMetricsPlugin) OnComplete

func (s *ServerMetricsPlugin) OnComplete(msg *protocol.Message, err error) error

func (*ServerMetricsPlugin) OnMessage

func (s *ServerMetricsPlugin) OnMessage(msg *protocol.Message, bytes *[]byte) error

func (*ServerMetricsPlugin) OnReplyMessage

func (s *ServerMetricsPlugin) OnReplyMessage(msg *protocol.Message, bytes *[]byte, err error) error

type TrafficMetrics

type TrafficMetrics struct {
	Gauge
}

TrafficMetrics 用于统计流量