Struct SegmentData 

pub struct SegmentData { /* private fields */ }

Available on crate feature dial9 only.

Data flowing through the processor pipeline.

The worker reads the sealed segment file into payload, populates initial metadata, then passes this through each SegmentProcessor in order. Metrics are flushed automatically when the SegmentData is dropped.

Implementations

impl SegmentData

pub fn segment(&self) -> &SealedSegment

Information about the sealed segment being processed.

pub fn payload(&self) -> &Payload

Current payload (raw, symbolized, compressed, etc.).

pub fn take_payload(&mut self) -> Payload

Take ownership of the payload, leaving an empty Payload in its place.

pub fn set_payload(&mut self, payload: impl Into<Payload>)

Replace the payload.

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

Metadata accumulated by upstream processors.

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

Mutable reference to the metadata map. Processors can insert keys (e.g. "content_encoding", "write_back_extension") to signal downstream stages.

pub fn set_compressed_size(&mut self, bytes: u64)

Record the segment’s post-compression size. Surfaces as the CompressedSize metric for this segment.

Trait Implementations

impl Debug for SegmentData

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

Formats the value using the given formatter.