From a6d2d262f6c565de5cb1069cf024f04bb40ffffa Mon Sep 17 00:00:00 2001 From: andy Date: Tue, 13 Aug 2024 16:56:21 +0800 Subject: [PATCH] error before 404 --- pkg/es/es5.go | 8 ++++---- pkg/es/es6.go | 8 ++++---- pkg/es/es7.go | 8 ++++---- pkg/es/es8.go | 8 ++++---- 4 files changed, 16 insertions(+), 16 deletions(-) diff --git a/pkg/es/es5.go b/pkg/es/es5.go index 44cf47d..8e20e92 100644 --- a/pkg/es/es5.go +++ b/pkg/es/es5.go @@ -293,14 +293,14 @@ func (es *V5) CreateIndex(esSetting IESSettings) error { func (es *V5) IndexExisted(indexName string) (bool, error) { res, err := es.Client.Indices.Exists([]string{indexName}) - if res.StatusCode == 404 { - return false, nil - } - if err != nil { return false, errors.WithStack(err) } + if res.StatusCode == 404 { + return false, nil + } + defer func() { _ = res.Body.Close() }() diff --git a/pkg/es/es6.go b/pkg/es/es6.go index 15b4edd..46f7241 100644 --- a/pkg/es/es6.go +++ b/pkg/es/es6.go @@ -270,14 +270,14 @@ func (es *V6) CreateIndex(esSetting IESSettings) error { func (es *V6) IndexExisted(indexName string) (bool, error) { res, err := es.Client.Indices.Exists([]string{indexName}) - if res.StatusCode == 404 { - return false, nil - } - if err != nil { return false, errors.WithStack(err) } + if res.StatusCode == 404 { + return false, nil + } + defer func() { _ = res.Body.Close() }() diff --git a/pkg/es/es7.go b/pkg/es/es7.go index c39ac20..69d7ae5 100644 --- a/pkg/es/es7.go +++ b/pkg/es/es7.go @@ -294,14 +294,14 @@ func (es *V7) CreateIndex(esSetting IESSettings) error { func (es *V7) IndexExisted(indexName string) (bool, error) { res, err := es.Client.Indices.Exists([]string{indexName}) - if res.StatusCode == 404 { - return false, nil - } - if err != nil { return false, errors.WithStack(err) } + if res.StatusCode == 404 { + return false, nil + } + defer func() { _ = res.Body.Close() }() diff --git a/pkg/es/es8.go b/pkg/es/es8.go index 3c5302b..8387d40 100644 --- a/pkg/es/es8.go +++ b/pkg/es/es8.go @@ -295,14 +295,14 @@ func (es *V8) CreateIndex(esSetting IESSettings) error { func (es *V8) IndexExisted(indexName string) (bool, error) { res, err := es.Client.Indices.Exists([]string{indexName}) - if res.StatusCode == 404 { - return false, nil - } - if err != nil { return false, errors.WithStack(err) } + if res.StatusCode == 404 { + return false, nil + } + defer func() { _ = res.Body.Close() }()