From d1671bbe77c3301c8fc645202acd368e9af336fb Mon Sep 17 00:00:00 2001 From: zeaslity Date: Thu, 18 Jan 2024 15:32:50 +0800 Subject: [PATCH] [Agent] [Status] add host info to agent status --- agent-go/status/Host_test.go | 13 ++----------- agent-go/status/Status.go | 17 ++++++++++++++++- 2 files changed, 18 insertions(+), 12 deletions(-) diff --git a/agent-go/status/Host_test.go b/agent-go/status/Host_test.go index fabde1d..8d2886a 100644 --- a/agent-go/status/Host_test.go +++ b/agent-go/status/Host_test.go @@ -1,25 +1,16 @@ package status import ( - "fmt" + "agent-go/utils" "testing" ) func TestGetHostInfo(t *testing.T) { - hostInfo := HostInfo{} - - fmt.Printf("host info is %v\n", hostInfo) - fmt.Printf("host info type is %T\n", hostInfo) - fmt.Printf("host info address is %p\n", &hostInfo) - - fmt.Println() - info, err := GetHostInfo() if err != nil { t.Errorf("get host info error is %v", err) } - fmt.Printf("get host info is %v\n", info) - fmt.Printf("get host info address is %p\n", &info) + utils.BeautifulPrint(info) } diff --git a/agent-go/status/Status.go b/agent-go/status/Status.go index 17effd7..9849e10 100644 --- a/agent-go/status/Status.go +++ b/agent-go/status/Status.go @@ -27,6 +27,7 @@ type AgentMetric struct { MemoryMetric *MemoryMetric NetworkMetric []NetworkMetric DiskInfo []DiskInfo + HostInfo *HostInfo DockerMetric *DockerMetric } @@ -36,7 +37,7 @@ func Ping() string { func ReportAgentMetric() *AgentMetric { - lenOfAgentMetric := 5 + lenOfAgentMetric := 6 waitResultChan := make(chan string, lenOfAgentMetric) timeout := time.After(5 * time.Second) var err error @@ -80,6 +81,19 @@ func ReportAgentMetric() *AgentMetric { log.ErrorF("[ReportAgentMetric] - GetDiskInfo exec error => %v", err) } + var hostInfo *HostInfo + err = pool.Submit(func() { + hostInfo, err = GetHostInfo() + if err != nil { + log.ErrorF("获取Agent的状态出现错误! 请检查 => %v", err) + waitResultChan <- "GetHostInfo error !" + } + waitResultChan <- "hostInfo success !" + }) + if err != nil { + log.ErrorF("[ReportAgentMetric] - hostInfo exec error => %v", err) + } + var networkMetric []NetworkMetric err = pool.Submit(func() { networkMetric, err = GetNetworkMetric() @@ -120,6 +134,7 @@ func ReportAgentMetric() *AgentMetric { MemoryMetric: memoryMetric, NetworkMetric: networkMetric, DiskInfo: diskInfoList, + HostInfo: hostInfo, DockerMetric: dockerMetric, }