opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-10-29 17:58:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

guest sync config tasks, add monitor command

Browse Source
This commit is contained in:
wanyaoqi
2019-01-07 17:09:57 +08:00
parent 7fd6c0eec2
commit 86f13d3d77
12 changed files with 598 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/hostman/hostutils/hostutils.go
+21 -2
View File
@@ -2,6 +2,7 @@ package hostutils
import (
"context"
"fmt"
"net/http"
"yunion.io/x/jsonutils"
@@ -37,6 +38,24 @@ func TaskComplete(ctx context.Context, params jsonutils.JSONObject) {
}
}
func GetWireOfIp(ctx context.Context, params jsonutils.JSONObject) (jsonutils.JSONObject, error) {
res, err := modules.Networks.List(GetComputeSession(ctx), params)
if err != nil {
return nil, err
}
if len(res.Data) == 1 {
wireId, _ := res.Data[0].GetString("wire_id")
return GetWireInfo(ctx, wireId)
} else {
return nil, fmt.Errorf("Fail to get network info: no networks")
}
}
func GetWireInfo(ctx context.Context, wireId string) (jsonutils.JSONObject, error) {
return modules.Wires.Get(GetComputeSession(ctx), wireId, nil)
}
func UpdateServerStatus(ctx context.Context, sid, status string) (jsonutils.JSONObject, error) {
var body = jsonutils.NewDict()
var stats = jsonutils.NewDict()
@@ -75,8 +94,8 @@ func DelayTask(ctx context.Context, task workmanager.DelayTaskFunc, params inter
wm.DelayTask(ctx, task, params)
}
func DelayTaskWithoutTask(ctx context.Context, task workmanager.DelayTaskFunc, params interface{}) {
wm.DelayTaskWithoutTask(ctx, task, params)
func DelayTaskWithoutReqctx(ctx context.Context, task workmanager.DelayTaskFunc, params interface{}) {
wm.DelayTaskWithoutReqctx(ctx, task, params)
}
func init() {