Versions in this module Expand all Collapse all v3 v3.1.2 Feb 5, 2024 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 ErrJavaException = perrors.New("got java exception") + var NilError = perrors.Errorf("object should not be nil") + var NilValue = reflect.Zero(reflect.TypeOf((*interface{})(nil)).Elem()) + var UnexpectedTypeError = perrors.Errorf("object should be a POJO") + func CopyMap(inMapValue, outMapValue reflect.Value) error + func CopySlice(inSlice, outSlice reflect.Value) error + func GetClassDesc(v interface{}) string + func GetJavaName(obj interface{}) (string, error) + func ReflectResponse(in interface{}, out interface{}) error + func ToMapStringInterface(origin map[interface{}]interface{}) map[string]interface + type DubboHeader struct + BodyLen int + ID int64 + ResponseStatus byte + SerialID byte + Type PackageType + type DubboRequest struct + Attachments map[string]interface{} + Params interface{} + func EnsureRequest(body interface{}) *DubboRequest + func NewRequest(params interface{}, atta map[string]interface{}) *DubboRequest + type DubboResponse struct + Attachments map[string]interface{} + Exception error + RspObj interface{} + func EnsureResponse(body interface{}) *DubboResponse + func NewResponse(rspObj interface{}, exception error, attachments map[string]interface{}) *DubboResponse + 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]interface{}, 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 PackageType int + type Service struct + Group string + Interface string + Method string + Path string + Timeout time.Duration + Version string
Go to main page