errors

Oct 10, 2023

Changes in this version

+ var ErrRpcCallFinished = gerror.New("rpc call has been finished")

Aug 8, 2023

Changes in this version

+ var ErrMsgNotRegistered = &RpcError

Jan 13, 2023

Changes in this version

+ var ErrInvalidPublisher = gerror.New("invalid publisher")

+ var ErrInvalidSubCtx = gerror.New("invalid subscribe params")

+ var ErrRepeatedSub = gerror.New("repeated subscribe for service ")

+ var ErrServiceNotFound = gerror.New("service not founded")

May 9, 2023

Changes in this version

+ var ErrRpcRet = gerror.New("rpc method execute return error")

+ type RpcPanicInfo struct

+ Info interface{}

+ Pkg []byte

+ func (info RpcPanicInfo) String() string

Dec 21, 2022

Changes in this version

+ var ErrServiceInit = gerror.New("initialize service error")

Jun 30, 2022

Changes in this version

+ var ErrIllegalProto = &RpcError

+ var ErrIllegalReq = &RpcError

+ var ErrInvalidProto = gerror.New("invalid rpc protocol")

+ var ErrProxyInvalid = &RpcError

+ var ErrRpcClosed = gerror.New("rpc has been closed")

+ var ErrRpcException = gerror.New("rpc method execute throw exception")

+ var ErrRpcNotFound = gerror.New("rpc service or method not found")

+ var ErrRpcNotInit = gerror.New("rpc framework not init")

+ var ErrRpcTimeOut = gerror.New("rpc proxy call time out")

+ var ErrServicePanic = &RpcError

+ var ErrStubCallInvalid = &RpcError

+ var ErrTransClose = &RpcError

type RpcErrorCode

+ const CommErr

+ const MethodException

+ const ProxyCallNoFound

+ const ProxyDisconnected

+ const ProxyNotExist

+ const ProxyTimeout

+ const RpcNoErr

+ const ServiceHasExist

+ const ServiceNotExist

+ const ServiceShutdown

+ const StubcallInvalid

+ const TransportClosed

Feb 11, 2022

Changes in this version

+ var ProtocolError = &RpcError

+ var ProxyInvalid = &RpcError

+ var RequestInvalid = &RpcError

+ var ServicePanic = &RpcError

+ var StubCallInvalid = &RpcError

+ var TransportClose = &RpcError

+ type RpcError struct

+ func NewMethodExecError(service, method string) *RpcError

+ func NewProxyDisconnected(uuid uint64, id uint32, name string) *RpcError

+ func NewProxyNotExit(proxyid uint32) *RpcError

+ func NewProxyNotFound(callid uint32) *RpcError

+ func NewRpcError(code RpcErrorCode, format string, args ...interface{}) *RpcError

+ func NewServiceNotExist(uuid uint64) *RpcError

+ func (re *RpcError) Code() RpcErrorCode

+ func (re *RpcError) Error() string

+ type RpcErrorCode uint32

+ const COMM_ERR

+ const FUNCTION_NOT_FOUND

+ const METHOD_EXECERROR

+ const PROXY_CALL_NO_FOUND

+ const PROXY_DISCONNECTED

+ const PROXY_NOT_EXIST

+ const PROXY_TIMEOUT

+ const SERIVCE_HAS_EXIST

+ const SERVICE_NOT_EXIST

+ const SERVICE_NOT_FOUND

+ const SERVICE_PANIC

+ const SERVICE_SHUTDOWN

+ const STUBCALL_INVALID

+ const TRANSPORT_CLOSED