Struct ChunkMetadata 

pub struct ChunkMetadata { /* private fields */ }

Metadata associated with a file chunk during processing

This value object encapsulates all metadata needed to track and manage chunks throughout the pipeline processing lifecycle, following DDD principles.

Key Features

• Chunk Identification: Unique identification and description
• Size Tracking: Accurate size tracking in bytes
• Integrity Verification: Checksum-based integrity checking
• Processing Context: Track processing stages and operations
• Temporal Tracking: Timestamp-based lifecycle management
• Extensible Attributes: Custom metadata through key-value attributes

Examples

Implementations

impl ChunkMetadata

pub fn new(chunk_size: usize, identifier: String) -> Result<Self, PipelineError>

Creates new chunk metadata with required fields

Arguments

• chunk_size - Size of the chunk in bytes
• identifier - Unique identifier or description for the chunk

Returns

• Result<ChunkMetadata, PipelineError> - New metadata instance or error

pub fn new_for_testing( chunk_size: usize, identifier: String, checksum: Option<String>, stage: Option<String>, ) -> Self

Creates chunk metadata with all fields for testing

pub fn chunk_size(&self) -> usize

Gets the chunk size

pub fn identifier(&self) -> &str

Gets the chunk identifier

pub fn checksum(&self) -> Option<&str>

Gets the checksum if available

pub fn stage(&self) -> Option<&str>

Gets the processing stage if available

pub fn created_at(&self) -> DateTime<Utc>

Gets the creation timestamp

pub fn with_checksum(self, checksum: String) -> Self

Sets the checksum for integrity verification

pub fn with_stage(self, stage: String) -> Self

Sets the processing stage

pub fn with_attribute(self, key: String, value: String) -> Self

Adds a custom attribute

pub fn get_attribute(&self, key: &str) -> Option<&str>

Gets a custom attribute

pub fn attributes(&self) -> &HashMap<String, String>

Gets all attributes

pub fn validate(&self) -> Result<(), PipelineError>

Validates the metadata integrity

Trait Implementations

impl Clone for ChunkMetadata

fn clone(&self) -> ChunkMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChunkMetadata

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

Formats the value using the given formatter.

impl Default for ChunkMetadata

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ChunkMetadata

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ChunkMetadata

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

Formats the value using the given formatter.

impl PartialEq for ChunkMetadata

fn eq(&self, other: &ChunkMetadata) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ChunkMetadata

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ChunkMetadata

impl StructuralPartialEq for ChunkMetadata