Struct BatchItem 

pub struct BatchItem<D>
where
    D: Clone + Send + Sync + Serialize,
{
    pub id: String,
    pub data: D,
    pub status: BatchItemStatus,
    pub error: Option<String>,
    pub duration_ms: Option<u64>,
    pub size_bucket: SizeBucket,
    pub trace_ctx: Option<TraceCtx>,
    pub attempt_id: Option<AttemptId>,
    pub trial_id: Option<TrialId>,
}

A single item within a batch job.

The data field carries user-defined per-item payload (e.g. file path, image ID, document reference). It must be serializable for event emission.

Trace context

Optional trace_ctx propagates cross-crate observability context from stack-ids. The attempt_id identifies the logical retry family for this batch-item (distinct from any outer job-level retry). The trial_id tracks each concrete execution attempt within that family.

Fields

id: String

Unique identifier for this item within the batch.

data: D

User-defined data payload.

status: BatchItemStatus

Current processing status.

error: Option<String>

Error message if status is Failed.

duration_ms: Option<u64>

Processing duration in milliseconds (set after completion).

size_bucket: SizeBucket

Size bucket for ETA estimation.

trace_ctx: Option<TraceCtx>

Cross-crate trace context for observability propagation.

attempt_id: Option<AttemptId>

Logical retry family for this batch-item.

One AttemptId per retry-owner boundary. Batch-item retries (via retry_failed) produce new TrialIds under the same AttemptId, keeping them distinguishable from outer job-level retries.

trial_id: Option<TrialId>

Concrete execution identifier within the current retry family.

Minted fresh on each processing attempt. Allows correlating logs, metrics, and errors to a specific execution without ambiguity.

Trait Implementations

impl<D> Clone for BatchItem<D>

where D: Clone + Send + Sync + Serialize + Clone,

fn clone(&self) -> BatchItem<D>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<D> Debug for BatchItem<D>

where D: Clone + Send + Sync + Serialize + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, D> Deserialize<'de> for BatchItem<D>

where D: Clone + Send + Sync + Serialize + Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<D> Serialize for BatchItem<D>

where D: Clone + Send + Sync + Serialize + Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.