Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

thrift

package

Go to main page

Versions in this module

v0

v0.1.3

Nov 27, 2024

v0.1.2

Sep 10, 2024

v0.1.1

Aug 29, 2024

Changes in this version

+ func SetSpanCache(enable bool)

+ type BufferReader struct

+ func NewBufferReader(r bufiox.Reader) *BufferReader

+ func (r *BufferReader) ReadBinary() (b []byte, err error)

+ func (r *BufferReader) ReadBool() (v bool, err error)

+ func (r *BufferReader) ReadByte() (v int8, err error)

+ func (r *BufferReader) ReadDouble() (v float64, err error)

+ func (r *BufferReader) ReadFieldBegin() (typeID TType, id int16, err error)

+ func (r *BufferReader) ReadI16() (v int16, err error)

+ func (r *BufferReader) ReadI32() (v int32, err error)

+ func (r *BufferReader) ReadI64() (v int64, err error)

+ func (r *BufferReader) ReadListBegin() (et TType, size int, err error)

+ func (r *BufferReader) ReadMapBegin() (kt, vt TType, size int, err error)

+ func (r *BufferReader) ReadMessageBegin() (name string, typeID TMessageType, seq int32, err error)

+ func (r *BufferReader) ReadSetBegin() (et TType, size int, err error)

+ func (r *BufferReader) ReadString() (s string, err error)

+ func (r *BufferReader) Readn() int64

+ func (r *BufferReader) Recycle()

+ func (r *BufferReader) Skip(t TType) error

+ type BufferWriter struct

+ func NewBufferWriter(iw bufiox.Writer) *BufferWriter

+ func (w *BufferWriter) Recycle()

+ func (w *BufferWriter) WriteBinary(v []byte) error

+ func (w *BufferWriter) WriteBool(v bool) error

+ func (w *BufferWriter) WriteByte(v int8) error

+ func (w *BufferWriter) WriteDouble(v float64) error

+ func (w *BufferWriter) WriteFieldBegin(typeID TType, id int16) error

+ func (w *BufferWriter) WriteFieldStop() error

+ func (w *BufferWriter) WriteI16(v int16) error

+ func (w *BufferWriter) WriteI32(v int32) error

+ func (w *BufferWriter) WriteI64(v int64) error

+ func (w *BufferWriter) WriteListBegin(et TType, size int) error

+ func (w *BufferWriter) WriteMapBegin(kt, vt TType, size int) error

+ func (w *BufferWriter) WriteMessageBegin(name string, typeID TMessageType, seq int32) error

+ func (w *BufferWriter) WriteSetBegin(et TType, size int) error

+ func (w *BufferWriter) WriteString(v string) error

v0.1.0

Jul 31, 2024

Changes in this version

+ const BAD_SEQUENCE_ID

+ const BAD_VERSION

+ const DEPTH_LIMIT

+ const INTERNAL_ERROR

+ const INVALID_DATA

+ const INVALID_MESSAGE_TYPE_EXCEPTION

+ const INVALID_PROTOCOL

+ const INVALID_TRANSFORM

+ const MISSING_RESULT

+ const NEGATIVE_SIZE

+ const NOT_IMPLEMENTED

+ const PROTOCOL_ERROR

+ const SIZE_LIMIT

+ const UNKNOWN_APPLICATION_EXCEPTION

+ const UNKNOWN_METHOD

+ const UNKNOWN_PROTOCOL_EXCEPTION

+ const UNSUPPORTED_CLIENT_TYPE

+ const WRONG_METHOD_NAME

+ var NocopyWriteThreshold = 4096

+ func FastMarshal(msg FastCodec) []byte

+ func FastUnmarshal(buf []byte, msg FastCodec) error

+ func MarshalFastMsg(method string, msgType TMessageType, seq int32, msg FastCodec) ([]byte, error)

+ func PrependError(prepend string, err error) error

+ func UnmarshalFastMsg(b []byte, msg FastCodec) (method string, seq int32, err error)

+ type ApplicationException struct

+ func NewApplicationException(t int32, msg string) *ApplicationException

+ func (e *ApplicationException) BLength() int

+ func (e *ApplicationException) Error() string

+ func (e *ApplicationException) FastRead(b []byte) (off int, err error)

+ func (e *ApplicationException) FastWrite(b []byte) (off int)

+ func (e *ApplicationException) FastWriteNocopy(b []byte, _ NocopyWriter) int

+ func (e *ApplicationException) Msg() string

+ func (e *ApplicationException) String() string

+ func (e *ApplicationException) TypeID() int32

+ func (e *ApplicationException) TypeId() int32

