From 190649dada8761426023615a01636a33145c2948 Mon Sep 17 00:00:00 2001 From: Xuanwo Date: Wed, 10 Jan 2024 17:12:47 +0800 Subject: [PATCH] Fix build Signed-off-by: Xuanwo --- core/src/services/cos/writer.rs | 4 ++-- core/src/services/obs/writer.rs | 4 ++-- core/src/services/oss/writer.rs | 4 ++-- core/src/services/s3/writer.rs | 4 ++-- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/core/src/services/cos/writer.rs b/core/src/services/cos/writer.rs index 346377d27d6e..a05472aa8aae 100644 --- a/core/src/services/cos/writer.rs +++ b/core/src/services/cos/writer.rs @@ -78,7 +78,7 @@ impl oio::MultipartWrite for CosWriter { StatusCode::OK => { let bs = resp.into_body().bytes().await?; - let result: InitiateMultipartResult = + let result: InitiateMultipartUploadResult = quick_xml::de::from_reader(bytes::Buf::reader(bs)) .map_err(new_xml_deserialize_error)?; @@ -127,7 +127,7 @@ impl oio::MultipartWrite for CosWriter { async fn complete_part(&self, upload_id: &str, parts: &[oio::MultipartPart]) -> Result<()> { let parts = parts .iter() - .map(|p| CompleteMultipartRequestPart { + .map(|p| CompleteMultipartUploadRequestPart { part_number: p.part_number, etag: p.etag.clone(), }) diff --git a/core/src/services/obs/writer.rs b/core/src/services/obs/writer.rs index 18511ca04d84..63d7287169ae 100644 --- a/core/src/services/obs/writer.rs +++ b/core/src/services/obs/writer.rs @@ -79,7 +79,7 @@ impl oio::MultipartWrite for ObsWriter { StatusCode::OK => { let bs = resp.into_body().bytes().await?; - let result: InitiateMultipartResult = + let result: InitiateMultipartUploadResult = quick_xml::de::from_reader(bytes::Buf::reader(bs)) .map_err(new_xml_deserialize_error)?; @@ -128,7 +128,7 @@ impl oio::MultipartWrite for ObsWriter { async fn complete_part(&self, upload_id: &str, parts: &[MultipartPart]) -> Result<()> { let parts = parts .iter() - .map(|p| CompleteMultipartRequestPart { + .map(|p| CompleteMultipartUploadRequestPart { part_number: p.part_number, etag: p.etag.clone(), }) diff --git a/core/src/services/oss/writer.rs b/core/src/services/oss/writer.rs index 253dcccb2b06..c8015788d32c 100644 --- a/core/src/services/oss/writer.rs +++ b/core/src/services/oss/writer.rs @@ -84,7 +84,7 @@ impl oio::MultipartWrite for OssWriter { StatusCode::OK => { let bs = resp.into_body().bytes().await?; - let result: InitiateMultipartResult = + let result: InitiateMultipartUploadResult = quick_xml::de::from_reader(bytes::Buf::reader(bs)) .map_err(new_xml_deserialize_error)?; @@ -133,7 +133,7 @@ impl oio::MultipartWrite for OssWriter { async fn complete_part(&self, upload_id: &str, parts: &[oio::MultipartPart]) -> Result<()> { let parts = parts .iter() - .map(|p| MultipartPart { + .map(|p| MultipartUploadPart { part_number: p.part_number, etag: p.etag.clone(), }) diff --git a/core/src/services/s3/writer.rs b/core/src/services/s3/writer.rs index 38b945d63de2..9b6b1bb6cc25 100644 --- a/core/src/services/s3/writer.rs +++ b/core/src/services/s3/writer.rs @@ -79,7 +79,7 @@ impl oio::MultipartWrite for S3Writer { StatusCode::OK => { let bs = resp.into_body().bytes().await?; - let result: InitiateMultipartResult = + let result: InitiateMultipartUploadResult = quick_xml::de::from_reader(bytes::Buf::reader(bs)) .map_err(new_xml_deserialize_error)?; @@ -131,7 +131,7 @@ impl oio::MultipartWrite for S3Writer { async fn complete_part(&self, upload_id: &str, parts: &[oio::MultipartPart]) -> Result<()> { let parts = parts .iter() - .map(|p| CompleteMultipartRequestPart { + .map(|p| CompleteMultipartUploadRequestPart { part_number: p.part_number, etag: p.etag.clone(), })