Struct SegmentData 

pub struct SegmentData { /* private fields */ }

Available on crate feature pipeline only.

Data flowing through the processor pipeline.

The driver reads the sealed segment into payload, populates initial metadata, then passes this through each SegmentProcessor in order.

SegmentData is intentionally !Clone: it is moved through the pipeline and dropped exactly once, which is crucial for in-flight byte accounting (a single Drop decrements the counters).

Implementations

impl SegmentData

pub fn segment(&self) -> &SegmentRef

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 set_compressed_size(&mut self, bytes: u64)

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

pub fn compressed_size(&self) -> Option<u64>

The post-compression size reported by a processor, if any.

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 adjust_accounting(&mut self)

Update memory-mode in-flight accounting to the current payload size. No-op for disk-backed segments.

Trait Implementations

impl Debug for SegmentData

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

Formats the value using the given formatter.