+ type BinaryProtocol struct

+ var Binary BinaryProtocol

+ func (BinaryProtocol) AppendBool(buf []byte, v bool) []byte

+ func (BinaryProtocol) AppendByte(buf []byte, v int8) []byte

+ func (BinaryProtocol) AppendDouble(buf []byte, v float64) []byte

+ func (BinaryProtocol) AppendFieldBegin(buf []byte, typeID TType, id int16) []byte

+ func (BinaryProtocol) AppendFieldStop(buf []byte) []byte

+ func (BinaryProtocol) AppendI16(buf []byte, v int16) []byte

+ func (BinaryProtocol) AppendI32(buf []byte, v int32) []byte

+ func (BinaryProtocol) AppendI64(buf []byte, v int64) []byte

+ func (BinaryProtocol) BinaryLength(v []byte) int

+ func (BinaryProtocol) BinaryLengthNocopy(v []byte) int

+ func (BinaryProtocol) BoolLength() int

+ func (BinaryProtocol) ByteLength() int

+ func (BinaryProtocol) DoubleLength() int

+ func (BinaryProtocol) FieldBeginLength() int

+ func (BinaryProtocol) FieldStopLength() int

+ func (BinaryProtocol) I16Length() int

+ func (BinaryProtocol) I32Length() int

+ func (BinaryProtocol) I64Length() int

+ func (BinaryProtocol) ListBeginLength() int

+ func (BinaryProtocol) MapBeginLength() int

+ func (BinaryProtocol) MessageBeginLength(method string) int

+ func (BinaryProtocol) ReadBool(buf []byte) (v bool, l int, err error)

+ func (BinaryProtocol) ReadByte(buf []byte) (v int8, l int, err error)

+ func (BinaryProtocol) ReadDouble(buf []byte) (v float64, l int, err error)

+ func (BinaryProtocol) ReadFieldBegin(buf []byte) (typeID TType, id int16, l int, err error)

+ func (BinaryProtocol) ReadI16(buf []byte) (v int16, l int, err error)

+ func (BinaryProtocol) ReadI32(buf []byte) (v int32, l int, err error)

+ func (BinaryProtocol) ReadI64(buf []byte) (v int64, l int, err error)

+ func (BinaryProtocol) ReadListBegin(buf []byte) (et TType, size, l int, err error)

+ func (BinaryProtocol) ReadMapBegin(buf []byte) (kt, vt TType, size, l int, err error)

+ func (BinaryProtocol) ReadSetBegin(buf []byte) (et TType, size, l int, err error)

+ func (BinaryProtocol) SetBeginLength() int

+ func (BinaryProtocol) Skip(b []byte, t TType) (int, error)

+ func (BinaryProtocol) StringLength(v string) int

+ func (BinaryProtocol) StringLengthNocopy(v string) int

+ func (BinaryProtocol) WriteBinary(buf, v []byte) int

+ func (BinaryProtocol) WriteBool(buf []byte, v bool) int

+ func (BinaryProtocol) WriteByte(buf []byte, v int8) int

+ func (BinaryProtocol) WriteDouble(buf []byte, v float64) int

+ func (BinaryProtocol) WriteFieldBegin(buf []byte, typeID TType, id int16) int

+ func (BinaryProtocol) WriteFieldStop(buf []byte) int

+ func (BinaryProtocol) WriteI16(buf []byte, v int16) int

+ func (BinaryProtocol) WriteI32(buf []byte, v int32) int

+ func (BinaryProtocol) WriteI64(buf []byte, v int64) int

+ func (BinaryProtocol) WriteListBegin(buf []byte, et TType, size int) int

+ func (BinaryProtocol) WriteMapBegin(buf []byte, kt, vt TType, size int) int

+ func (BinaryProtocol) WriteMessageBegin(buf []byte, name string, typeID TMessageType, seq int32) int

+ func (BinaryProtocol) WriteSetBegin(buf []byte, et TType, size int) int

+ func (BinaryProtocol) WriteString(buf []byte, v string) int

+ func (p BinaryProtocol) AppendBinary(buf, v []byte) []byte

+ func (p BinaryProtocol) AppendListBegin(buf []byte, et TType, size int) []byte

+ func (p BinaryProtocol) AppendMapBegin(buf []byte, kt, vt TType, size int) []byte

+ func (p BinaryProtocol) AppendMessageBegin(buf []byte, name string, typeID TMessageType, seq int32) []byte

+ func (p BinaryProtocol) AppendSetBegin(buf []byte, et TType, size int) []byte

+ func (p BinaryProtocol) AppendString(buf []byte, v string) []byte

