From 85199758170621d0512927f32d7d4e6bcf0bcddd Mon Sep 17 00:00:00 2001
From: Wangjunqi123 <wangjunqi@kylinos.cn>
Date: Tue, 25 Jun 2024 10:30:36 +0800
Subject: [PATCH] server/service: query log time axis data

---
 server/service/cluster/LogStream.go   |  1 +
 server/service/cluster/LogTimeAixs.go | 27 +++++++++++++++++++++++++++
 server/service/cluster/meta.go        |  2 ++
 server/service/machine/LogStream.go   |  1 +
 server/service/machine/LogTimeAixs.go |  2 ++
 5 files changed, 33 insertions(+)
 create mode 100644 server/service/cluster/LogStream.go
 create mode 100644 server/service/cluster/LogTimeAixs.go
 create mode 100644 server/service/cluster/meta.go
 create mode 100644 server/service/machine/LogStream.go
 create mode 100644 server/service/machine/LogTimeAixs.go

diff --git a/server/service/cluster/LogStream.go b/server/service/cluster/LogStream.go
new file mode 100644
index 0000000..494b718
--- /dev/null
+++ b/server/service/cluster/LogStream.go
@@ -0,0 +1 @@
+package cluster
\ No newline at end of file
diff --git a/server/service/cluster/LogTimeAixs.go b/server/service/cluster/LogTimeAixs.go
new file mode 100644
index 0000000..2b400ae
--- /dev/null
+++ b/server/service/cluster/LogTimeAixs.go
@@ -0,0 +1,27 @@
+package cluster
+
+import (
+	"github.com/tidwall/gjson"
+)
+
+func ProcessLogTimeAixsData(raw_results_bytes []byte) ([]map[string]interface{}, error) {
+	log_type_datas := []map[string]interface{}{}
+
+	hostname_agg_raw_arr := gjson.GetBytes(raw_results_bytes, "aggregations.1.buckets").Array()
+	for _, log_type_data_raw := range hostname_agg_raw_arr {
+		log_type_data := map[string]interface{}{}
+		log_timestamp_datas := [][]interface{}{}
+
+		log_type_data["name"] = log_type_data_raw.Get("key").String()
+		for _, log_timestamp_data_raw := range log_type_data_raw.Get("1-1.buckets").Array() {
+			log_timestamp_data := []interface{}{}
+			log_timestamp_data = append(log_timestamp_data, log_timestamp_data_raw.Get("key").Int()/1000)
+			log_timestamp_data = append(log_timestamp_data, log_timestamp_data_raw.Get("doc_count").Int())
+			log_timestamp_datas = append(log_timestamp_datas, log_timestamp_data)
+		}
+
+		log_type_data["data"] = log_timestamp_datas
+		log_type_datas = append(log_type_datas, log_type_data)
+	}
+	return log_type_datas, nil
+}
diff --git a/server/service/cluster/meta.go b/server/service/cluster/meta.go
new file mode 100644
index 0000000..22d5d77
--- /dev/null
+++ b/server/service/cluster/meta.go
@@ -0,0 +1,2 @@
+package cluster
+
diff --git a/server/service/machine/LogStream.go b/server/service/machine/LogStream.go
new file mode 100644
index 0000000..494b718
--- /dev/null
+++ b/server/service/machine/LogStream.go
@@ -0,0 +1 @@
+package cluster
\ No newline at end of file
diff --git a/server/service/machine/LogTimeAixs.go b/server/service/machine/LogTimeAixs.go
new file mode 100644
index 0000000..22d5d77
--- /dev/null
+++ b/server/service/machine/LogTimeAixs.go
@@ -0,0 +1,2 @@
+package cluster
+
-- 
Gitee