...
Package protorpc
Overview ▹
Index ▹
func NewCodec ¶
func NewCodec(rwc io.ReadWriteCloser) codec.Codec
func ReadNetString ¶
func ReadNetString(r io.Reader) (data []byte, err error)
ReadNetString reads data from a big-endian netstring.
func WriteNetString ¶
func WriteNetString(w io.Writer, data []byte) (written int, err error)
WriteNetString writes data to a big-endian netstring on a Writer. Size is always a 32-bit unsigned int.
type Request ¶
type Request struct { ServiceMethod *string `protobuf:"bytes,1,opt,name=service_method" json:"service_method,omitempty"` Seq *uint64 `protobuf:"fixed64,2,opt,name=seq" json:"seq,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Request) GetSeq ¶
func (m *Request) GetSeq() uint64
func (*Request) GetServiceMethod ¶
func (m *Request) GetServiceMethod() string
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) Reset ¶
func (m *Request) Reset()
func (*Request) String ¶
func (m *Request) String() string
type Response ¶
type Response struct { ServiceMethod *string `protobuf:"bytes,1,opt,name=service_method" json:"service_method,omitempty"` Seq *uint64 `protobuf:"fixed64,2,opt,name=seq" json:"seq,omitempty"` Error *string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Response) GetError ¶
func (m *Response) GetError() string
func (*Response) GetSeq ¶
func (m *Response) GetSeq() uint64
func (*Response) GetServiceMethod ¶
func (m *Response) GetServiceMethod() string
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) Reset ¶
func (m *Response) Reset()
func (*Response) String ¶
func (m *Response) String() string