diff options
| author | limd <limd@sugon.com> | 2020-09-25 11:22:47 +0800 |
|---|---|---|
| committer | limd <limd@sugon.com> | 2020-09-25 11:22:47 +0800 |
| commit | ed7816681aae57569c64fc0182364ddbc116a3fa (patch) | |
| tree | 2ffd2e1cb0745cc6d80486e7bb90056d076b1f90 | |
| parent | 370a98cf6b5fd1a205c8015404dbb3815afb0eac (diff) | |
| download | seaweedfs-ed7816681aae57569c64fc0182364ddbc116a3fa.tar.xz seaweedfs-ed7816681aae57569c64fc0182364ddbc116a3fa.zip | |
Add cassandra authenticator mode
| -rw-r--r-- | weed/filer/cassandra/cassandra_store.go | 7 |
1 files changed, 6 insertions, 1 deletions
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() |