diff --git a/server/service/cluster/LogStream.go b/server/service/cluster/LogStream.go new file mode 100644 index 0000000000000000000000000000000000000000..494b718b85ae49a2dc1ea5d4f1cc3564126e98ed --- /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 0000000000000000000000000000000000000000..2b400ae8b7897ae7941da91b0424fee38c4eeab3 --- /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 0000000000000000000000000000000000000000..22d5d772a218f269e7d8e64b8817576ad46a0f06 --- /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 0000000000000000000000000000000000000000..494b718b85ae49a2dc1ea5d4f1cc3564126e98ed --- /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 0000000000000000000000000000000000000000..22d5d772a218f269e7d8e64b8817576ad46a0f06 --- /dev/null +++ b/server/service/machine/LogTimeAixs.go @@ -0,0 +1,2 @@ +package cluster +