rpc

package

v0.0.0-...-dfc5ca7 Latest Latest Go to latest Published: Feb 17, 2017 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func NewRpcListener() (*net.TCPListener, error)

func RecvMetricValues(args []*cmodel.MetricValue, reply *cmodel.TransferResponse, from string) error

process new metric values

func RpcServe(ln *net.TCPListener)

func StartRpc()

type Transfer int

func (this *Transfer) Ping(req cmodel.NullRpcRequest, resp *cmodel.SimpleRpcResponse) error

func (t *Transfer) Update(args []*cmodel.MetricValue, reply *cmodel.TransferResponse) error

type TransferResp struct {
	Msg        string
	Total      int
	ErrInvalid int
	Latency    int64
}

func (t *TransferResp) String() string