Extended CredentialProvider interface with async API

Author: vladvildanov

redis/credentials.py

@@ -10,6 +10,9 @@ class CredentialProvider:
     def get_credentials(self) -> Union[Tuple[str], Tuple[str, str]]:
         raise NotImplementedError("get_credentials must be implemented")
 
+    async def get_credentials_async(self) -> Union[Tuple[str], Tuple[str, str]]:
+        raise NotImplementedError("get_credentials_async must be implemented")
+
 
 class StreamingCredentialProvider(CredentialProvider, ABC):
     """
@@ -34,7 +37,6 @@ def is_streaming(self) -> bool:
         pass
 
 
-
 class UsernamePasswordCredentialProvider(CredentialProvider):
     """
     Simple implementation of CredentialProvider that just wraps static
@@ -49,3 +51,8 @@ def get_credentials(self):
         if self.username:
             return self.username, self.password
         return (self.password,)
+
+    async def get_credentials_async(self) -> Union[Tuple[str], Tuple[str, str]]:
+        if self.username:
+            return self.username, self.password
+        return (self.password,)