Skip to main content

send_admin_request

running_process::broker::client

Function send_admin_request 

Source 
pub fn send_admin_request(
    broker_endpoint: &str,
    request: AdminRequest,
) -> Result<AdminReply, BrokerClientError>
Expand description

Send one typed admin request to a broker endpoint and return its reply.

The blocking connect + write + read round-trip runs on a helper thread bounded by broker_client_deadline (issue #590, cluster H); on timeout the helper thread owns and drops the abandoned stream so a stalled broker never wedges the caller.