client: support default port (#88)

* client: support default port

* docs: link README

Author: alissa-tung

Cargo.lock

@@ -11,10 +11,10 @@ Rust client library for HStreamDB.
 
 This library is experimental and work in progress, please use the latest released version on [crates.io](https://crates.io/crates/hstreamdb).
 
-| client library version | HStream server version     |
-| ---------------------- | -------------------------- |
-| `v0.1.*`               | >= `v0.9.4` && <= `v0.9.7` |
-| `v0.2.*`               | >= `v0.9.4` && <= `v0.9.7` |
+| client library version | HStream server version      |
+| ---------------------- | --------------------------- |
+| `v0.1.*`               | >= `v0.9.4` && <= `v0.9.7`  |
+| `v0.2.*`               | >= `v0.9.4` && <= `v0.12.0` |
 
 
 ## Example Usage

README.md

@@ -0,0 +1 @@
+../../README.md

src/hstreamdb-pb/README.md

@@ -15,7 +15,7 @@ thiserror = "1.0.38"
 log = "0.4.17"
 
 flate2 = "1.0.25"
-zstd = "0.11.2"
+zstd = "0.12.1"
 
 num-bigint = "0.4.3"
 num-traits = "0.2.15"
@@ -35,5 +35,5 @@ workspace-hack = { version = "0.1", path = "../utils/workspace-hack" }
 hstreamdb-test-utils = { path = "../utils/hstreamdb-test-utils" }
 
 anyhow = "1.0.68"
-env_logger = "0.9.3"
+env_logger = "0.10.0"
 rand = "0.8.5"

src/hstreamdb-pb/README.md

@@ -0,0 +1 @@
+../../README.md

src/hstreamdb/Cargo.toml

@@ -32,7 +32,15 @@ impl Client {
         const HSTREAM_PREFIX: &str = "hstream";
         let server_url = server_url.into();
         let (url_scheme, url) = {
-            let url = Url::parse(&server_url)?;
+            let url = {
+                let mut url = Url::parse(&server_url)?;
+                if url.port().is_none() {
+                    url.set_port(Some(6570))
+                        .map_err(|()| common::Error::SetPortError(server_url.to_string()))?;
+                }
+                url
+            };
+
             if url.scheme() == HSTREAM_PREFIX {
                 let url_scheme = if channel_provider_settings.client_tls_config.is_none() {
                     "http"

src/hstreamdb/README.md

@@ -94,6 +94,8 @@ pub enum Error {
     BadArgument(String),
     #[error(transparent)]
     AppenderSendError(producer::SendError),
+    #[error("the URL {0} is cannot-be-a-base, or does not have a host, or has the file scheme")]
+    SetPortError(String),
 }
 
 #[derive(Debug, thiserror::Error)]

src/hstreamdb/README.md

@@ -5,7 +5,7 @@ edition = "2021"
 
 [dependencies]
 log = "0.4.17"
-env_logger = "0.9.3"
+env_logger = "0.10.0"
 
 anyhow = "1.0.68"
 rand = "0.8.5"

src/hstreamdb/src/client.rs

@@ -11,7 +11,7 @@ workspace-hack = { version = "0.1", path = "../../utils/workspace-hack" }
 hstreamdb = { path = "../../hstreamdb" }
 
 log = "0.4.17"
-env_logger = "0.9.3"
+env_logger = "0.10.0"
 
 once_cell = "1.17.0"
 rustler = "0.26.0"