Replace host str to use https if encrypted

examples/volumes.rs

@@ -12,7 +12,7 @@ fn main() {
                 println!("volume -> {:#?}", v)
             }
         })
-        .map_err(|e| eprintln!("Error: {}", e));;
+        .map_err(|e| eprintln!("Error: {}", e));
 
     tokio::run(fut);
 }

src/builder.rs

@@ -1662,7 +1662,7 @@ mod tests {
         assert_eq!(
             r#"{"HostConfig":{"RestartPolicy":{"MaximumRetryCount":10,"Name":"on-failure"}},"Image":"test_image"}"#,
             options.serialize().unwrap()
-       );
+        );
 
         options = ContainerOptionsBuilder::new("test_image")
             .restart_policy("always", 0)
@@ -1707,7 +1707,9 @@ mod tests {
             .server_address("https://example.org")
             .build();
         assert_eq!(
-            base64::encode(r#"{"username":"user_abc","password":"password_abc","email":"email_abc","serveraddress":"https://example.org"}"#),
+            base64::encode(
+                r#"{"username":"user_abc","password":"password_abc","email":"email_abc","serveraddress":"https://example.org"}"#
+            ),
             options.serialize()
         );
     }

src/lib.rs

@@ -885,6 +885,16 @@ fn get_docker_for_tcp(tcp_host_str: String) -> Docker {
             connector.set_ca_file(&Path::new(ca)).unwrap();
         }
 
+        // If we are attempting to connec to the docker daemon via tcp
+        // we need to convert the scheme to `https` to let hyper connect.
+        // Otherwise, hyper will reject the connection since it does not
+        // recongnize `tcp` as a valid `http` scheme.
+        let tcp_host_str = if tcp_host_str.contains("tcp://") {
+            tcp_host_str.replace("tcp://", "https://")
+        } else {
+            tcp_host_str
+        };
+
         Docker {
             transport: Transport::EncryptedTcp {
                 client: Client::builder()