diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-08-30 14:54:52 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-08-30 14:54:52 +0200 |
| commit | 7200954318a1b248b4194ee9273bcd2502b50d58 (patch) | |
| tree | 1e1d6d702c212f8272209159a857b4931c1a148e /src/model/s3/lifecycle_worker.rs | |
| parent | 0f1849e1ac882f5f88fe341549f0e7f01a1a7b70 (diff) | |
| download | garage-7200954318a1b248b4194ee9273bcd2502b50d58.tar.gz garage-7200954318a1b248b4194ee9273bcd2502b50d58.zip | |
lifecycle worker: add logging
Diffstat (limited to 'src/model/s3/lifecycle_worker.rs')
| -rw-r--r-- | src/model/s3/lifecycle_worker.rs | 8 |
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?; |