errors

Documentation

Index

• Variables
• type RpcError
  • 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
• type RpcPanicInfo
  • func (info RpcPanicInfo) String() string

Variables

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 !"}
)

Types

type RpcError

type RpcError struct {
	// contains filtered or unexported fields
}

func NewMethodExecError

func NewMethodExecError(service, method string) *RpcError

func NewProxyDisconnected

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

func NewProxyNotExit

func NewProxyNotExit(proxyid uint32) *RpcError

func NewProxyNotFound

func NewProxyNotFound(callid uint32) *RpcError

func NewRpcError

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

func NewServiceNotExist

func NewServiceNotExist(uuid uint64) *RpcError

func (*RpcError) Code

func (re *RpcError) Code() RpcErrorCode

func (*RpcError) Error

func (re *RpcError) Error() string

type RpcErrorCode

type RpcErrorCode uint32

const (
	RpcNoErr RpcErrorCode = iota
	CommErr
	TransportClosed
	ProxyNotExist
	ProxyDisconnected
	ProxyTimeout
	ProxyCallNoFound
	StubCallInvalid
	ServiceShutdown
	ServiceNotExist
	ServiceHasExist
	MethodException
	ServicePanic
	SERVICE_NOT_FOUND
	FUNCTION_NOT_FOUND
)

type RpcPanicInfo

type RpcPanicInfo struct {
	Info interface{}
	Pkg  []byte
}

func (RpcPanicInfo) String

func (info RpcPanicInfo) String() string