udwRpc2

package

v0.0.0-...-f254aa5 Latest Latest Go to latest Published: Jan 15, 2020 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func PanicToErrMsg(f func()) (errMsg string)

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

func NewClientHub(req ClientReq) *ClientHub

func (ch *ClientHub) RequestCb(cb func(ctx *ReqCtx)) (errMsg string)

type ClientReq struct {
	Addr           string
	MaxOpenConnNum int
	MaxIdleTime    time.Duration
}

type ClientStat struct {
	GetConnNum    int
	NewConnNum    int
	InFreeConnNum int

	IsClose       bool
	CachedStmtNum int
}

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

func (conn *Conn) Close()

type PeerIp struct {
	Ip string
}

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

func (ctx *ReqCtx) Close()

func (ctx *ReqCtx) GetPeerIp() string

func (ctx *ReqCtx) GetReader() *udwShm.ShmReader

func (ctx *ReqCtx) GetWriter() *udwShm.ShmWriter

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

func NewNetworkError(errMsg string) *RpcError

func NewOtherError(errMsg string) *RpcError

func (err *RpcError) Error() string

func (err *RpcError) IsNetworkError() bool

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

func NewServerHub(req ServerReq) *ServerHub

func (sh *ServerHub) Close()

type ServerReq struct {
	Addr        string
	MaxIdleTime time.Duration
	Handler     func(ctx *ReqCtx)
}