apache

package
v0.11.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 11, 2024 License: Apache-2.0 Imports: 8 Imported by: 38

Documentation

Index

Constants

View Source 
const (
	VERSION_MASK = 0xffff0000
	VERSION_1    = 0x80010000
)
View Source 
const (
	UNKNOWN_PROTOCOL_EXCEPTION = 0
	INVALID_DATA               = 1
	NEGATIVE_SIZE              = 2
	SIZE_LIMIT                 = 3
	BAD_VERSION                = 4
	NOT_IMPLEMENTED            = 5
	DEPTH_LIMIT                = 6
)
View Source 
const (
	STOP   = 0
	VOID   = 1
	BOOL   = 2
	BYTE   = 3
	I08    = 3
	DOUBLE = 4
	I16    = 6
	I32    = 8
	I64    = 10
	STRING = 11
	UTF7   = 11
	STRUCT = 12
	MAP    = 13
	SET    = 14
	LIST   = 15
	UTF8   = 16
	UTF16  = 17
)

Variables

View Source 
var (
	PrependError                  = thrift.PrependError
	NewTProtocolExceptionWithType = thrift.NewTProtocolExceptionWithType
)
View Source 
var SkipDefaultDepth = thrift.SkipDefaultDepth

Functions

This section is empty.

Types

type BinaryProtocol 

type BinaryProtocol struct {
	// contains filtered or unexported fields
}

BinaryProtocol was moved from cloudwego/kitex/pkg/remote/codec/thrift

func NewBinaryProtocol 

func NewBinaryProtocol(r bufiox.Reader, w bufiox.Writer) *BinaryProtocol

NewBinaryProtocol ... Deprecated: use github.com/cloudwego/gopkg/protocol/thrift.NewBufferReader|NewBufferWriter

func (*BinaryProtocol) Flush 

func (p *BinaryProtocol) Flush(ctx context.Context) (err error)

Flush ...

func (*BinaryProtocol) ReadBinary 

func (p *BinaryProtocol) ReadBinary() ([]byte, error)

ReadBinary ...

func (*BinaryProtocol) ReadBool 

func (p *BinaryProtocol) ReadBool() (bool, error)

ReadBool ...

func (*BinaryProtocol) ReadByte 

func (p *BinaryProtocol) ReadByte() (value int8, err error)

ReadByte ...

func (*BinaryProtocol) ReadDouble 

func (p *BinaryProtocol) ReadDouble() (value float64, err error)

ReadDouble ...

func (*BinaryProtocol) ReadFieldBegin 

func (p *BinaryProtocol) ReadFieldBegin() (name string, typeID TType, id int16, err error)

ReadFieldBegin ...

func (*BinaryProtocol) ReadFieldEnd 

func (p *BinaryProtocol) ReadFieldEnd() error

ReadFieldEnd ...

func (*BinaryProtocol) ReadI16 

func (p *BinaryProtocol) ReadI16() (value int16, err error)

ReadI16 ...

func (*BinaryProtocol) ReadI32 

func (p *BinaryProtocol) ReadI32() (value int32, err error)

ReadI32 ...

func (*BinaryProtocol) ReadI64 

func (p *BinaryProtocol) ReadI64() (value int64, err error)

ReadI64 ...

func (*BinaryProtocol) ReadListBegin 

func (p *BinaryProtocol) ReadListBegin() (elemType TType, size int, err error)

ReadListBegin ...

func (*BinaryProtocol) ReadListEnd 

func (p *BinaryProtocol) ReadListEnd() error

ReadListEnd ...

func (*BinaryProtocol) ReadMapBegin 

func (p *BinaryProtocol) ReadMapBegin() (kType, vType TType, size int, err error)

ReadMapBegin ...

func (*BinaryProtocol) ReadMapEnd 

func (p *BinaryProtocol) ReadMapEnd() error

ReadMapEnd ...

func (*BinaryProtocol) ReadMessageBegin 

func (p *BinaryProtocol) ReadMessageBegin() (name string, typeID TMessageType, seqID int32, err error)

ReadMessageBegin ...

func (*BinaryProtocol) ReadMessageEnd 

func (p *BinaryProtocol) ReadMessageEnd() error

ReadMessageEnd ...

func (*BinaryProtocol) ReadSetBegin 

func (p *BinaryProtocol) ReadSetBegin() (elemType TType, size int, err error)

ReadSetBegin ...

func (*BinaryProtocol) ReadSetEnd 

func (p *BinaryProtocol) ReadSetEnd() error

