Skip to content

Commit 5c377cb

Browse files
Update crates/fluss/src/client/connection.rs
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
1 parent 351f6d9 commit 5c377cb

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

crates/fluss/src/client/connection.rs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -79,11 +79,10 @@ impl FlussConnection {
7979
}
8080

8181
pub async fn get_admin(&self) -> Result<FlussAdmin> {
82-
// Lazily initialize and cache the FlussAdmin instance. The cached FlussAdmin
83-
// holds a reference to RpcClient, which manages connection reuse and re-acquisition
84-
// when a cached connection becomes poisoned. Subsequent calls clone cheaply —
85-
// all internal fields (ServerConnection, Arc<Metadata>, Arc<RpcClient>) are
86-
// Arc-backed so cloning is just a reference-count bump.
82+
// Lazily initialize and cache the FlussAdmin instance. Subsequent calls
83+
// return a clone of the same cached admin. All internal fields
84+
// (ServerConnection, Arc<Metadata>, Arc<RpcClient>) are Arc-backed, so
85+
// cloning is effectively just a reference-count bump.
8786
let admin = self
8887
.admin_client
8988
.get_or_try_init(|| FlussAdmin::new(self.network_connects.clone(), self.metadata.clone()))

0 commit comments

Comments
 (0)