gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-30 16:59:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(ci): clear remaining merged main Clippy lints (#6616)

Browse Source
This commit is contained in:
Zhengchao An
2026-08-26 10:50:49 +08:00
committed by GitHub
parent df5ae13fd0
commit bab9049cb0
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/app/object_usecase.rs
+2 -3
View File
@@ -3275,9 +3275,8 @@ fn successful_delete_audit_objects(
.objects .objects
.iter() .iter()
.zip(successful_results) .zip(successful_results)
.filter_map(|(requested, successful)| { .filter(|(_, successful)| *successful)
successful.then(|| AuditObjectVersion::new(requested.key.clone(), requested.version_id.clone())) .map(|(requested, _)| AuditObjectVersion::new(requested.key.clone(), requested.version_id.clone()))
})
.collect() .collect()
} }
rustfs/src/connect/client.rs
+5 -3
View File
@@ -64,7 +64,7 @@ pub(crate) enum RotationAttempt {
} }
enum SingleRequest { enum SingleRequest {
Response(CredentialResponse), Response(Box<CredentialResponse>),
Unavailable { Unavailable {
status: Option<StatusCode>, status: Option<StatusCode>,
retry_after: Option<Duration>, retry_after: Option<Duration>,
@@ -329,7 +329,7 @@ impl ConnectClient {
let path = format!("clusterDevices/{}:rotateCredential", credential.uid); let path = format!("clusterDevices/{}:rotateCredential", credential.uid);
let url = self.url(&path)?; let url = self.url(&path)?;
let response = match self.send_once(StatusCode::OK, client.post(url).json(&body)).await? { let response = match self.send_once(StatusCode::OK, client.post(url).json(&body)).await? {
SingleRequest::Response(response) => response, SingleRequest::Response(response) => *response,
SingleRequest::Unavailable { status, retry_after } => { SingleRequest::Unavailable { status, retry_after } => {
return Ok(RotationAttempt::Unavailable { status, retry_after }); return Ok(RotationAttempt::Unavailable { status, retry_after });
} }
@@ -520,7 +520,9 @@ impl ConnectClient {
}; };
let status = response.status(); let status = response.status();
if status == success { if status == success {
return decode_response(response).await.map(SingleRequest::Response); return decode_response(response)
.await
.map(|response| SingleRequest::Response(Box::new(response)));
} }
if matches!(status, StatusCode::UNAUTHORIZED | StatusCode::FORBIDDEN) { if matches!(status, StatusCode::UNAUTHORIZED | StatusCode::FORBIDDEN) {
let reason = decode_reason(response).await; let reason = decode_reason(response).await;