errors

var (
	ErrRpcNotFound      = gerror.New("rpc service or method not found")
	ErrRpcTimeOut       = gerror.New("rpc proxy call time out")
	ErrRpcRet           = gerror.New("rpc method execute return error")
	ErrRpcNotInit       = gerror.New("rpc framework not init")
	ErrRpcCallFinished  = gerror.New("rpc call has been finished")
	ErrRpcClosed        = gerror.New("rpc has been closed")
	ErrInvalidProto     = gerror.New("invalid rpc protocol")
	ErrServiceInit      = gerror.New("initialize service error")
	ErrInvalidSubCtx    = gerror.New("invalid subscribe params")
	ErrRepeatedSub      = gerror.New("repeated subscribe for service ")
	ErrServiceNotFound  = gerror.New("service not founded")
	ErrInvalidPublisher = gerror.New("invalid publisher")
)

var (
	ErrTransClose       = &RpcError{TransportClosed, "Transport has been closed"}
	ErrProxyInvalid     = &RpcError{ProxyNotExist, "Proxy Is Invalid"}
	ErrStubCallInvalid  = &RpcError{StubCallInvalid, "stub's call invalid"}
	ErrServicePanic     = &RpcError{ServicePanic, "service exec panic"}
	ErrIllegalReq       = &RpcError{errCode: CommErr, errStr: "invalid request message!"}
	ErrIllegalProto     = &RpcError{errCode: CommErr, errStr: "rpc protocol message buffer error !"}
	ErrMsgNotRegistered = &RpcError{errCode: CommErr, errStr: "rpc message not registered !"}
)