admin/kubesphere
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Optimize the error message

Browse Source 
Signed-off-by: chengdehao <dehaocheng@yunify.com>
This commit is contained in:
chengdehao
2022-01-24 16:52:02 +08:00
parent 77d14fe4dc
commit 37369334f1
5 changed files with 44 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/simple/client/es/versions/v7/v7.go
View File

@@ -28,6 +28,8 @@ import (
"github.com/elastic/go-elasticsearch/v7"
"github.com/elastic/go-elasticsearch/v7/esapi"
"kubesphere.io/kubesphere/pkg/simple/client/es/versions"
)
type Elastic struct {
@@ -115,12 +117,15 @@ func (e *Elastic) GetTotalHitCount(v interface{}) int64 {
}
func parseError(response *esapi.Response) error {
var e map[string]interface{}
var e versions.Error
if err := json.NewDecoder(response.Body).Decode(&e); err != nil {
return err
} else {
// Print the response status and error information.
e, _ := e["error"].(map[string]interface{})
return fmt.Errorf("type: %v, reason: %v", e["type"], e["reason"])
if len(e.Details.RootCause) != 0 {
return fmt.Errorf("type: %v, reason: %v", e.Details.Type, e.Details.RootCause[0].Reason)
} else {
return fmt.Errorf("type: %v, reason: %v", e.Details.Type, e.Details.Reason)
}
}
}