From ed7816681aae57569c64fc0182364ddbc116a3fa Mon Sep 17 00:00:00 2001 From: limd Date: Fri, 25 Sep 2020 11:22:47 +0800 Subject: [PATCH] Add cassandra authenticator mode --- weed/filer/cassandra/cassandra_store.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/weed/filer/cassandra/cassandra_store.go b/weed/filer/cassandra/cassandra_store.go index 250db629a..ae8cb7a86 100644 --- a/weed/filer/cassandra/cassandra_store.go +++ b/weed/filer/cassandra/cassandra_store.go @@ -28,11 +28,16 @@ func (store *CassandraStore) Initialize(configuration util.Configuration, prefix return store.initialize( configuration.GetString(prefix+"keyspace"), configuration.GetStringSlice(prefix+"hosts"), + configuration.GetString(prefix+"username"), + configuration.GetString(prefix+"password"), ) } -func (store *CassandraStore) initialize(keyspace string, hosts []string) (err error) { +func (store *CassandraStore) initialize(keyspace string, hosts []string, username string, password string) (err error) { store.cluster = gocql.NewCluster(hosts...) + if username != "" && password != "" { + store.cluster.Authenticator = gocql.PasswordAuthenticator{Username: username, Password: password} + } store.cluster.Keyspace = keyspace store.cluster.Consistency = gocql.LocalQuorum store.session, err = store.cluster.CreateSession()