This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq-client-rust.git
commit dfce18051965ba71fcb494332dd1d00a33eeec4e Author: Li Zhanhui <[email protected]> AuthorDate: Sat Apr 2 12:04:13 2022 +0000 WIP: --- src/client.rs | 23 +++++++++++++++++++---- 1 file changed, 19 insertions(+), 4 deletions(-) diff --git a/src/client.rs b/src/client.rs index 813de08..c67ef55 100644 --- a/src/client.rs +++ b/src/client.rs @@ -8,6 +8,7 @@ use tonic::{ Request, Response, }; +#[derive(Debug, PartialEq)] pub struct Credentials { access_key: String, access_secret: String, @@ -24,10 +25,10 @@ pub struct StaticCredentialProvider { } impl StaticCredentialProvider { - pub fn new(access_key: String, access_secret: String) -> Self { + pub fn new(access_key: &str, access_secret: &str) -> Self { Self { - access_key, - access_secret, + access_key: access_key.to_owned(), + access_secret: access_secret.to_owned(), } } } @@ -36,7 +37,7 @@ impl CredentialProvider for StaticCredentialProvider { fn get_credentials(&self) -> Credentials { Credentials { access_key: self.access_key.clone(), - access_secret: self.access_key.clone(), + access_secret: self.access_secret.clone(), session_token: None, } } @@ -158,6 +159,20 @@ mod test { assert_eq!(route_response.status.unwrap().code, Code::Ok as i32); } + #[test] + fn test_static_credentials_provider() { + let provider = StaticCredentialProvider::new("ak", "as"); + let credentials = provider.get_credentials(); + assert_eq!( + credentials, + Credentials { + access_key: String::from("ak"), + access_secret: String::from("as"), + session_token: None, + } + ); + } + #[tokio::test] async fn test_periodic_task() { let client_manager = ClientManager::default();
