rpc

Documentation

Index

• func StartRpc()
• type PolyRequest
• type Polymetric
  • func (this *Polymetric) Ping(req cmodel.NullRpcRequest, resp *cmodel.SimpleRpcResponse) error
  • func (t *Polymetric) Update(args []*cmodel.PolyRequest, reply *PolymetricResp) error
• type PolymetricResp
  • func (t *PolymetricResp) String() string

Functions

func StartRpc

func StartRpc()

Types

type PolyRequest

type PolyRequest struct {
	PolyName string      `json:"poly_name"`
	Value    interface{} `json:"value"`
}

type Polymetric

type Polymetric int

func (*Polymetric) Ping

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

func (*Polymetric) Update

func (t *Polymetric) Update(args []*cmodel.PolyRequest, reply *PolymetricResp) error

type PolymetricResp

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

func (*PolymetricResp) String

func (t *PolymetricResp) String() string