smn_rpc

package
v0.0.0-...-baa1c12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 23, 2022 License: MIT Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AccpterRun

func AccpterRun(adapter MessageAdapterItf, rpcSvr RICSvrItf)

func Int64ArrToIntArr

func Int64ArrToIntArr(arr []int64) []int

func IntArrToInt64Arr

func IntArrToInt64Arr(arr []int) []int64

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 UInt64ArrToUIntArr(arr []uint64) []uint

func UIntArrToUInt64Arr

func UIntArrToUInt64Arr(arr []uint) []uint64

func WriteCall

func WriteCall(conn net.Conn, dict int32, message proto.Message) (int, error)

func WriteRet

func WriteRet(conn net.Conn, dict int32, message proto.Message, err error) (int, error)

Types

type ConnFunc

type ConnFunc func(conn net.Conn)

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

func (*MessageAdapter) ReadCall

func (ma *MessageAdapter) ReadCall() (*smn_base.Call, error)

func (*MessageAdapter) ReadRet

func (ma *MessageAdapter) ReadRet() (*smn_base.Ret, error)

func (*MessageAdapter) WriteCall

func (ma *MessageAdapter) WriteCall(dict int32, message proto.Message) (int, error)

func (*MessageAdapter) WriteRet

func (ma *MessageAdapter) WriteRet(dict int32, message proto.Message, err error) (int, error)

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

type StructCall struct {
	Dict     int32
	Msg      proto.Message
	Callback func(*smn_base.Ret)
}

StructCall MessageAdapterItf's Param .

type StructResult

type StructResult struct {
	Callback func(*smn_base.Ret)
	Ret      *smn_base.Ret
}

StructResult result .

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL