rpcenc

type JSONClientEncoder struct{}

type JSONReply struct {
	Result json.RawMessage `json:"result,omitempty"`
	Error  string          `json:"error,omitempty"`
}

type JSONRequest struct {
	Param    json.RawMessage `json:"param"`
	MetaData nproto.MetaData `json:"metaData,omitempty"`
	Timeout  int64           `json:"timeout,omitempty"`
}

type JSONServerEncoder struct{}

type PBClientEncoder struct{}

type PBServerEncoder struct{}

type RPCClientEncoder interface {
	// EncodeRequest encodes request to data.
	EncodeRequest(req *RPCRequest) ([]byte, error)
	// DecodeReply decodes reply from data.
	DecodeReply(data []byte, reply *RPCReply) error
}

type RPCReply struct {
	// Result is the normal result of this rpc. Must set to nil if there is an error.
	// NOTE: Must filled with an empty proto message before decoding.
	// Otherwise the encoder can't determine the which type to decode.
	Result proto.Message
	// Error is the error result of this rpc. Must set to nil if there is no error.
	Error error
}

type RPCRequest struct {
	// Param is the parameter of this rpc.
	// NOTE: Must filled with an empty proto message before decoding.
	// Otherwise the encoder can't determine which type to decode.
	Param proto.Message
	// MD is a dict containing extra context information. Maybe nil.
	MD nproto.MD
	// Timeout is timeout of this RPC if > 0.
	Timeout time.Duration
}

type RPCServerEncoder interface {
	// DecodeRequest decodes request from data.
	DecodeRequest(data []byte, req *RPCRequest) error
	// EncodeReply encodes reply to data.
	EncodeReply(reply *RPCReply) ([]byte, error)
}