ReadSetEnd ...

func (*BinaryProtocol) ReadString 

func (p *BinaryProtocol) ReadString() (value string, err error)

ReadString ...

func (*BinaryProtocol) ReadStructBegin 

func (p *BinaryProtocol) ReadStructBegin() (name string, err error)

ReadStructBegin ...

func (*BinaryProtocol) ReadStructEnd 

func (p *BinaryProtocol) ReadStructEnd() error

ReadStructEnd ...

func (*BinaryProtocol) Recycle 

func (p *BinaryProtocol) Recycle()

Recycle ...

func (*BinaryProtocol) Skip 

func (p *BinaryProtocol) Skip(fieldType TType) (err error)

Skip ...

func (*BinaryProtocol) Transport 

func (p *BinaryProtocol) Transport() TTransport

Transport ...

func (*BinaryProtocol) WriteBinary 

func (p *BinaryProtocol) WriteBinary(value []byte) error

WriteBinary ...

func (*BinaryProtocol) WriteBool 

func (p *BinaryProtocol) WriteBool(value bool) error

WriteBool ...

func (*BinaryProtocol) WriteByte 

func (p *BinaryProtocol) WriteByte(value int8) error

WriteByte ...

func (*BinaryProtocol) WriteDouble 

func (p *BinaryProtocol) WriteDouble(value float64) error

WriteDouble ...

func (*BinaryProtocol) WriteFieldBegin 

func (p *BinaryProtocol) WriteFieldBegin(name string, typeID TType, id int16) error

WriteFieldBegin ...

func (*BinaryProtocol) WriteFieldEnd 

func (p *BinaryProtocol) WriteFieldEnd() error

WriteFieldEnd ...

func (*BinaryProtocol) WriteFieldStop 

func (p *BinaryProtocol) WriteFieldStop() error

WriteFieldStop ...

func (*BinaryProtocol) WriteI16 

func (p *BinaryProtocol) WriteI16(value int16) error

WriteI16 ...

func (*BinaryProtocol) WriteI32 

func (p *BinaryProtocol) WriteI32(value int32) error

WriteI32 ...

func (*BinaryProtocol) WriteI64 

func (p *BinaryProtocol) WriteI64(value int64) error

WriteI64 ...

func (*BinaryProtocol) WriteListBegin 

func (p *BinaryProtocol) WriteListBegin(elemType TType, size int) error

WriteListBegin ...

func (*BinaryProtocol) WriteListEnd 

func (p *BinaryProtocol) WriteListEnd() error

WriteListEnd ...

func (*BinaryProtocol) WriteMapBegin 

func (p *BinaryProtocol) WriteMapBegin(keyType, valueType TType, size int) error

WriteMapBegin ...

func (*BinaryProtocol) WriteMapEnd 

func (p *BinaryProtocol) WriteMapEnd() error

WriteMapEnd ...

func (*BinaryProtocol) WriteMessageBegin 

func (p *BinaryProtocol) WriteMessageBegin(name string, typeID TMessageType, seqID int32) error

WriteMessageBegin ...

func (*BinaryProtocol) WriteMessageEnd 

func (p *BinaryProtocol) WriteMessageEnd() error

WriteMessageEnd ...

func (*BinaryProtocol) WriteSetBegin 

func (p *BinaryProtocol) WriteSetBegin(elemType TType, size int) error

WriteSetBegin ...

func (*BinaryProtocol) WriteSetEnd 

func (p *BinaryProtocol) WriteSetEnd() error

WriteSetEnd ...

func (*BinaryProtocol) WriteString 

func (p *BinaryProtocol) WriteString(value string) error

WriteString ...

func (*BinaryProtocol) WriteStructBegin 

func (p *BinaryProtocol) WriteStructBegin(name string) error

WriteStructBegin ...

func (*BinaryProtocol) WriteStructEnd 

func (p *BinaryProtocol) WriteStructEnd() error

WriteStructEnd ...

type TException 

type TException = thrift.TException

type TMessageType 

type TMessageType = thrift.TMessageType
const (
	INVALID_TMESSAGE_TYPE TMessageType = 0
	CALL                  TMessageType = 1
	REPLY                 TMessageType = 2
	EXCEPTION             TMessageType = 3
	ONEWAY                TMessageType = 4
)

type TProtocol 

type TProtocol = thrift.TProtocol

type TStruct 

type TStruct = thrift.TStruct

type TTransport 

type TTransport = thrift.TTransport

type TType 

type TType = thrift.TType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.