Struct PipelineData 

pub struct PipelineData {
    pub buffer: Arc<ZeroCopyBuffer>,
    pub metadata: PipelineMetadata,
    pub stage: PipelineStage,
    pub segments: Vec<SegmentView>,
}

Zero-copy pipeline data flowing between stages

Fields

buffer: Arc<ZeroCopyBuffer>

Core data buffer with zero-copy views

metadata: PipelineMetadata

Metadata about the data

stage: PipelineStage

Current processing stage

segments: Vec<SegmentView>

Segment views for different data types

Implementations

impl PipelineData

pub fn new(capacity: usize) -> Self

pub fn add_segment(&mut self, segment: SegmentView)

Add a segment view without copying data

pub fn create_view(&self, offset: usize, length: usize) -> Result<SegmentView>

Create a new view of existing data

pub fn total_size(&self) -> usize

Get total data size across all segments

pub fn advance_stage(&mut self, stage: PipelineStage)

Advance to next pipeline stage

Trait Implementations

impl Clone for PipelineData

fn clone(&self) -> PipelineData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineData

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

Formats the value using the given formatter.