Skip to content

Commit

Permalink
Update mirrord/kube/src/api/kubernetes/portforwarder.rs
Browse files Browse the repository at this point in the history
Co-authored-by: Michał Smolarek <[email protected]>
  • Loading branch information
DmitryDodzin and Razz4780 authored Feb 2, 2025
1 parent 910d9b9 commit 8c379a4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion mirrord/kube/src/api/kubernetes/portforwarder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -215,7 +215,7 @@ pub async fn retry_portforward(
client: &Client,
connect_info: AgentKubernetesConnectInfo,
) -> Result<(Box<dyn UnpinStream>, SinglePortForwarder)> {
// use 1024 * 1024 to be identical to `kube` implementation (https://github.com/kube-rs/kube/blob/ecbdafc214538aadc78ec8447f2fa12d0057492b/kube-client/src/api/portforward.rs#L101)
// use 1024 * 1024 to be identical to [`kube` implementation](https://github.com/kube-rs/kube/blob/ecbdafc214538aadc78ec8447f2fa12d0057492b/kube-client/src/api/portforward.rs#L101).
let (lhs, rhs) = tokio::io::duplex(1024 * 1024);

let port_forwarder = SinglePortForwarder::connect(client, connect_info, Box::new(rhs)).await?;
Expand Down

0 comments on commit 8c379a4

Please sign in to comment.