Versions in this module Expand all Collapse all v1 v1.2.1 Mar 15, 2020 Changes in this version + var ErrNil = errors.New("mqrpc: nil returned") + func Bool(reply interface{}, err interface{}) (bool, error) + func Bytes(reply interface{}, err interface{}) ([]byte, error) + func Float64(reply interface{}, err interface{}) (float64, error) + func Int(reply interface{}, err interface{}) (int, error) + func Int64(reply interface{}, err interface{}) (int64, error) + func InterfaceMap(reply interface{}, err interface{}) (map[string]interface{}, error) + func Marshal(mrsp interface{}, ff func() (reply interface{}, err interface{})) error + func Proto(mrsp interface{}, ff func() (reply interface{}, err interface{})) error + func String(reply interface{}, err interface{}) (string, error) + func StringMap(reply interface{}, err interface{}) (map[string]string, error) + type CallInfo struct + Agent MQServer + ExecTime int64 + Props map[string]interface{} + Result rpcpb.ResultInfo + RpcInfo rpcpb.RPCInfo + type FunctionInfo struct + Function reflect.Value + Goroutine bool + type GoroutineControl interface + Finish func() + Wait func() error + type LocalClient interface + Call func(callInfo CallInfo, callback chan rpcpb.ResultInfo) (err error) + CallNR func(callInfo CallInfo) (err error) + Done func() error + type LocalServer interface + Callback func(callinfo CallInfo) error + IsClose func() bool + Shutdown func() (err error) + StopConsume func() error + Write func(callInfo CallInfo) error + type MQServer interface + Callback func(callinfo CallInfo) error + type Marshaler interface + Marshal func() ([]byte, error) + String func() string + Unmarshal func([]byte) error + type ParamOption func() []interface + func Param(params ...interface{}) ParamOption + type RPCClient interface + Call func(ctx context.Context, _func string, params ...interface{}) (interface{}, string) + CallArgs func(ctx context.Context, _func string, ArgsType []string, args [][]byte) (interface{}, string) + CallNR func(_func string, params ...interface{}) (err error) + CallNRArgs func(_func string, ArgsType []string, args [][]byte) (err error) + Done func() (err error) + type RPCListener interface + BeforeHandle func(fn string, callInfo *CallInfo) error + NoFoundFunction func(fn string) (*FunctionInfo, error) + OnComplete func(fn string, callInfo *CallInfo, result *rpcpb.ResultInfo, exec_time int64) + OnError func(fn string, callInfo *CallInfo, err error) + OnTimeOut func(fn string, Expired int64) + type RPCServer interface + Addr func() string + Done func() (err error) + GetExecuting func() int64 + Register func(id string, f interface{}) + RegisterGO func(id string, f interface{}) + SetGoroutineControl func(control GoroutineControl) + SetListener func(listener RPCListener)
Go to main page