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 // } //}