|
|
@@ -31,8 +31,9 @@ func init(){
|
|
|
|
|
|
// 设置cassandar 配置
|
|
|
cassandra := config.AppConfig.GetKey("cassandra")
|
|
|
+ keyspace := config.AppConfig.GetKey("keyspace")
|
|
|
_clusterCfg = gocql.NewCluster(strings.Split(cassandra, ",")...)
|
|
|
- _clusterCfg.Keyspace = "i2_log"
|
|
|
+ _clusterCfg.Keyspace = keyspace
|
|
|
_clusterCfg.Consistency = gocql.Quorum
|
|
|
//设置连接池的数量,默认是2个（针对每一个host,都建立起NumConns个连接）
|
|
|
_clusterCfg.NumConns = 3
|
huangrf