diff --git a/Cargo.lock b/Cargo.lock index 49e0416169..2a2ced228b 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3162,6 +3162,7 @@ dependencies = [ "enum-map", "hex", "postgres_ffi", + "rand 0.8.5", "serde", "serde_json", "serde_with", diff --git a/libs/pageserver_api/Cargo.toml b/libs/pageserver_api/Cargo.toml index 4d08d78e87..09f85f6bfc 100644 --- a/libs/pageserver_api/Cargo.toml +++ b/libs/pageserver_api/Cargo.toml @@ -15,6 +15,7 @@ byteorder.workspace = true utils.workspace = true postgres_ffi.workspace = true enum-map.workspace = true +rand.workspace = true strum.workspace = true strum_macros.workspace = true hex.workspace = true diff --git a/pageserver/src/client/mgmt_api.rs b/pageserver/src/client/mgmt_api.rs index 07f4213e7f..82058316ed 100644 --- a/pageserver/src/client/mgmt_api.rs +++ b/pageserver/src/client/mgmt_api.rs @@ -25,7 +25,7 @@ impl Client { anyhow::bail!("status error"); } let body = hyper::body::to_bytes(resp).await?; - Ok(serde_json::from_slice(&body)?) + serde_json::from_slice(&body).context("deserialize") } pub async fn list_timelines( @@ -41,7 +41,7 @@ impl Client { anyhow::bail!("status error"); } let body = hyper::body::to_bytes(resp).await?; - Ok(serde_json::from_slice(&body)?) + serde_json::from_slice(&body).context("deserialize") } pub async fn timeline_info( @@ -58,7 +58,7 @@ impl Client { anyhow::bail!("status error"); } let body = hyper::body::to_bytes(resp).await?; - Ok(serde_json::from_slice(&body)?) + serde_json::from_slice(&body).context("deserialize") } pub async fn keyspace( @@ -75,7 +75,7 @@ impl Client { anyhow::bail!("status error"); } let body = hyper::body::to_bytes(resp).await?; - Ok(serde_json::from_slice(&body).context("deserialize")?) + serde_json::from_slice(&body).context("deserialize") } async fn get(&self, uri: Uri) -> hyper::Result> {