Versions in this module Expand all Collapse all v0 v0.0.2 Dec 12, 2019 Changes in this version + const ARRAY_BOOL + const ARRAY_DESC + const ARRAY_DOUBLE + const ARRAY_FLOAT + const ARRAY_INT + const ARRAY_LONG + const ARRAY_STRING + const ASCII_GAP + const BC_BINARY + const BC_BINARY_CHUNK + const BC_BINARY_DIRECT + const BC_BINARY_SHORT + const BC_DATE + const BC_DATE_MINUTE + const BC_DOUBLE + const BC_DOUBLE_BYTE + const BC_DOUBLE_MILL + const BC_DOUBLE_ONE + const BC_DOUBLE_SHORT + const BC_DOUBLE_ZERO + const BC_END + const BC_FALSE + const BC_INT + const BC_INT_BYTE_ZERO + const BC_INT_SHORT_ZERO + const BC_INT_ZERO + const BC_LIST_DIRECT + const BC_LIST_DIRECT_UNTYPED + const BC_LIST_FIXED + const BC_LIST_FIXED_UNTYPED + const BC_LIST_VARIABLE + const BC_LIST_VARIABLE_UNTYPED + const BC_LONG + const BC_LONG_BYTE_ZERO + const BC_LONG_INT + const BC_LONG_SHORT_ZERO + const BC_LONG_ZERO + const BC_MAP + const BC_MAP_UNTYPED + const BC_NULL + const BC_OBJECT + const BC_OBJECT_DEF + const BC_OBJECT_DIRECT + const BC_REF + const BC_STRING + const BC_STRING_CHUNK + const BC_STRING_DIRECT + const BC_STRING_SHORT + const BC_TRUE + const BINARY_DIRECT_MAX + const BINARY_SHORT_MAX + const CHUNK_SIZE + const CLASS_DESC + const DEFAULT_DUBBO_PROTOCOL_VERSION + const DEFAULT_LEN + const DESC_REGEX + const DUBBO_VERSION + const DUBBO_VERSION_KEY + const FLAG_EVENT + const FLAG_REQUEST + const FLAG_TWOWAY + const GROUP_KEY + const HEADER_LENGTH + const INTERFACE_KEY + const INT_BYTE_MAX + const INT_BYTE_MIN + const INT_DIRECT_MAX + const INT_DIRECT_MIN + const INT_SHORT_MAX + const INT_SHORT_MIN + const JAVA_IDENT_REGEX + const LIST_DIRECT_MAX + const LONG_BYTE_MAX + const LONG_BYTE_MIN + const LONG_DIRECT_MAX + const LONG_DIRECT_MIN + const LONG_SHORT_MAX + const LONG_SHORT_MIN + const LOWEST_VERSION_FOR_RESPONSE_ATTACHMENT + const MAGIC + const MAGIC_HIGH + const MAGIC_LOW + const OBJECT_DIRECT_MAX + const PACKET_DIRECT_MAX + const PACKET_SHORT_MAX + const PATH_KEY + const P_PACKET + const P_PACKET_CHUNK + const P_PACKET_DIRECT + const P_PACKET_SHORT + const PackageError + const PackageHeartbeat + const PackageRequest + const PackageRequest_TwoWay + const PackageResponse + const PackageResponse_Exception + const PackageType_BitSize + const RESPONSE_NULL_VALUE + const RESPONSE_NULL_VALUE_WITH_ATTACHMENTS + const RESPONSE_VALUE + const RESPONSE_VALUE_WITH_ATTACHMENTS + const RESPONSE_WITH_EXCEPTION + const RESPONSE_WITH_EXCEPTION_WITH_ATTACHMENTS + const Response_BAD_REQUEST + const Response_BAD_RESPONSE + const Response_CLIENT_ERROR + const Response_CLIENT_TIMEOUT + const Response_OK + const Response_SERVER_ERROR + const Response_SERVER_TIMEOUT + const Response_SERVICE_ERROR + const Response_SERVICE_NOT_FOUND + const SERIAL_MASK + const STRING_DIRECT_MAX + const STRING_FALSE + const STRING_NIL + const STRING_ONE + const STRING_SHORT_MAX + const STRING_TRUE + const STRING_ZERO + const TAG_READ + const TIMEOUT_KEY + const VERSION_KEY + const Zero + var DescRegex = regexp.Compile(DESC_REGEX) + var DubboRequestHeaderBytes = [HEADER_LENGTH]byte + var DubboRequestHeaderBytesTwoWay = [HEADER_LENGTH]byte + var DubboRequestHeartbeatHeader = [HEADER_LENGTH]byte + var DubboResponseHeaderBytes = [HEADER_LENGTH]byte + var DubboResponseHeartbeatHeader = [HEADER_LENGTH]byte + var ErrBodyNotEnough = perrors.New("body buffer too short") + var ErrHeaderNotEnough = perrors.New("header buffer too short") + var ErrIllegalPackage = perrors.New("illegal package!") + var ErrIllegalRefIndex = perrors.Errorf("illegal ref index") + var ErrJavaException = perrors.New("got java exception") + var ErrNotEnoughBuf = perrors.Errorf("not enough buf") + var NilValue = reflect.Zero(reflect.TypeOf((*interface{})(nil)).Elem()) + var ZeroDate = time.Time + func AddrEqual(x, y interface{}) bool + func ConvertSliceValueType(destTyp reflect.Type, v reflect.Value) (reflect.Value, error) + func CopyMap(inMapValue, outMapValue reflect.Value) error + func CopySlice(inSlice, outSlice reflect.Value) error + func EnsureFloat64(i interface{}) float64 + func EnsureInt64(i interface{}) int64 + func EnsureInterface(in interface{}, err error) (interface{}, error) + func EnsurePackValue(in interface{}) reflect.Value + func EnsureRawValue(in interface{}) reflect.Value + func EnsureUint64(i interface{}) uint64 + func PackFloat64(v float64) []byte + func PackInt16(v int16) []byte + func PackInt32(v int32) []byte + func PackInt64(v int64) []byte + func PackInt8(v int8, b []byte) []byte + func PackPtr(v reflect.Value) reflect.Value + func PackUint16(v uint16) []byte + func ReflectResponse(in interface{}, out interface{}) error + func RegisterJavaEnum(o POJOEnum) int + func RegisterPOJO(o POJO) int + func RegisterPOJOs(os ...POJO) []int + func SetSerializer(key string, codec Serializer) + func SetSlice(dest reflect.Value, objects interface{}) error + func SetTagIdentifier(s string) + func SetValue(dest, v reflect.Value) + func Slice(s string) (b []byte) + func SprintHex(b []byte) (rs string) + func ToMapStringString(origin map[interface{}]interface{}) map[string]string + func UnpackFloat64(b []byte) float64 + func UnpackInt16(b []byte) int16 + func UnpackInt32(b []byte) int32 + func UnpackInt64(b []byte) int64 + func UnpackPtr(v reflect.Value) reflect.Value + func UnpackPtrType(typ reflect.Type) reflect.Type + func UnpackPtrValue(v reflect.Value) reflect.Value + func UnpackUint16(b []byte) uint16 + type DecimalSerializer struct + func (DecimalSerializer) DecObject(d *Decoder) (interface{}, error) + func (DecimalSerializer) EncObject(e *Encoder, v POJO) error + type Decoder struct + func NewDecoder(b []byte) *Decoder + func NewDecoderWithSkip(b []byte) *Decoder + func (d *Decoder) Decode() (interface{}, error) + func (d *Decoder) DecodeValue() (interface{}, error) + type DubboHeader struct + BodyLen int + ID int64 + ResponseStatus byte + SerialID byte + Type PackageType + type Encoder struct + func NewEncoder() *Encoder + func (e *Encoder) Append(buf []byte) + func (e *Encoder) Buffer() []byte + func (e *Encoder) Encode(v interface{}) error + type HessianCodec struct + func NewHessianCodec(reader *bufio.Reader) *HessianCodec + func NewHessianCodecCustom(pkgType PackageType, reader *bufio.Reader, bodyLen int) *HessianCodec + func (h *HessianCodec) ReadAttachments() (map[string]string, error) + func (h *HessianCodec) ReadBody(rspObj interface{}) error + func (h *HessianCodec) ReadHeader(header *DubboHeader) error + func (h *HessianCodec) Write(service Service, header DubboHeader, body interface{}) ([]byte, error) + type JavaEnum int32 + const InvalidJavaEnum + type JavaEnumClass struct + type Object interface + type POJO interface + JavaClassName func() string + type POJOEnum interface + EnumValue func(string) JavaEnum + String func() string + type POJORegistry struct + type PackageType int + type Request struct + Attachments map[string]string + Params interface{} + func EnsureRequest(body interface{}) *Request + func NewRequest(params interface{}, atta map[string]string) *Request + type Response struct + Attachments map[string]string + Exception error + RspObj interface{} + func EnsureResponse(body interface{}) *Response + func NewResponse(rspObj interface{}, exception error, attachments map[string]string) *Response + type Serializer interface + DecObject func(*Decoder) (interface{}, error) + EncObject func(*Encoder, POJO) error + func GetSerializer(key string) (Serializer, bool) + type Service struct + Group string + Interface string + Method string + Path string + Timeout time.Duration + Version string + type TypeRefs struct + func (t *TypeRefs) Get(index int) reflect.Type
Go to main page