go/thrift/binary_protocol.go

32 type TBinaryProtocol struct {  struct
33 	trans         TRichTransport
34 	origTransport TTransport
35 	cfg           *TConfiguration
36 	buffer        [64]byte
109 …ocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error {
137 func (p *TBinaryProtocol) WriteMessageEnd(ctx context.Context) error {
141 func (p *TBinaryProtocol) WriteStructBegin(ctx context.Context, name string) error {
145 func (p *TBinaryProtocol) WriteStructEnd(ctx context.Context) error {
149 …*TBinaryProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16) error {
158 func (p *TBinaryProtocol) WriteFieldEnd(ctx context.Context) error {
162 func (p *TBinaryProtocol) WriteFieldStop(ctx context.Context) error {
167 …inaryProtocol) WriteMapBegin(ctx context.Context, keyType TType, valueType TType, size int) error {
180 func (p *TBinaryProtocol) WriteMapEnd(ctx context.Context) error {
184 func (p *TBinaryProtocol) WriteListBegin(ctx context.Context, elemType TType, size int) error {
193 func (p *TBinaryProtocol) WriteListEnd(ctx context.Context) error {
197 func (p *TBinaryProtocol) WriteSetBegin(ctx context.Context, elemType TType, size int) error {
206 func (p *TBinaryProtocol) WriteSetEnd(ctx context.Context) error {
210 func (p *TBinaryProtocol) WriteBool(ctx context.Context, value bool) error {
217 func (p *TBinaryProtocol) WriteByte(ctx context.Context, value int8) error {
222 func (p *TBinaryProtocol) WriteI16(ctx context.Context, value int16) error {
229 func (p *TBinaryProtocol) WriteI32(ctx context.Context, value int32) error {
236 func (p *TBinaryProtocol) WriteI64(ctx context.Context, value int64) error {
243 func (p *TBinaryProtocol) WriteDouble(ctx context.Context, value float64) error {
247 func (p *TBinaryProtocol) WriteString(ctx context.Context, value string) error {
256 func (p *TBinaryProtocol) WriteBinary(ctx context.Context, value []byte) error {
269 … ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error) {
309 func (p *TBinaryProtocol) ReadMessageEnd(ctx context.Context) error {
313 func (p *TBinaryProtocol) ReadStructBegin(ctx context.Context) (name string, err error) {
317 func (p *TBinaryProtocol) ReadStructEnd(ctx context.Context) error {
321 …Protocol) ReadFieldBegin(ctx context.Context) (name string, typeId TType, seqId int16, err error) {
333 func (p *TBinaryProtocol) ReadFieldEnd(ctx context.Context) error {
339 … (p *TBinaryProtocol) ReadMapBegin(ctx context.Context) (kType, vType TType, size int, err error) {
365 func (p *TBinaryProtocol) ReadMapEnd(ctx context.Context) error {
369 func (p *TBinaryProtocol) ReadListBegin(ctx context.Context) (elemType TType, size int, err error) {
390 func (p *TBinaryProtocol) ReadListEnd(ctx context.Context) error {
394 func (p *TBinaryProtocol) ReadSetBegin(ctx context.Context) (elemType TType, size int, err error) {
414 func (p *TBinaryProtocol) ReadSetEnd(ctx context.Context) error {
418 func (p *TBinaryProtocol) ReadBool(ctx context.Context) (bool, error) {
427 func (p *TBinaryProtocol) ReadByte(ctx context.Context) (int8, error) {
432 func (p *TBinaryProtocol) ReadI16(ctx context.Context) (value int16, err error) {
439 func (p *TBinaryProtocol) ReadI32(ctx context.Context) (value int32, err error) {
446 func (p *TBinaryProtocol) ReadI64(ctx context.Context) (value int64, err error) {
453 func (p *TBinaryProtocol) ReadDouble(ctx context.Context) (value float64, err error) {
460 func (p *TBinaryProtocol) ReadString(ctx context.Context) (value string, err error) {
486 func (p *TBinaryProtocol) ReadBinary(ctx context.Context) ([]byte, error) {
499 func (p *TBinaryProtocol) Flush(ctx context.Context) (err error) {
503 func (p *TBinaryProtocol) Skip(ctx context.Context, fieldType TType) (err error) {
507 func (p *TBinaryProtocol) Transport() TTransport {
511 func (p *TBinaryProtocol) readAll(ctx context.Context, buf []byte) (err error) {
527 func (p *TBinaryProtocol) readStringBody(size int32) (value string, err error) {
532 func (p *TBinaryProtocol) SetTConfiguration(conf *TConfiguration) {