From 1603f4d6a16ee84f70db2fbf17eee46c6a9edab6 Mon Sep 17 00:00:00 2001 From: Wangjunqi123 Date: Wed, 5 Jun 2024 09:01:23 +0800 Subject: [PATCH] kibanaclient: initialize kibana client v7 --- elk/kibanaClient/7_17_16/client.go | 39 ++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 elk/kibanaClient/7_17_16/client.go diff --git a/elk/kibanaClient/7_17_16/client.go b/elk/kibanaClient/7_17_16/client.go new file mode 100644 index 00000000..8a62f71b --- /dev/null +++ b/elk/kibanaClient/7_17_16/client.go @@ -0,0 +1,39 @@ +package kibanaClient + +import ( + "context" + "errors" + + "gitee.com/openeuler/PilotGo-plugin-elk/conf" + "gitee.com/openeuler/PilotGo-plugin-elk/errormanager" + "gitee.com/openeuler/PilotGo-plugin-elk/pluginclient" + "github.com/elastic/elastic-agent-libs/kibana" +) + +var Global_kibana *KibanaClient_v7 + +type KibanaClient_v7 struct { + Client *kibana.Client + Ctx context.Context +} + +func InitKibanaClient() { + cfg := &kibana.ClientConfig{ + Protocol: "http", + Host: conf.Global_Config.Kibana.Addr, + Username: conf.Global_Config.Kibana.Username, + Password: conf.Global_Config.Kibana.Password, + } + + ki_client, err := kibana.NewClientWithConfig(cfg, "", "", "", "") + if err != nil { + err = errors.New("failed to init kibana client **errstackfatal**0") // err top + errormanager.ErrorTransmit(pluginclient.Global_Context, err, true) + return + } + + Global_kibana = &KibanaClient_v7{ + Client: ki_client, + Ctx: context.Background(), + } +} -- Gitee