elastic.go 579 B

1234567891011121314151617181920212223
  1. package utility
  2. import (
  3. "app.yhyue.com/moapp/jybase/es"
  4. "github.com/gogf/gf/v2/frame/g"
  5. "github.com/gogf/gf/v2/os/gctx"
  6. )
  7. type esConf struct {
  8. Address string `json:"address"`
  9. Size int `json:"size"`
  10. Version string `json:"version"`
  11. UserName string `json:"userName"`
  12. Password string `json:"password"`
  13. }
  14. func init() {
  15. var EsConf esConf
  16. ctx := gctx.New()
  17. _ = g.Cfg().MustGet(ctx, "elasticsearch", "").Scan(&EsConf)
  18. es.NewEs(EsConf.Version, EsConf.Address, EsConf.Size, EsConf.UserName, EsConf.Password)
  19. g.Log().Info(ctx, "初始化 elasticsearch", EsConf)
  20. }