Enum DataBatch 

pub enum DataBatch {
    Instrument(BatchView<InstrumentAny>),
    BookDelta(BatchView<OrderBookDelta>),
    BookDeltas(BatchView<OrderBookDeltas>),
    BookDepth(BatchView<OrderBookDepth>),
    Quote(BatchView<QuoteTick>),
    Trade(BatchView<TradeTick>),
    Bar(BatchView<Bar>),
    MarkPrice(BatchView<MarkPriceUpdate>),
    IndexPrice(BatchView<IndexPriceUpdate>),
    FundingRate(BatchView<FundingRateUpdate>),
    OptionGreeks(BatchView<OptionGreeks>),
    InstrumentStatus(BatchView<InstrumentStatus>),
    InstrumentClose(BatchView<InstrumentClose>),
    Custom(BatchView<CustomData>),
    Defi(BatchView<DefiData>),
}

Shared typed batch used by replay and catalog fan-out paths.

Variants

Instrument(BatchView<InstrumentAny>)

BookDelta(BatchView<OrderBookDelta>)

BookDeltas(BatchView<OrderBookDeltas>)

BookDepth(BatchView<OrderBookDepth>)

Quote(BatchView<QuoteTick>)

Trade(BatchView<TradeTick>)

Bar(BatchView<Bar>)

MarkPrice(BatchView<MarkPriceUpdate>)

IndexPrice(BatchView<IndexPriceUpdate>)

FundingRate(BatchView<FundingRateUpdate>)

OptionGreeks(BatchView<OptionGreeks>)

InstrumentStatus(BatchView<InstrumentStatus>)

InstrumentClose(BatchView<InstrumentClose>)

Custom(BatchView<CustomData>)

Defi(BatchView<DefiData>)

Implementations

impl DataBatch

pub fn from_data_vec_for_type( data_type: &NautilusDataType, data: Vec<Data>, ) -> Result<Self>

Converts owned compatibility rows into a typed batch for data_type.

This is a transition path for backends that still decode through Data but should not expose legacy batches to typed replay.

Errors

Returns an error if data_type is not replayable as a typed batch.

pub fn from_data_vec_grouped(data: &[Data]) -> Result<Vec<Self>>

Groups mixed compatibility rows into typed batches.

Data::BookDeltas values retain their event-batch boundary in a separate typed batch.

Errors

Returns an error if a row cannot be represented by a typed batch.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn data_type_name(&self) -> &'static str

Returns the storage-family name of this batch’s data type.

pub fn is_monotonically_increasing_by_init(&self) -> bool

pub fn get(&self, index: usize) -> Option<DataRef<'_>>

pub fn aligned_chunk( &self, start: usize, chunk_size: Option<usize>, ) -> Option<(Self, usize)>

pub fn slice(&self, start: usize, end: usize) -> Self

pub fn to_data_vec_for_compat(&self) -> Vec<Data>

Trait Implementations

impl Clone for DataBatch

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataBatch

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

Formats the value using the given formatter.

impl<T: IntoDataBatch> From<Vec<T>> for DataBatch

fn from(data: Vec<T>) -> Self

Converts to this type from the input type.