From 48d76a1e632e365c08ce3e3853315c116fcda7f6 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Wed, 30 Sep 2015 10:10:24 +0300 Subject: [PATCH] added password for cassandra storage --- engine/storage_cassandra.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/engine/storage_cassandra.go b/engine/storage_cassandra.go index 55dbf182a..8448627b8 100644 --- a/engine/storage_cassandra.go +++ b/engine/storage_cassandra.go @@ -15,10 +15,15 @@ type CassandraStorage struct { ms Marshaler } -func NewCassandraStorage(addresses []string, keyspace, mrshlerStr string) (*CassandraStorage, error) { +func NewCassandraStorage(addresses []string, keyspace, user, pass, mrshlerStr string) (*CassandraStorage, error) { cluster := gocql.NewCluster(addresses...) cluster.Keyspace = keyspace + cluster.Authenticator = gocql.PasswordAuthenticator{ + Username: user, + Password: pass, + } session, err := cluster.CreateSession() + if err != nil { return nil, err }