GoCQL cluster.CreateSession () выводит ошибку на стандартный вывод - PullRequest
0 голосов
/ 11 декабря 2018

В этом коде

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, закодированная в нашем модульном тесте, поэтому убедитесь, что вышестоящий код может правильно обработать ошибку соединения.

...