Skip to content

Commit 73de5c1

Browse files
authored
fix(sdk): prevent client from getting stuck after disconnect (#2610)
NotConnected error was not triggering reconnection logic, causing clients to remain permanently disconnected when heartbeat or poll operations failed after connection loss.
1 parent de6995d commit 73de5c1

File tree

4 files changed

+5
-3
lines changed

4 files changed

+5
-3
lines changed

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

DEPENDENCIES.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,7 @@ icu_provider: 2.1.1, "Unicode-3.0",
386386
ident_case: 1.0.1, "Apache-2.0 OR MIT",
387387
idna: 1.1.0, "Apache-2.0 OR MIT",
388388
idna_adapter: 1.2.1, "Apache-2.0 OR MIT",
389-
iggy: 0.8.1-edge.4, "Apache-2.0",
389+
iggy: 0.8.1-edge.5, "Apache-2.0",
390390
iggy-bench: 0.3.1-edge.1, "Apache-2.0",
391391
iggy-bench-dashboard-server: 0.5.1-edge.1, "Apache-2.0",
392392
iggy-cli: 0.10.1-edge.1, "Apache-2.0",

core/sdk/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
[package]
1919
name = "iggy"
20-
version = "0.8.1-edge.4"
20+
version = "0.8.1-edge.5"
2121
description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
2222
edition = "2024"
2323
license = "Apache-2.0"

core/sdk/src/tcp/tcp_client.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,8 @@ impl BinaryTransport for TcpClient {
120120
| IggyError::EmptyResponse
121121
| IggyError::Unauthenticated
122122
| IggyError::StaleClient
123+
| IggyError::NotConnected
124+
| IggyError::CannotEstablishConnection
123125
) {
124126
return Err(error);
125127
}

0 commit comments

Comments
 (0)