Versions in this module Expand all Collapse all v0 v0.1.0 Apr 2, 2019 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
Go to main page