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.8

Dec 4, 2023

v0.1.7

Jan 26, 2022

v0.1.6

Jan 25, 2022

v0.1.5

Oct 28, 2021

v0.1.4

Oct 27, 2021

v0.1.3

Oct 27, 2021

v0.1.2

Oct 26, 2021

v0.1.1

Oct 26, 2021

v0.1.0

Oct 26, 2021

Changes in this version

+ const DefaultMaxFrameSize

+ const ExceptionBadSequenceID

+ const ExceptionInternalError

+ const ExceptionInvalidMessageType

+ const ExceptionMissingResult

+ const ExceptionProtocolError

+ const ExceptionUnknown

+ const ExceptionUnknownMethod

+ const ExceptionWrongMethodName

+ const MessageTypeCall

+ const MessageTypeException

+ const MessageTypeOneway

+ const MessageTypeReply

+ const TypeBool

+ const TypeByte

+ const TypeDouble

+ const TypeI08

+ const TypeI16

+ const TypeI32

+ const TypeI64

+ const TypeList

+ const TypeMap

+ const TypeSet

+ const TypeStop

+ const TypeString

+ const TypeStruct

+ const TypeUtf16

+ const TypeUtf7

+ const TypeUtf8

+ const TypeVoid

+ var BinaryProtocol = NewProtocolBuilder(func(r io.Reader) ProtocolReader { ... }, ...)

+ var CompactProtocol = NewProtocolBuilder(NewCompactProtocolReader, NewCompactProtocolWriter)

+ var ErrOnewayNotEnabled = errors.New("thrift.client: one way support not enabled on codec")

+ var ErrTooManyPendingRequests = errors.New("thrift.client: too many pending requests")

+ var ErrUnimplemented = errors.New("thrift: unimplemented")

+ var TypeNames = map[int]string

+ func Bool(v bool) *bool

+ func Byte(v byte) *byte

+ func CamelCase(s string) string

+ func DecodeStruct(r ProtocolReader, v interface{}) (err error)

+ func Dial(network, address string, framed bool, protocol ProtocolBuilder, ...) (*rpc.Client, error)

+ func EncodeStruct(w ProtocolWriter, v interface{}) (err error)

+ func Float32(v float32) *float32

+ func Float64(v float64) *float64

+ func Int16(v int16) *int16

+ func Int32(v int32) *int32

+ func Int64(v int64) *int64

+ func NewClient(conn Transport, supportOnewayRequests bool) *rpc.Client

+ func NewClientCodec(conn Transport, supportOnewayRequests bool) rpc.ClientCodec

+ func NewServerCodec(conn Transport) rpc.ServerCodec

+ func ReadValue(r ProtocolReader, thriftType byte) (interface{}, error)

+ func ServeConn(conn Transport)

+ func SkipValue(r ProtocolReader, thriftType byte) error

+ func String(v string) *string

+ type ApplicationException struct

+ Message string

+ Type int32

+ func (e *ApplicationException) String() string

+ type Decoder interface

+ DecodeThrift func(ProtocolReader) error

+ type Encoder interface

+ EncodeThrift func(ProtocolWriter) error

+ type ErrFrameTooBig struct

+ MaxSize int64

+ Size int64

+ func (e ErrFrameTooBig) Error() string

+ type Flusher interface

+ Flush func() error

+ type FramedReadWriteCloser struct

+ func NewFramedReadWriteCloser(wrapped io.ReadWriteCloser, maxFrameSize int) *FramedReadWriteCloser

+ func (f *FramedReadWriteCloser) Close() error

+ func (f *FramedReadWriteCloser) Flush() error

+ func (f *FramedReadWriteCloser) Read(p []byte) (int, error)

+ func (f *FramedReadWriteCloser) ReadByte() (byte, error)

+ func (f *FramedReadWriteCloser) Write(p []byte) (int, error)

+ type InvalidValueError struct

+ Str string

+ Value reflect.Value

+ func (e *InvalidValueError) Error() string

+ type MissingRequiredField struct

+ FieldName string

+ StructName string

+ func (e *MissingRequiredField) Error() string

+ type ProtocolBuilder interface

+ NewProtocolReader func(io.Reader) ProtocolReader

+ NewProtocolWriter func(io.Writer) ProtocolWriter

+ func NewProtocolBuilder(r func(io.Reader) ProtocolReader, w func(io.Writer) ProtocolWriter) ProtocolBuilder

+ type ProtocolError struct

+ Message string

+ Protocol string

+ func (e ProtocolError) Error() string

+ type ProtocolReadWriter interface

+ type ProtocolReader interface

+ ReadBool func() (bool, error)

+ ReadByte func() (byte, error)

+ ReadBytes func() ([]byte, error)

+ ReadDouble func() (float64, error)

+ ReadFieldBegin func() (fieldType byte, id int16, err error)

+ ReadFieldEnd func() error

+ ReadI16 func() (int16, error)

+ ReadI32 func() (int32, error)

+ ReadI64 func() (int64, error)

+ ReadListBegin func() (elementType byte, size int, err error)

+ ReadListEnd func() error

+ ReadMapBegin func() (keyType byte, valueType byte, size int, err error)

+ ReadMapEnd func() error

+ ReadMessageBegin func() (name string, messageType byte, seqid int32, err error)

+ ReadMessageEnd func() error

+ ReadSetBegin func() (elementType byte, size int, err error)

+ ReadSetEnd func() error

+ ReadString func() (string, error)

+ ReadStructBegin func() error

+ ReadStructEnd func() error

+ func NewBinaryProtocolReader(r io.Reader, strict bool) ProtocolReader

+ func NewCompactProtocolReader(r io.Reader) ProtocolReader

+ type ProtocolWriter interface

+ WriteBool func(value bool) error

+ WriteByte func(value byte) error

+ WriteBytes func(value []byte) error

+ WriteDouble func(value float64) error

+ WriteFieldBegin func(name string, fieldType byte, id int16) error

+ WriteFieldEnd func() error

+ WriteFieldStop func() error

+ WriteI16 func(value int16) error

+ WriteI32 func(value int32) error

+ WriteI64 func(value int64) error

+ WriteListBegin func(elementType byte, size int) error

+ WriteListEnd func() error

+ WriteMapBegin func(keyType byte, valueType byte, size int) error

+ WriteMapEnd func() error

+ WriteMessageBegin func(name string, messageType byte, seqid int32) error

+ WriteMessageEnd func() error

+ WriteSetBegin func(elementType byte, size int) error

+ WriteSetEnd func() error

+ WriteString func(value string) error

+ WriteStructBegin func(name string) error

+ WriteStructEnd func() error

+ func NewBinaryProtocolWriter(w io.Writer, strict bool) ProtocolWriter

+ func NewCompactProtocolWriter(w io.Writer) ProtocolWriter

+ func NewTextProtocolWriter(w io.Writer) ProtocolWriter

+ type Transport interface

+ func NewTransport(rwc io.ReadWriteCloser, p ProtocolBuilder) Transport

+ type UnsupportedTypeError struct

+ Type reflect.Type

+ func (e *UnsupportedTypeError) Error() string

+ type UnsupportedValueError struct

+ Str string

+ Value reflect.Value

+ func (e *UnsupportedValueError) Error() string