experiment

pkg/logger/cassandra.go

@@ -227,9 +227,9 @@ func (stor *cassStorage) disconnect() {
 }
 
 // newCassandraStorage returns Storage interface with cassStorage type
-func newCassandraStorage(ip string, user string, pass string) (stor storage, err error) {
+func newCassandraStorage(ip []string, user string, pass string) (stor storage, err error) {
 	var temp cassStorage
-	temp.cluster = gocql.NewCluster(ip)
+	temp.cluster = gocql.NewCluster(ip...)
 	temp.cluster.Authenticator = gocql.PasswordAuthenticator{
 		Username: user,
 		Password: pass,

pkg/logger/logger.go

@@ -101,7 +101,7 @@ func (logger *Logger) init() (err error) {
 		logger.stor = newLocalStorage()
 	case "production":
 		logger.logInfo.Println("Cassandra storage")
-		logger.stor, err = newCassandraStorage("cassandra", "cassandra", "cassandra")
+		logger.stor, err = newCassandraStorage([]string{"cass-ssset-0.cassandra", "cass-ssset-1.cassandra", "cass-ssset-2.cassandra"}, "cassandra", "cassandra")
 	default:
 		err = errors.New("Wrong deployment type: " + deplType)
 	}