rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-15 20:40:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: region server use handle_batch_body

Browse Source
This commit is contained in:
evenyag
2025-02-10 21:20:14 +08:00
parent fd9940a253
commit bdbb5435ea
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/datanode/src/region_server.rs
View File

@@ -410,6 +410,24 @@ impl RegionServer {
#[async_trait]
impl RegionServerHandler for RegionServer {
async fn handle(&self, request: region_request::Body) -> ServerResult<RegionResponseV1> {
if matches!(request, region_request::Body::Inserts(_)) {
let resp = self
.handle_batch_body(request)
.await
.map_err(BoxedError::new)
.context(ExecuteGrpcRequestSnafu)?;
return Ok(RegionResponseV1 {
header: Some(ResponseHeader {
status: Some(Status {
status_code: StatusCode::Success as _,
..Default::default()
}),
}),
affected_rows: resp.affected_rows as _,
extensions: resp.extensions,
});
}
let bundle = convert_body_to_requests(request)
.context(BuildRegionRequestsSnafu)
.map_err(BoxedError::new)
@@ -941,7 +959,7 @@ impl RegionServerInner {
// }
// }
todo!()
Ok(RegionResponse::new(0))
}
fn set_region_status_not_ready(