Documentation ¶
Overview ¶
Package google_protobuf_rpc_wire is a generated protocol buffer package.
protorpc wire format wrapper 0. Frame Format len : uvarint64 data: byte[len] 1. Client Send Request Send RequestHeader: sendFrame(conn, hdr, len(hdr)) Send Request: sendFrame(conn, body, hdr.snappy_compressed_request_len) 2. Server Recv Request Recv RequestHeader: recvFrame(conn, hdr, max_hdr_len, 0) Recv Request: recvFrame(conn, body, hdr.snappy_compressed_request_len, 0) 3. Server Send Response Send ResponseHeader: sendFrame(conn, hdr, len(hdr)) Send Response: sendFrame(conn, body, hdr.snappy_compressed_response_len) 4. Client Recv Response Recv ResponseHeader: recvFrame(conn, hdr, max_hdr_len, 0) Recv Response: recvFrame(conn, body, hdr.snappy_compressed_response_len, 0) 5. Header Size len(RequestHeader) < Const.max_header_len.default len(ResponseHeader) < Const.max_header_len.default
It is generated from these files:
wire.proto
It has these top-level messages:
Const RequestHeader ResponseHeader
Index ¶
- Constants
- type Const
- type RequestHeader
- func (m *RequestHeader) GetChecksum() uint32
- func (m *RequestHeader) GetId() uint64
- func (m *RequestHeader) GetMethod() string
- func (m *RequestHeader) GetRawRequestLen() uint32
- func (m *RequestHeader) GetSnappyCompressedRequestLen() uint32
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) String() string
- type ResponseHeader
- func (m *ResponseHeader) GetChecksum() uint32
- func (m *ResponseHeader) GetError() string
- func (m *ResponseHeader) GetId() uint64
- func (m *ResponseHeader) GetRawResponseLen() uint32
- func (m *ResponseHeader) GetSnappyCompressedResponseLen() uint32
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) String() string
Constants ¶
View Source
const Default_Const_MaxHeaderLen uint32 = 1024
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Const ¶
type Const struct { MaxHeaderLen *uint32 `protobuf:"varint,1,opt,name=max_header_len,def=1024" json:"max_header_len,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Const) GetMaxHeaderLen ¶
func (*Const) ProtoMessage ¶
func (*Const) ProtoMessage()
type RequestHeader ¶
type RequestHeader struct { Id uint64 `protobuf:"varint,1,opt,name=id" json:"id"` Method string `protobuf:"bytes,2,opt,name=method" json:"method"` RawRequestLen uint32 `protobuf:"varint,3,opt,name=raw_request_len" json:"raw_request_len"` SnappyCompressedRequestLen uint32 `protobuf:"varint,4,opt,name=snappy_compressed_request_len" json:"snappy_compressed_request_len"` Checksum uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum"` XXX_unrecognized []byte `json:"-"` }
func (*RequestHeader) GetChecksum ¶
func (m *RequestHeader) GetChecksum() uint32
func (*RequestHeader) GetId ¶
func (m *RequestHeader) GetId() uint64
func (*RequestHeader) GetMethod ¶
func (m *RequestHeader) GetMethod() string
func (*RequestHeader) GetRawRequestLen ¶
func (m *RequestHeader) GetRawRequestLen() uint32
func (*RequestHeader) GetSnappyCompressedRequestLen ¶
func (m *RequestHeader) GetSnappyCompressedRequestLen() uint32
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) Reset ¶
func (m *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (m *RequestHeader) String() string
type ResponseHeader ¶
type ResponseHeader struct { Id uint64 `protobuf:"varint,1,opt,name=id" json:"id"` Error string `protobuf:"bytes,2,opt,name=error" json:"error"` RawResponseLen uint32 `protobuf:"varint,3,opt,name=raw_response_len" json:"raw_response_len"` SnappyCompressedResponseLen uint32 `protobuf:"varint,4,opt,name=snappy_compressed_response_len" json:"snappy_compressed_response_len"` Checksum uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum"` XXX_unrecognized []byte `json:"-"` }
func (*ResponseHeader) GetChecksum ¶
func (m *ResponseHeader) GetChecksum() uint32
func (*ResponseHeader) GetError ¶
func (m *ResponseHeader) GetError() string
func (*ResponseHeader) GetId ¶
func (m *ResponseHeader) GetId() uint64
func (*ResponseHeader) GetRawResponseLen ¶
func (m *ResponseHeader) GetRawResponseLen() uint32
func (*ResponseHeader) GetSnappyCompressedResponseLen ¶
func (m *ResponseHeader) GetSnappyCompressedResponseLen() uint32
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) Reset ¶
func (m *ResponseHeader) Reset()
func (*ResponseHeader) String ¶
func (m *ResponseHeader) String() string
Click to show internal directories.
Click to hide internal directories.