diff --git a/utils/EsUtil.go b/utils/EsUtil.go index f4b4259..ef9a90f 100644 --- a/utils/EsUtil.go +++ b/utils/EsUtil.go @@ -4,9 +4,13 @@ import ( "beeblog/models" "context" "fmt" + beego "github.com/beego/beego/v2/server/web" "github.com/olivere/elastic" + "log" + "os" "reflect" "strconv" + "time" ) var client *elastic.Client @@ -44,21 +48,21 @@ const mapping = ` } }` -//func init() { -// host, _ := beego.AppConfig.String("eshost") -// var err error -// client, err = elastic.NewClient( -// elastic.SetURL(host), -// elastic.SetSniff(false), -// elastic.SetHealthcheckInterval(10*time.Second), -// elastic.SetGzip(true), -// elastic.SetErrorLog(log.New(os.Stderr, "ELASTIC ", log.LstdFlags)), -// elastic.SetInfoLog(log.New(os.Stdout, "", log.LstdFlags))) -// -// if err != nil { -// panic(err) -// } -//} +func init() { + host, _ := beego.AppConfig.String("eshost") + var err error + client, err = elastic.NewClient( + elastic.SetURL(host), + elastic.SetSniff(false), + elastic.SetHealthcheckInterval(10*time.Second), + elastic.SetGzip(true), + elastic.SetErrorLog(log.New(os.Stderr, "ELASTIC ", log.LstdFlags)), + elastic.SetInfoLog(log.New(os.Stdout, "", log.LstdFlags))) + + if err != nil { + panic(err) + } +} func Index() { ctx := context.Background()