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

test(ilm): cover queue-full terminal job records (#5310)

Browse Source 
Co-authored-by: heihutu <heihutu@gmail.com>
This commit is contained in:
houseme
2026-07-27 01:11:47 +08:00
committed by GitHub
parent 683ff52a7b
commit e79337bb5c
1 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/bucket/lifecycle/bucket_lifecycle_ops.rs
+19 -3
View File
@@ -7575,13 +7575,27 @@ mod tests {
} }
#[test] #[test]
fn manual_transition_job_record_closed_and_timeout_reports_are_partial() { fn manual_transition_job_record_queue_pressure_reports_are_partial() {
let options = ManualTransitionRunOptions::default(); let options = ManualTransitionRunOptions::default();
for (bucket, outcome, skipped_queue_closed, skipped_queue_timeout, queue_snapshot) in [ for (bucket, outcome, skipped_queue_full, skipped_queue_closed, skipped_queue_timeout, queue_snapshot) in [
(
"manual-queue-full-bucket",
TransitionEnqueueOutcome::QueueFull,
1,
0,
0,
ManualTransitionQueueSnapshot {
queue_capacity: 1,
workers: 1,
queue_full: 1,
..Default::default()
},
),
( (
"manual-queue-closed-bucket", "manual-queue-closed-bucket",
TransitionEnqueueOutcome::QueueClosed, TransitionEnqueueOutcome::QueueClosed,
0,
1, 1,
0, 0,
ManualTransitionQueueSnapshot { ManualTransitionQueueSnapshot {
@@ -7594,6 +7608,7 @@ mod tests {
"manual-queue-timeout-bucket", "manual-queue-timeout-bucket",
TransitionEnqueueOutcome::QueueSendTimedOut, TransitionEnqueueOutcome::QueueSendTimedOut,
0, 0,
0,
1, 1,
ManualTransitionQueueSnapshot { ManualTransitionQueueSnapshot {
queue_capacity: 1, queue_capacity: 1,
@@ -7612,9 +7627,10 @@ mod tests {
assert_eq!(record.state, ManualTransitionJobState::Partial); assert_eq!(record.state, ManualTransitionJobState::Partial);
assert_eq!(record.report.enqueued, 0); assert_eq!(record.report.enqueued, 0);
assert_eq!(record.report.skipped_queue_full, 0); assert_eq!(record.report.skipped_queue_full, skipped_queue_full);
assert_eq!(record.report.skipped_queue_closed, skipped_queue_closed); assert_eq!(record.report.skipped_queue_closed, skipped_queue_closed);
assert_eq!(record.report.skipped_queue_timeout, skipped_queue_timeout); assert_eq!(record.report.skipped_queue_timeout, skipped_queue_timeout);
assert_eq!(record.queue_snapshot.queue_full, queue_snapshot.queue_full);
assert_eq!(record.queue_snapshot.queue_send_timeout, queue_snapshot.queue_send_timeout); assert_eq!(record.queue_snapshot.queue_send_timeout, queue_snapshot.queue_send_timeout);
assert!(record.completed_at_unix_nanos.is_some()); assert!(record.completed_at_unix_nanos.is_some());
assert!(record.error.is_none()); assert!(record.error.is_none());