Change tcp_keepalive to take a std::Duration

Author: espindola

Cargo.toml

@@ -7,7 +7,7 @@ license = "MIT OR Apache-2.0"
 name = "mysql_async"
 readme = "README.md"
 repository = "https://github.com/blackbeam/mysql_async"
-version = "0.36.1"
+version = "0.37.0"
 exclude = ["test/*"]
 edition = "2021"
 categories = ["asynchronous", "database"]

src/conn/mod.rs

@@ -957,9 +957,7 @@ impl Conn {
                 #[cfg(not(unix))]
                 return Err(crate::DriverError::NamedPipesDisabled.into());
             } else {
-                let keepalive = opts
-                    .tcp_keepalive()
-                    .map(|x| std::time::Duration::from_millis(x.into()));
+                let keepalive = opts.tcp_keepalive();
                 Stream::connect_tcp(opts.hostport_or_url(), keepalive).await?
             };
 

src/opts/mod.rs

@@ -575,8 +575,8 @@ pub(crate) struct MysqlOpts {
     /// Database name (defaults to `None`).
     db_name: Option<String>,
 
-    /// TCP keep alive timeout in milliseconds (defaults to `None`).
-    tcp_keepalive: Option<u32>,
+    /// TCP keep alive timeout (defaults to `None`).
+    tcp_keepalive: Option<Duration>,
 
     /// Whether to enable `TCP_NODELAY` (defaults to `true`).
     ///
@@ -804,7 +804,7 @@ impl Opts {
     /// assert_eq!(opts.tcp_keepalive(), Some(10_000));
     /// # Ok(()) }
     /// ```
-    pub fn tcp_keepalive(&self) -> Option<u32> {
+    pub fn tcp_keepalive(&self) -> Option<Duration> {
         self.inner.mysql_opts.tcp_keepalive
     }
 
@@ -1353,8 +1353,8 @@ impl OptsBuilder {
     }
 
     /// Defines `tcp_keepalive` option. See [`Opts::tcp_keepalive`].
-    pub fn tcp_keepalive<T: Into<u32>>(mut self, tcp_keepalive: Option<T>) -> Self {
-        self.opts.tcp_keepalive = tcp_keepalive.map(Into::into);
+    pub fn tcp_keepalive(mut self, tcp_keepalive: Option<Duration>) -> Self {
+        self.opts.tcp_keepalive = tcp_keepalive;
         self
     }
 
@@ -1773,7 +1773,7 @@ fn mysqlopts_from_url(url: &Url) -> std::result::Result<MysqlOpts, UrlError> {
             }
         } else if key == "tcp_keepalive" {
             match u32::from_str(&value) {
-                Ok(value) => opts.tcp_keepalive = Some(value),
+                Ok(value) => opts.tcp_keepalive = Some(Duration::from_millis(value.into())),
                 _ => {
                     return Err(UrlError::InvalidParamValue {
                         param: "tcp_keepalive_ms".into(),