chore(deps): Bump tokio-tungstenite from 0.19.0 to 0.20.0 (vectordotd…

…ev#18065)

* chore(deps): Bump tokio-tungstenite from 0.19.0 to 0.20.0

Bumps [tokio-tungstenite](https://github.com/snapview/tokio-tungstenite) from 0.19.0 to 0.20.0.
- [Changelog](https://github.com/snapview/tokio-tungstenite/blob/master/CHANGELOG.md)
- [Commits](snapview/tokio-tungstenite@v0.19.0...v0.20.0)

---
updated-dependencies:
- dependency-name: tokio-tungstenite
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

* Use non deprecated config options (default is no buffering)

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: neuronull <neuronull@pm.me>

Cargo.toml

@@ -317,7 +317,7 @@ strip-ansi-escapes = { version = "0.1.1", default-features = false }
 syslog = { version = "6.1.0", default-features = false, optional = true }
 tikv-jemallocator = { version = "0.5.0", default-features = false, optional = true }
 tokio-postgres = { version = "0.7.7", default-features = false, features = ["runtime", "with-chrono-0_4"], optional = true }
-tokio-tungstenite = {version = "0.19.0", default-features = false, features = ["connect"], optional = true}
+tokio-tungstenite = {version = "0.20.0", default-features = false, features = ["connect"], optional = true}
 toml = { version = "0.7.6", default-features = false, features = ["parse", "display"] }
 tonic = { version = "0.9", optional = true, default-features = false, features = ["transport", "codegen", "prost", "tls", "tls-roots", "gzip"] }
 trust-dns-proto = { version = "0.22.0", default-features = false, features = ["dnssec"], optional = true }

lib/vector-api-client/Cargo.toml

@@ -26,7 +26,7 @@ graphql_client = { version = "0.13.0", default-features = false, features = ["gr
 
 # HTTP / WebSockets
 reqwest = { version = "0.11.18", default-features = false, features = ["json"] }
-tokio-tungstenite = { version = "0.19.0", default-features = false, features = ["connect", "rustls"] }
+tokio-tungstenite = { version = "0.20.0", default-features = false, features = ["connect", "rustls"] }
 
 # External libs
 chrono = { version = "0.4.6", default-features = false, features = ["serde"] }

src/sinks/websocket/sink.rs

@@ -132,10 +132,7 @@ impl WebSocketConnector {
 
         let maybe_tls = self.tls_connect().await?;
 
-        let ws_config = WebSocketConfig {
-            max_send_queue: None, // don't buffer messages
-            ..Default::default()
-        };
+        let ws_config = WebSocketConfig::default();
 
         let (ws_stream, _response) = client_async_with_config(request, maybe_tls, Some(ws_config))
             .await