+ func (p BinaryProtocol) ReadBinary(buf []byte) (b []byte, l int, err error)

+ func (p BinaryProtocol) ReadMessageBegin(buf []byte) (name string, typeID TMessageType, seq int32, l int, err error)

+ func (p BinaryProtocol) ReadString(buf []byte) (s string, l int, err error)

+ func (p BinaryProtocol) WriteBinaryNocopy(buf []byte, w NocopyWriter, v []byte) int

+ func (p BinaryProtocol) WriteStringNocopy(buf []byte, w NocopyWriter, v string) int

+ type BinaryReader struct

+ func NewBinaryReader(r io.Reader) *BinaryReader

+ func (r *BinaryReader) ReadBinary() (b []byte, err error)

+ func (r *BinaryReader) ReadBool() (v bool, err error)

+ func (r *BinaryReader) ReadByte() (v int8, err error)

+ func (r *BinaryReader) ReadDouble() (v float64, err error)

+ func (r *BinaryReader) ReadFieldBegin() (typeID TType, id int16, err error)

+ func (r *BinaryReader) ReadI16() (v int16, err error)

+ func (r *BinaryReader) ReadI32() (v int32, err error)

+ func (r *BinaryReader) ReadI64() (v int64, err error)

+ func (r *BinaryReader) ReadListBegin() (et TType, size int, err error)

+ func (r *BinaryReader) ReadMapBegin() (kt, vt TType, size int, err error)

+ func (r *BinaryReader) ReadMessageBegin() (name string, typeID TMessageType, seq int32, err error)

+ func (r *BinaryReader) ReadSetBegin() (et TType, size int, err error)

+ func (r *BinaryReader) ReadString() (s string, err error)

+ func (r *BinaryReader) Readn() int64

+ func (r *BinaryReader) Release()

+ func (r *BinaryReader) Skip(t TType) error

+ type BinaryWriter struct

+ func NewBinaryWriter() *BinaryWriter

+ func NewBinaryWriterSize(sz int) *BinaryWriter

+ func (w *BinaryWriter) Bytes() []byte

+ func (w *BinaryWriter) Release()

+ func (w *BinaryWriter) Reset()

+ func (w *BinaryWriter) WriteBinary(v []byte)

+ func (w *BinaryWriter) WriteBool(v bool)

+ func (w *BinaryWriter) WriteByte(v int8)

+ func (w *BinaryWriter) WriteDouble(v float64)

+ func (w *BinaryWriter) WriteFieldBegin(typeID TType, id int16)

+ func (w *BinaryWriter) WriteFieldStop()

+ func (w *BinaryWriter) WriteI16(v int16)

+ func (w *BinaryWriter) WriteI32(v int32)

+ func (w *BinaryWriter) WriteI64(v int64)

+ func (w *BinaryWriter) WriteListBegin(et TType, size int)

+ func (w *BinaryWriter) WriteMapBegin(kt, vt TType, size int)

+ func (w *BinaryWriter) WriteMessageBegin(name string, typeID TMessageType, seq int32)

+ func (w *BinaryWriter) WriteSetBegin(et TType, size int)

+ func (w *BinaryWriter) WriteString(v string)

+ type FastCodec interface

+ BLength func() int

+ FastRead func(buf []byte) (int, error)

+ FastWriteNocopy func(buf []byte, bw NocopyWriter) int

+ type NocopyWriter interface

+ WriteDirect func(b []byte, remainCap int) error

+ type ProtocolException struct

+ func NewProtocolException(t int32, m string) *ProtocolException

+ func NewProtocolExceptionWithErr(err error) *ProtocolException

+ func (e *ProtocolException) Is(err error) bool

+ func (e *ProtocolException) Unwrap() error

+ type SkipDecoder struct

+ func NewSkipDecoder(r io.Reader) *SkipDecoder

+ func (p *SkipDecoder) Next(t TType) (buf []byte, err error)

+ func (p *SkipDecoder) Release()

+ func (p *SkipDecoder) Reset(r io.Reader)

+ type TMessageType = int32

+ const CALL

+ const EXCEPTION

+ const INVALID_TMESSAGE_TYPE

+ const ONEWAY

+ const REPLY

+ type TType = int8

+ const BOOL

+ const BYTE

+ const DOUBLE

+ const I08

+ const I16

+ const I32

+ const I64

+ const LIST

+ const MAP

+ const SET

+ const STOP

+ const STRING

+ const STRUCT

+ const UTF16

+ const UTF7

+ const UTF8

+ const VOID

+ type TransportException struct

+ func NewTransportException(t int32, m string) *TransportException