diff options
| author | Bar Shaul <88437685+barshaul@users.noreply.github.com> | 2022-11-10 12:38:47 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-10 12:38:47 +0200 |
| commit | bb06ccd52924800ac501d17c8a42038c8e5c5770 (patch) | |
| tree | df9fa0ae2c2553ecc3779b3f7166d6cad4855c03 /redis/asyncio/cluster.py | |
| parent | fb647430f00cc7bb67c978e75f2dabc661567779 (diff) | |
| download | redis-py-bb06ccd52924800ac501d17c8a42038c8e5c5770.tar.gz | |
CredentialsProvider class added to support password rotation (#2261)
* A CredentialsProvider class has been added to allow the user to add his own provider for password rotation
* Moved CredentialsProvider to a separate file, added type hints
* Changed username and password to properties
* Added: StaticCredentialProvider, examples, tests
Changed: CredentialsProvider to CredentialProvider
Fixed: calling AUTH only with password
* Changed private members' prefix to __
* fixed linters
* fixed auth test
* fixed credential test
* Raise an error if username or password are passed along with credential_provider
* fixing linters
* fixing test
* Changed dundered to single per side underscore
* Changed Connection class members username and password to properties to enable backward compatibility with changing the members value on existing connection.
* Reverting last commit and adding backward compatibility to 'username' and 'password' inside on_connect function
* Refactored CredentialProvider class
* Fixing tuple type to Tuple
* Fixing optional string members in UsernamePasswordCredentialProvider
* Fixed credential test
* Added credential provider support to AsyncRedis
* linters
* linters
* linters
* linters - black
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
Co-authored-by: dvora-h <dvora.heller@redis.com>
Diffstat (limited to 'redis/asyncio/cluster.py')
| -rw-r--r-- | redis/asyncio/cluster.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index 97f4151..57aafbd 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -40,6 +40,7 @@ from redis.cluster import ( ) from redis.commands import READ_COMMANDS, AsyncRedisClusterCommands from redis.crc import REDIS_CLUSTER_HASH_SLOTS, key_slot +from redis.credentials import CredentialProvider from redis.exceptions import ( AskError, BusyLoadingError, @@ -220,6 +221,7 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterCommand # Client related kwargs db: Union[str, int] = 0, path: Optional[str] = None, + credential_provider: Optional[CredentialProvider] = None, username: Optional[str] = None, password: Optional[str] = None, client_name: Optional[str] = None, @@ -266,6 +268,7 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterCommand "connection_class": Connection, "parser_class": ClusterParser, # Client related kwargs + "credential_provider": credential_provider, "username": username, "password": password, "client_name": client_name, |