diff --git a/cluster/cluster.go b/cluster/cluster.go index 5a03777..eaf921b 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -499,3 +499,18 @@ func GetNodeName(nodeid int) string { // return _self.cfg.GetNodeNameByNodeId(nodeid) } + +func DynamicCall(address string, serviceMethod string, args interface{}, reply interface{}) error { + //conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8095") + rpcClient, err := rpc.Dial("tcp", address) + if err != nil { + return err + } + defer rpcClient.Close() + err = rpcClient.Call(serviceMethod, args, reply) + if err != nil { + return err + } + + return nil +}