В этом коде
func InitDB(keyspace string) (*gocql.Session, error) {
//**********************************************************************************
// connect to the Cassandra cluster
//**********************************************************************************
cluster := gocql.NewCluster("127.0.0.1")
cluster.Keyspace = keyspace
cluster.Consistency = gocql.Quorum
cqlSession, err := cluster.CreateSession()
if err != nil {
log.Println("CreateSession failed:", err)
return nil, errors.New("Can't connect to DB")
}
// fmt.Println("Cassandra opened")
return cqlSession, nil
}
, если пространство ключей не существует, gocql печатает два сообщения журнала на стандартный вывод:
2018/12/10 18:24:42 error: failed to connect to 127.0.0.1:9042 due to error: Keyspace 'qwerty' does not exist
2018/12/10 18:24:42 error: failed to connect to 127.0.0.1:9042 due to error: Keyspace 'qwerty' does not exist
Эти строкисгенерированный
Logger.Printf("error: failed to connect to %s due to error: %v", pool.addr, err)
в connectionpool.go
Есть ли способ подавить эти сообщения, исключая их редактирование из кода gocql?Они сбивают с толку наш тестовый сервер CI.
У нас есть явная ошибка CreateSession, закодированная в нашем модульном тесте, поэтому убедитесь, что вышестоящий код может правильно обработать ошибку соединения.