1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
| package service
|
| import (
| "basic.com/valib/bhomeclient.git"
| "encoding/json"
| "errors"
| "vamicro/devicemanage-service/vo"
| )
|
| func remoteCall(arg interface{}, rTopic string, targetDevId string, ip string) (*bhomeclient.Reply, error) {
| body, err := json.Marshal(arg)
| if err != nil {
| return nil, err
| }
| r, err := WrapQueryRpc(rTopic, body, targetDevId, ip)
| if err != nil {
| return nil, err
| }
| if len(r) != 1 {
| return nil, errors.New("no response")
| }
| var ret bhomeclient.Reply
| err = json.Unmarshal(r[0].Payload, &ret)
| if err != nil {
| return nil, err
| }
| return &ret, nil
| }
|
| //控制其它节点创建集群
| func RemoteCreateCluster(arg vo.CreateClusterArg) (*bhomeclient.Reply, error){
| return remoteCall(arg, "RemoteCreateCluster", "", arg.Ip)
| }
|
| func RemoteSearchCluster(arg vo.SearchClusterArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteSearchCluster", arg.DevId, arg.Ip)
| }
|
| func RemoteGetSearchNodes(arg vo.GetSearchNodesArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteGetSearchNodes", arg.DevId, arg.Ip)
| }
|
| func RemoteJoinCluster(arg vo.JoinClusterArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteJoinCluster", arg.DevId, arg.Ip)
| }
|
| func RemoteReboot(arg vo.RebootArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteReboot", arg.DevId, arg.Ip)
| }
|
| func RemoteUninstall(arg vo.UninstallArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteUninstall", "", "")
| }
|
| func RemoteUpgrade(arg vo.UpgradeArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteUpgrade", "", "")
| }
|
| func RemoteSysUpdate(arg vo.SysUpdateArg) (*bhomeclient.Reply, error) {
| return remoteCall(arg, "RemoteSysUpdate", "", "")
| }
|
|
