Struct SequencedRecord 

pub struct SequencedRecord<T> {
    pub sequence_id: u64,
    pub data: T,
}

Record with sequence ID for ordered processing

Wraps a record with a monotonically increasing sequence ID to enable deterministic output ordering even when processing happens in parallel. This is essential for maintaining data integrity when using multi-threaded record processing.

Examples

use copybook_sequence_ring::SequencedRecord;

let record1 = SequencedRecord::new(1, "first record");
let record2 = SequencedRecord::new(2, "second record");

assert_eq!(record1.sequence_id, 1);
assert_eq!(record2.data, "second record");

Fields

sequence_id: u64

Sequence number for ordering

Monotonically increasing ID assigned when record enters processing. Used to reconstruct original order after parallel processing.

data: T

The actual record data

Payload being processed (e.g., binary COBOL record, JSON value).

Implementations

impl<T> SequencedRecord<T>

pub fn new(sequence_id: u64, data: T) -> Self

Create a new sequenced record

Arguments

• sequence_id - Unique monotonic sequence number for ordering
• data - Record payload to process

Examples

use copybook_sequence_ring::SequencedRecord;

let record = SequencedRecord::new(42, vec![1, 2, 3]);
assert_eq!(record.sequence_id, 42);
assert_eq!(record.data, vec![1, 2, 3]);

Trait Implementations

impl<T: Clone> Clone for SequencedRecord<T>

fn clone(&self) -> SequencedRecord<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for SequencedRecord<T>

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

Formats the value using the given formatter.