feat(client): add a client port override method (#259)

* feat(client): add a client port override method Signed-off-by: Mike Nguyen <[email protected]> * chore(lint): cargo fmt Signed-off-by: Mike Nguyen <[email protected]> * doc(client): add port method Signed-off-by: mikeee <[email protected]> * release: rc6 Signed-off-by: mikeee <[email protected]> --------- Signed-off-by: Mike Nguyen <[email protected]> Signed-off-by: mikeee <[email protected]>
dapr · Feb 9, 2025 · 57347e7 · 57347e7
1 parent 93322c0
commit 57347e7
Show file tree

Hide file tree

Showing 5 changed files with 30 additions and 3 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -26,7 +26,7 @@ tonic = "0.12.3"
 tonic-build = "0.12.3"
 
 [workspace.package]
-version = "0.16.0-rc.5"
+version = "0.16.0-rc.6"
 authors = [
     "Mike Nguyen <[email protected]>",
     "The Dapr Authors <[email protected]>"

diff --git a/README.md b/README.md
@@ -53,7 +53,7 @@ Add the following to your `Cargo.toml` file:
 
 ```toml
 [dependencies]
-dapr = "0.16.0-rc.5"
+dapr = "0.16.0-rc.6"
 ```
 
 Here's a basic example to create a client:

diff --git a/dapr/src/client.rs b/dapr/src/client.rs
@@ -30,6 +30,26 @@ impl<T: DaprInterface> Client<T> {
         Ok(Client(T::connect(address).await?))
     }
 
+    /// Connect to the Dapr sidecar with a specific port.
+    ///
+    /// # Arguments
+    ///
+    /// * `addr` - Address of gRPC server to connect to.
+    /// * `port` - Port of the gRPC server to connect to.
+    pub async fn connect_with_port(addr: String, port: String) -> Result<Self, Error> {
+        // assert that port is between 1 and 65535
+        let port: u16 = match port.parse::<u16>() {
+            Ok(p) => p,
+            Err(_) => {
+                panic!("Port must be a number between 1 and 65535");
+            }
+        };
+
+        let address = format!("{}:{}", addr, port);
+
+        Ok(Client(T::connect(address).await?))
+    }
+
     /// Invoke a method in a Dapr enabled app.
     ///
     /// # Arguments

diff --git a/daprdocs/content/en/rust-sdk-docs/rust-client/_index.md b/daprdocs/content/en/rust-sdk-docs/rust-client/_index.md
@@ -46,6 +46,12 @@ let mut client = dapr::Client::<dapr::client::TonicClient>::connect(addr,
 port).await?;
 ```
 
+Alternatively if you would like to specify a custom port, this can be done by using this connect method:
+
+```rust
+let mut client = dapr::Client::<dapr::client::TonicClient>::connect_with_port(addr, "3500".to_string()).await?;
+```
+
 ## Building blocks
 
 The Rust SDK allows you to interface with the

diff --git a/examples/src/conversation/main.rs b/examples/src/conversation/main.rs
@@ -10,8 +10,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     // Set the Dapr address
     let address = "https://127.0.0.1".to_string();
+    let port = "3500".to_string();
 
-    let mut client = DaprClient::connect(address).await?;
+    let mut client = DaprClient::connect_with_port(address, port).await?;
 
     let input = ConversationInputBuilder::new("hello world").build();