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(), })