core

Documentation

Index

• func CounterToGauge(item *dataobj.MetricValue) *dataobj.MetricValue
• func CounterValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue
• func GaugeValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue
• func InitRpcClients()
• func NewMetricValue(metric string, val interface{}, dataType string, tags ...string) *dataobj.MetricValue
• func Push(metricItems []*dataobj.MetricValue)
• func SubtractToGauge(item *dataobj.MetricValue) *dataobj.MetricValue
• type RpcClientContainer
  • func (rcc *RpcClientContainer) Del(addr string)
  • func (rcc *RpcClientContainer) Get(addr string) *rpc.Client
  • func (rcc *RpcClientContainer) Put(addr string, client *rpc.Client) bool

Functions

func CounterToGauge

func CounterToGauge(item *dataobj.MetricValue) *dataobj.MetricValue

func CounterValue

func CounterValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue

func GaugeValue

func GaugeValue(metric string, val interface{}, tags ...string) *dataobj.MetricValue

func InitRpcClients

func InitRpcClients()

func NewMetricValue

func NewMetricValue(metric string, val interface{}, dataType string, tags ...string) *dataobj.MetricValue

func Push

func Push(metricItems []*dataobj.MetricValue)

func SubtractToGauge

func SubtractToGauge(item *dataobj.MetricValue) *dataobj.MetricValue

Types

type RpcClientContainer

type RpcClientContainer struct {
	M map[string]*rpc.Client
	sync.RWMutex
}

func (*RpcClientContainer) Del

func (rcc *RpcClientContainer) Del(addr string)

func (*RpcClientContainer) Get

func (rcc *RpcClientContainer) Get(addr string) *rpc.Client

func (*RpcClientContainer) Put

func (rcc *RpcClientContainer) Put(addr string, client *rpc.Client) bool

Put 返回的bool表示affected，确实把自己塞进去了