Function extract_read_payload

d-engine-server/src/api/embedded_client.rs:101–115

Unwrap a `ClientResponsePayload` as a `ReadResults`, returning a `Protocol { InvalidResponse }` error for any other variant. Centralises the match so both `get_with_consistency` and `get_multi_with_consistency` share identical error semantics, and so the logic can be unit-tested without standing up a full Raft channel.

(result: Option<ClientResponsePayload>)

/// `get_multi_with_consistency` share identical error semantics, and so
/// the logic can be unit-tested without standing up a full Raft channel.
fn extract_read_payload(result: Option<ClientResponsePayload>) -> ClientApiResult<ReadResults> {
    match result {
        Some(ClientResponsePayload::Read(r)) => Ok(r),
        Some(ClientResponsePayload::Write(_)) => Err(ClientApiError::Protocol {
            code: ErrorCode::InvalidResponse,
            message: "expected ReadData payload, got WriteResult".to_string(),
            supported_versions: None,
        }),
        None => Err(ClientApiError::Protocol {
            code: ErrorCode::InvalidResponse,
            message: "expected ReadData payload, got None".to_string(),
            supported_versions: None,
        }),
    }
}

/// Zero-overhead KV client for embedded mode.
///