Skip to main content

handle_admin_connection

running_process::broker::server::admin

Function handle_admin_connection 

Source 
pub fn handle_admin_connection<S: Read + Write>(
    stream: &mut S,
    snapshot: &AdminSnapshot,
) -> Result<AdminReply, AdminConnectionError>
Expand description

Handle one already-accepted broker admin connection.

The connection reads one v1-framed Frame carrying an AdminRequest, dispatches through handle_admin_frame, writes one v1-framed response Frame carrying an AdminReply, then returns the decoded reply for tests and callers that need exit-code metadata.