diff --git a/db/elasticEngine.go b/db/elasticEngine.go index a11e5d9..57b08bd 100644 --- a/db/elasticEngine.go +++ b/db/elasticEngine.go @@ -117,7 +117,7 @@ func (p *ElkEngine)Update(index string,types string,id string,data map[string]in } func (p *ElkEngine)CreateIndex(index string,typemaping string) error{ if nil != p { - exists, err := p.cli.IndexExists("elastic_index").Do(context.Background()) + exists, err := p.cli.IndexExists(index).Do(context.Background()) if err != nil { // Handle error log.Print(err) @@ -137,4 +137,21 @@ func (p *ElkEngine)CreateIndex(index string,typemaping string) error{ } } return errors.New(ERROR_PTR) +} + +func (p *ElkEngine)IndexExisted(index string) (bool,error ){ + if nil != p { + exists, err := p.cli.IndexExists(index).Do(context.Background()) + if exists{ + return true,nil + } + if err != nil { + // Handle error + log.Print(err) + return false,err + } + return false,nil + + } + return false,nil } \ No newline at end of file diff --git a/main.go b/main.go index 258d6e8..0e76d9f 100644 --- a/main.go +++ b/main.go @@ -43,7 +43,7 @@ func InitRedis() { func InitElasticSearch(){ e := db.GetElastic().CreateIndex("hardware",model.HardwareTypeMapping()) if nil != e{ - log.Print(e.Error()) + } } func InitLogs() {