Documentation ¶
Overview ¶
Package protorpc_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(zsock, hdr, len(hdr)) Send Request: sendFrame(zsock, body, hdr.snappy_compressed_request_len) 2. Server Recv Request Recv RequestHeader: recvFrame(zsock, hdr, max_hdr_len, 0) Recv Request: recvFrame(zsock, body, hdr.snappy_compressed_request_len, 0) 3. Server Send Response Send ResponseHeader: sendFrame(zsock, hdr, len(hdr)) Send Response: sendFrame(zsock, body, hdr.snappy_compressed_response_len) 4. Client Recv Response Recv ResponseHeader: recvFrame(zsock, hdr, max_hdr_len, 0) Recv Response: recvFrame(zsock, body, hdr.snappy_compressed_response_len, 0)
It is generated from these files:
wire.proto
It has these top-level messages:
RequestHeader ResponseHeader
Index ¶
- Variables
- type Const
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- 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 (*ResponseHeader) Descriptor() ([]byte, []int)
- 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 ¶
This section is empty.
Variables ¶
View Source
var Const_name = map[int32]string{
0: "ZERO",
1024: "MAX_REQUEST_HEADER_LEN",
}
View Source
var Const_value = map[string]int32{
"ZERO": 0,
"MAX_REQUEST_HEADER_LEN": 1024,
}
Functions ¶
This section is empty.
Types ¶
type RequestHeader ¶
type RequestHeader struct { Id uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"` Method string `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"` RawRequestLen uint32 `protobuf:"varint,3,opt,name=raw_request_len,json=rawRequestLen" json:"raw_request_len,omitempty"` SnappyCompressedRequestLen uint32 `` /* 137-byte string literal not displayed */ Checksum uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum,omitempty"` }
func (*RequestHeader) Descriptor ¶
func (*RequestHeader) Descriptor() ([]byte, []int)
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,omitempty"` Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` RawResponseLen uint32 `protobuf:"varint,3,opt,name=raw_response_len,json=rawResponseLen" json:"raw_response_len,omitempty"` SnappyCompressedResponseLen uint32 `` /* 140-byte string literal not displayed */ Checksum uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum,omitempty"` }
func (*ResponseHeader) Descriptor ¶
func (*ResponseHeader) Descriptor() ([]byte, []int)
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.