metric

Documentation

Index

• func UpdateMetric(addr string) error
• type Metric
  • func NewMetric(clusterId uint64, host, addr string, maxSlowLogNum uint64) *Metric
  • func (m *Metric) AddConnectCount(delta int64)
  • func (m *Metric) GetMetricAddress() string
  • func (m *Metric) Output(output interface{})
  • func (m *Metric) ProxyApiMetric(method string, ack bool, delay time.Duration)
  • func (m *Metric) Run()
  • func (m *Metric) SendMetric(url string, message proto.Message) error
  • func (m *Metric) SlowLogMetric(slowLog string, delay time.Duration)
  • func (m *Metric) StoreApiMetric(method string, ack bool, delay time.Duration)
• type SlowLog

Functions

func UpdateMetric

func UpdateMetric(addr string) error

Types

type Metric

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

var GsMetric *Metric

func NewMetric

func NewMetric(clusterId uint64, host, addr string, maxSlowLogNum uint64) *Metric

func (*Metric) AddConnectCount

func (m *Metric) AddConnectCount(delta int64)

func (*Metric) GetMetricAddress

func (m *Metric) GetMetricAddress() string

func (*Metric) Output

func (m *Metric) Output(output interface{})

func (*Metric) ProxyApiMetric

func (m *Metric) ProxyApiMetric(method string, ack bool, delay time.Duration)

func (*Metric) Run

func (m *Metric) Run()

func (*Metric) SendMetric

func (m *Metric) SendMetric(url string, message proto.Message) error

func (*Metric) SlowLogMetric

func (m *Metric) SlowLogMetric(slowLog string, delay time.Duration)

func (*Metric) StoreApiMetric

func (m *Metric) StoreApiMetric(method string, ack bool, delay time.Duration)

type SlowLog

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