qubit-batch 0.8.1

One-shot batch execution and processing with sequential and scoped parallel utilities
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

/*******************************************************************************
 *
 *    Copyright (c) 2025 - 2026 Haixing Hu.
 *
 *    SPDX-License-Identifier: Apache-2.0
 *
 *    Licensed under the Apache License, Version 2.0.
 *
 ******************************************************************************/
use thiserror::Error;

/// Error returned when constructing a batch outcome with invalid counters.
///
/// ```rust
/// use qubit_batch::{
///     BatchOutcomeBuildError,
///     BatchOutcomeBuilder,
/// };
///
/// let error = BatchOutcomeBuilder::<&'static str>::builder(1)
///     .completed_count(2)
///     .succeeded_count(2)
///     .build()
///     .expect_err("completed count should not exceed declared task count");
///
/// assert!(matches!(
///     error,
///     BatchOutcomeBuildError::CompletedCountExceeded { .. }
/// ));
/// ```
#[derive(Debug, Clone, Error, PartialEq, Eq)]
pub enum BatchOutcomeBuildError {
    /// The completed task count is greater than the declared task count.
    #[error(
        "completed task count must not exceed declared task count: task_count {task_count}, completed_count {completed_count}"
    )]
    CompletedCountExceeded {
        /// Declared task count.
        task_count: usize,
        /// Number of completed tasks.
        completed_count: usize,
    },

    /// Adding failed and panicked task counts overflowed.
    #[error(
        "failed and panicked task counts must not overflow: failed_count {failed_count}, panicked_count {panicked_count}"
    )]
    FailureCountOverflow {
        /// Number of tasks that returned their own error.
        failed_count: usize,
        /// Number of tasks that panicked.
        panicked_count: usize,
    },

    /// Adding successful and failed task counts overflowed.
    #[error(
        "terminal task counts must not overflow: succeeded_count {succeeded_count}, failure_count {failure_count}"
    )]
    TerminalCountOverflow {
        /// Number of successful tasks.
        succeeded_count: usize,
        /// Number of failed or panicked tasks.
        failure_count: usize,
    },

    /// Completed tasks do not equal successful plus failed plus panicked tasks.
    #[error(
        "completed task count must equal succeeded + failed + panicked counts: completed_count {completed_count}, terminal_count {terminal_count}"
    )]
    TerminalCountMismatch {
        /// Number of completed tasks.
        completed_count: usize,
        /// Number of successful, failed, and panicked tasks combined.
        terminal_count: usize,
        /// Number of successful tasks.
        succeeded_count: usize,
        /// Number of tasks that returned their own error.
        failed_count: usize,
        /// Number of tasks that panicked.
        panicked_count: usize,
    },

    /// Detailed failure records do not match the aggregate failure count.
    #[error(
        "failure detail count must equal failed + panicked counts: expected {expected}, actual {actual}"
    )]
    FailureDetailCountMismatch {
        /// Expected number of failure details.
        expected: usize,
        /// Actual number of failure details.
        actual: usize,
    },

    /// A failure detail index is outside the declared task range.
    #[error(
        "failure index must be less than declared task count: index {index}, task_count {task_count}"
    )]
    FailureIndexOutOfRange {
        /// Out-of-range failure index.
        index: usize,
        /// Declared task count.
        task_count: usize,
    },

    /// Multiple failure details refer to the same task index.
    #[error("failure index must be unique: index {index}")]
    DuplicateFailureIndex {
        /// Duplicate failure index.
        index: usize,
    },

    /// Detailed failure variants do not match failed and panicked counters.
    #[error(
        "failure detail variants must match failed_count and panicked_count: expected_failed {expected_failed}, actual_failed {actual_failed}, expected_panicked {expected_panicked}, actual_panicked {actual_panicked}"
    )]
    FailureVariantCountMismatch {
        /// Expected number of business failure details.
        expected_failed: usize,
        /// Actual number of business failure details.
        actual_failed: usize,
        /// Expected number of panic failure details.
        expected_panicked: usize,
        /// Actual number of panic failure details.
        actual_panicked: usize,
    },
}