diff options
author | Alex Auvolat <alex@adnab.me> | 2023-01-10 15:22:25 +0100 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2023-01-10 15:22:25 +0100 |
commit | b83517d521b1bea7585ce45a803fad373f28225c (patch) | |
tree | 5562397a39647be8d61a9c870103d15c604e09ad /src/api/k2v/index.rs | |
parent | 57eabe787948ad6c23eae7761d02545c675bf7ff (diff) | |
download | garage-b83517d521b1bea7585ce45a803fad373f28225c.tar.gz garage-b83517d521b1bea7585ce45a803fad373f28225c.zip |
Implement PollRange API endpoint
Diffstat (limited to 'src/api/k2v/index.rs')
-rw-r--r-- | src/api/k2v/index.rs | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/api/k2v/index.rs b/src/api/k2v/index.rs index 210950bf..6c1d4a91 100644 --- a/src/api/k2v/index.rs +++ b/src/api/k2v/index.rs @@ -1,10 +1,9 @@ use std::sync::Arc; -use hyper::{Body, Response, StatusCode}; +use hyper::{Body, Response}; use serde::Serialize; use garage_util::data::*; -use garage_util::error::Error as GarageError; use garage_rpc::ring::Ring; use garage_table::util::*; @@ -12,6 +11,7 @@ use garage_table::util::*; use garage_model::garage::Garage; use garage_model::k2v::item_table::{BYTES, CONFLICTS, ENTRIES, VALUES}; +use crate::helpers::*; use crate::k2v::error::*; use crate::k2v::range::read_range; @@ -68,10 +68,7 @@ pub async fn handle_read_index( next_start, }; - let resp_json = serde_json::to_string_pretty(&resp).map_err(GarageError::from)?; - Ok(Response::builder() - .status(StatusCode::OK) - .body(Body::from(resp_json))?) + Ok(json_ok_response(&resp)?) } #[derive(Serialize)] |