jy-data-extract/src/jy/util/elastic_client.go

package util

import (
	"github.com/go-redis/redis"
	"qfw/util"
	"time"
)

//import (
//	"gopkg.in/olivere/elastic.v5"
//)
//
//var ElasticClient *elastic.Client
var ElasticClientIndex,ElasticClientType,ElasticClientDB string
var QykRedisPool *redis.Client
func init() {
	QykRedisPool = redis.NewClient(&redis.Options{
		Addr:         util.ObjToString(Config["redis_qyk"]),
		DB:           1,
		DialTimeout:  10 * time.Second,
		ReadTimeout:  30 * time.Second,
		WriteTimeout: 30 * time.Second,
		PoolSize:     30,
		MinIdleConns: 20,
		PoolTimeout:  30 * time.Second,
	})
}
//func init() {
//	if eClient, err := elastic.NewClient(elastic.SetURL(util.ObjToString(Config["elasticsearch"])));err != nil{
//		log.Println(Config["elasticsearch"])
//		log.Fatalln("ElasticClient err:",err)
//	}else {
//		ElasticClient = eClient
//	}
//}