aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-08-30 14:54:52 +0200
committerAlex Auvolat <alex@adnab.me>2023-08-30 14:54:52 +0200
commit7200954318a1b248b4194ee9273bcd2502b50d58 (patch)
tree1e1d6d702c212f8272209159a857b4931c1a148e /src
parent0f1849e1ac882f5f88fe341549f0e7f01a1a7b70 (diff)
downloadgarage-7200954318a1b248b4194ee9273bcd2502b50d58.tar.gz
garage-7200954318a1b248b4194ee9273bcd2502b50d58.zip
lifecycle worker: add logging
Diffstat (limited to 'src')
-rw-r--r--src/model/s3/lifecycle_worker.rs8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/model/s3/lifecycle_worker.rs b/src/model/s3/lifecycle_worker.rs
index 1981e0fd..02e296e7 100644
--- a/src/model/s3/lifecycle_worker.rs
+++ b/src/model/s3/lifecycle_worker.rs
@@ -282,6 +282,10 @@ async fn process_object(
state: ObjectVersionState::Complete(ObjectVersionData::DeleteMarker),
}],
);
+ info!(
+ "Lifecycle: expiring 1 object in bucket {:?}",
+ object.bucket_id
+ );
garage.object_table.insert(&deleted_object).await?;
*objects_expired += 1;
}
@@ -311,6 +315,10 @@ async fn process_object(
if !aborted_versions.is_empty() {
// Insert aborted mpu info
let n_aborted = aborted_versions.len();
+ info!(
+ "Lifecycle: aborting {} incomplete upload(s) in bucket {:?}",
+ n_aborted, object.bucket_id
+ );
let aborted_object =
Object::new(object.bucket_id, object.key.clone(), aborted_versions);
garage.object_table.insert(&aborted_object).await?;