INNER CODE UNIT · Go

func

go-graphite/go-carbon · api/api.go:37

func (api *Api) Addr() net.Addr {
	if api.listener == nil {
		return nil
	}
	return api.listener.Addr()
}

// Collect cache metrics
func (api *Api) Stat(send helper.StatCallback) {
	helper.SendAndSubstractUint32("cacheRequests", &api.stat.cacheRequests, send)
	helper.SendAndSubstractUint32("cacheRequestMetrics", &api.stat.cacheRequestMetrics, send)
	helper.SendAndSubstractUint32("cacheResponseMetrics", &api.stat.cacheResponseMetrics, send)
	helper.SendAndSubstractUint32("cacheResponsePoints", &api.stat.cacheResponsePoints, send)
}

// Listen bind port. Receive messages and send to out channel
func (api *Api) Listen(addr *net.TCPAddr) error {
	return api.StartFunc(func() error {

View source record →