TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2026-02-21 05:05:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

显示SSH认证相关集群、节点

Browse Source
This commit is contained in:
刘祥超
2020-10-25 21:27:38 +08:00
parent 627a06e7bc
commit 4fd05d0a91
3 changed files with 7 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
internal/nodes/node_status_executor.go
View File

@@ -2,6 +2,7 @@ package nodes
import (
"encoding/json"
"github.com/TeaOSLab/EdgeCommon/pkg/nodeconfigs"
"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
teaconst "github.com/TeaOSLab/EdgeNode/internal/const"
"github.com/TeaOSLab/EdgeNode/internal/logs"
@@ -45,7 +46,7 @@ func (this *NodeStatusExecutor) update() {
return
}
status := &NodeStatus{}
status := &nodeconfigs.NodeStatus{}
status.BuildVersion = teaconst.Version
status.ConfigVersion = sharedNodeConfig.Version
status.IsActive = true
@@ -80,7 +81,7 @@ func (this *NodeStatusExecutor) update() {
}
// 更新CPU
func (this *NodeStatusExecutor) updateCPU(status *NodeStatus) {
func (this *NodeStatusExecutor) updateCPU(status *nodeconfigs.NodeStatus) {
duration := time.Duration(0)
if this.isFirstTime {
duration = 100 * time.Millisecond
@@ -117,7 +118,7 @@ func (this *NodeStatusExecutor) updateCPU(status *NodeStatus) {
}
// 更新硬盘
func (this *NodeStatusExecutor) updateDisk(status *NodeStatus) {
func (this *NodeStatusExecutor) updateDisk(status *nodeconfigs.NodeStatus) {
partitions, err := disk.Partitions(false)
if err != nil {
logs.Error("NODE_STATUS", err.Error())