|
|
|
@@ -2,6 +2,7 @@ package repository |
|
|
|
|
|
|
|
import ( |
|
|
|
"bytes" |
|
|
|
"encoding/base64" |
|
|
|
"encoding/json" |
|
|
|
"fmt" |
|
|
|
"io/ioutil" |
|
|
|
@@ -100,11 +101,14 @@ type ResultInfo struct { |
|
|
|
|
|
|
|
//发送post请求到elk |
|
|
|
func SendReqToElk(jsonStr []byte) (content string) { |
|
|
|
ElkBase64Init := setting.ElkUser + ":" + setting.ElkPassword |
|
|
|
ElkBase64 := base64.StdEncoding.EncodeToString([]byte(ElkBase64Init)) |
|
|
|
BasicElkBase64 := "Basic" + " " + ElkBase64 |
|
|
|
url := setting.ElkUrl |
|
|
|
req, _ := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr)) |
|
|
|
req.Header.Set("Content-Type", "application/json") |
|
|
|
req.Header.Set("kbn-version", "7.13.2") |
|
|
|
req.Header.Set("Authorization", "Basic cWl6aGk6UGNsMjAyMA==") |
|
|
|
req.Header.Set("Authorization", BasicElkBase64) |
|
|
|
|
|
|
|
client := &http.Client{} |
|
|
|
resp, err := client.Do(req) |
|
|
|
|