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 Meta(id int64) (script string, args string, account string, err error)
• func NewMetricValue(metric string, val interface{}, dataType string, tags ...string) *dataobj.MetricValue
• func Push(metricItems []*dataobj.MetricValue) error
• 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 Meta

func Meta(id int64) (script string, args string, account string, err error)

Meta 从Server端获取任务元信息

func NewMetricValue

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

func Push

func Push(metricItems []*dataobj.MetricValue) error

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，确实把自己塞进去了