Versions in this module Expand all Collapse all v1 v1.0.0 Nov 23, 2022 Changes in this version + func AccpterRun(adapter MessageAdapterItf, rpcSvr RICSvrItf) + func Int64ArrToIntArr(arr []int64) []int + func IntArrToInt64Arr(arr []int) []int64 + func NewRPCServiceManager(conn net.Conn) *muti_service.ServiceManager + func ServiceManagerRegister(mgr *muti_service.ServiceManager, no int64, desc string, rpcSvr RICSvrItf) (isExist bool) + func UInt64ArrToUIntArr(arr []uint64) []uint + func UIntArrToUInt64Arr(arr []uint) []uint64 + func WriteCall(conn net.Conn, dict int32, message proto.Message) (int, error) + func WriteRet(conn net.Conn, dict int32, message proto.Message, err error) (int, error) + type ConnFunc func(conn net.Conn) + type MessageAdapter struct + func (ma *MessageAdapter) Close() error + func (ma *MessageAdapter) GetConn() net.Conn + func (ma *MessageAdapter) ReadCall() (*smn_base.Call, error) + func (ma *MessageAdapter) ReadRet() (*smn_base.Ret, error) + func (ma *MessageAdapter) WriteCall(dict int32, message proto.Message) (int, error) + func (ma *MessageAdapter) WriteRet(dict int32, message proto.Message, err error) (int, error) + type MessageAdapterItf interface + Close func() error + GetConn func() net.Conn + ReadCall func() (*smn_base.Call, error) + ReadRet func() (*smn_base.Ret, error) + WriteCall func(dict int32, message proto.Message) (int, error) + WriteRet func(dict int32, message proto.Message, err error) (int, error) + func NewMessageAdapter(conn net.Conn) MessageAdapterItf + type RICSvrItf interface + OnMessage func(c *smn_base.Call, conn net.Conn) (_d int32, _p proto.Message, _e error) + type StructCall struct + Callback func(*smn_base.Ret) + Dict int32 + Msg proto.Message + type StructResult struct + Callback func(*smn_base.Ret) + Ret *smn_base.Ret