go/thrift/binary_protocol.go

32 type TBinaryProtocol struct {  struct
33 	trans         TRichTransport
34 	origTransport TTransport
35 	strictRead    bool
36 	strictWrite   bool
37 	buffer        [64]byte
75 func (p *TBinaryProtocol) WriteMessageBegin(name string, typeId TMessageType, seqId int32) error {
103 func (p *TBinaryProtocol) WriteMessageEnd() error {
107 func (p *TBinaryProtocol) WriteStructBegin(name string) error {
111 func (p *TBinaryProtocol) WriteStructEnd() error {
115 func (p *TBinaryProtocol) WriteFieldBegin(name string, typeId TType, id int16) error {
124 func (p *TBinaryProtocol) WriteFieldEnd() error {
128 func (p *TBinaryProtocol) WriteFieldStop() error {
133 func (p *TBinaryProtocol) WriteMapBegin(keyType TType, valueType TType, size int) error {
146 func (p *TBinaryProtocol) WriteMapEnd() error {
150 func (p *TBinaryProtocol) WriteListBegin(elemType TType, size int) error {
159 func (p *TBinaryProtocol) WriteListEnd() error {
163 func (p *TBinaryProtocol) WriteSetBegin(elemType TType, size int) error {
172 func (p *TBinaryProtocol) WriteSetEnd() error {
176 func (p *TBinaryProtocol) WriteBool(value bool) error {
183 func (p *TBinaryProtocol) WriteByte(value int8) error {
188 func (p *TBinaryProtocol) WriteI16(value int16) error {
195 func (p *TBinaryProtocol) WriteI32(value int32) error {
202 func (p *TBinaryProtocol) WriteI64(value int64) error {
209 func (p *TBinaryProtocol) WriteDouble(value float64) error {
213 func (p *TBinaryProtocol) WriteString(value string) error {
222 func (p *TBinaryProtocol) WriteBinary(value []byte) error {
235 …p *TBinaryProtocol) ReadMessageBegin() (name string, typeId TMessageType, seqId int32, err error) {
275 func (p *TBinaryProtocol) ReadMessageEnd() error {
279 func (p *TBinaryProtocol) ReadStructBegin() (name string, err error) {
283 func (p *TBinaryProtocol) ReadStructEnd() error {
287 func (p *TBinaryProtocol) ReadFieldBegin() (name string, typeId TType, seqId int16, err error) {
299 func (p *TBinaryProtocol) ReadFieldEnd() error {
305 func (p *TBinaryProtocol) ReadMapBegin() (kType, vType TType, size int, err error) {
331 func (p *TBinaryProtocol) ReadMapEnd() error {
335 func (p *TBinaryProtocol) ReadListBegin() (elemType TType, size int, err error) {
356 func (p *TBinaryProtocol) ReadListEnd() error {
360 func (p *TBinaryProtocol) ReadSetBegin() (elemType TType, size int, err error) {
380 func (p *TBinaryProtocol) ReadSetEnd() error {
384 func (p *TBinaryProtocol) ReadBool() (bool, error) {
393 func (p *TBinaryProtocol) ReadByte() (int8, error) {
398 func (p *TBinaryProtocol) ReadI16() (value int16, err error) {
405 func (p *TBinaryProtocol) ReadI32() (value int32, err error) {
412 func (p *TBinaryProtocol) ReadI64() (value int64, err error) {
419 func (p *TBinaryProtocol) ReadDouble() (value float64, err error) {
426 func (p *TBinaryProtocol) ReadString() (value string, err error) {
439 func (p *TBinaryProtocol) ReadBinary() ([]byte, error) {
454 func (p *TBinaryProtocol) Flush(ctx context.Context) (err error) {
458 func (p *TBinaryProtocol) Skip(fieldType TType) (err error) {
462 func (p *TBinaryProtocol) Transport() TTransport {
466 func (p *TBinaryProtocol) readAll(buf []byte) error {
473 func (p *TBinaryProtocol) readStringBody(size int32) (value string, err error) {