core

package
v4.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 4, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL