Documentation ¶
Index ¶
- 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
- type MessageAdapter
- 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
- type RICSvrItf
- type StructCall
- type StructResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AccpterRun ¶
func AccpterRun(adapter MessageAdapterItf, rpcSvr RICSvrItf)
func Int64ArrToIntArr ¶
func IntArrToInt64Arr ¶
func NewRPCServiceManager ¶
func NewRPCServiceManager(conn net.Conn) *muti_service.ServiceManager
func ServiceManagerRegister ¶
func ServiceManagerRegister(mgr *muti_service.ServiceManager, no int64, desc string, rpcSvr RICSvrItf) (isExist bool)
func UInt64ArrToUIntArr ¶
func UIntArrToUInt64Arr ¶
Types ¶
type MessageAdapter ¶
type MessageAdapter struct {
// contains filtered or unexported fields
}
func (*MessageAdapter) Close ¶
func (ma *MessageAdapter) Close() error
func (*MessageAdapter) GetConn ¶
func (ma *MessageAdapter) GetConn() net.Conn
type MessageAdapterItf ¶
type MessageAdapterItf interface { WriteCall(dict int32, message proto.Message) (int, error) WriteRet(dict int32, message proto.Message, err error) (int, error) ReadCall() (*smn_base.Call, error) ReadRet() (*smn_base.Ret, error) GetConn() net.Conn Close() error }
func NewMessageAdapter ¶
func NewMessageAdapter(conn net.Conn) MessageAdapterItf
type RICSvrItf ¶
type RICSvrItf interface { // OnMessage @ret d -> dict, _p proto.Message, _e error. OnMessage(c *smn_base.Call, conn net.Conn) (_d int32, _p proto.Message, _e error) }
RICSvrItf rpc server interface.
type StructCall ¶
StructCall MessageAdapterItf's Param .
Click to show internal directories.
Click to hide internal directories.