Versions in this module Expand all Collapse all v1 v1.6.7 Feb 27, 2018 Changes in this version + type CallInfo struct + Agent MQServer + Props map[string]interface{} + Result rpcpb.ResultInfo + RpcInfo rpcpb.RPCInfo + type FunctionInfo struct + Function interface{} + 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 RPCClient interface + Call func(_func string, params ...interface{}) (interface{}, string) + CallArgs func(_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) + NewLocalClient func(server RPCServer) (err error) + NewRabbitmqClient func(info *conf.Rabbitmq) (err error) + NewRedisClient func(info *conf.Redis) (err error) + type RPCListener interface + BeforeHandle func(fn string, session gate.Session, callInfo *CallInfo) 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 + Done func() (err error) + GetExecuting func() int64 + GetLocalServer func() LocalServer + NewRabbitmqRPCServer func(info *conf.Rabbitmq) (err error) + NewRedisRPCServer func(info *conf.Redis) (err error) + Register func(id string, f interface{}) + RegisterGO func(id string, f interface{}) + SetGoroutineControl func(control GoroutineControl) + SetListener func(listener RPCListener)