Struct PendingRow 

pub struct PendingRow {
    pub row_id: RowId,
    pub timepoint: TimePoint,
    pub components: HashMap<ComponentIdentifier, SerializedComponentBatch, BuildHasherDefault<NoHashHasher<ComponentIdentifier>>>,
}

A single row’s worth of data (i.e. a single log call).

Send those to the batcher to build up a Chunk.

Fields

row_id: RowId

Auto-generated TUID, uniquely identifying this event and keeping track of the client’s wall-clock.

timepoint: TimePoint

User-specified TimePoint for this event.

components: HashMap<ComponentIdentifier, SerializedComponentBatch, BuildHasherDefault<NoHashHasher<ComponentIdentifier>>>

The component data.

Each array is a single component, i.e. not a list array.

Implementations

impl PendingRow

pub fn new( timepoint: TimePoint, components: HashMap<ComponentIdentifier, SerializedComponentBatch, BuildHasherDefault<NoHashHasher<ComponentIdentifier>>>, ) -> PendingRow

pub fn from_iter( timepoint: TimePoint, components: impl IntoIterator<Item = SerializedComponentBatch>, ) -> PendingRow

impl PendingRow

pub fn into_chunk(self, entity_path: EntityPath) -> Result<Chunk, ChunkError>

Turn a single row into a Chunk of its own.

That’s very wasteful, probably don’t do that outside of testing, or unless you have very good reasons too.

See also Self::many_into_chunks.

pub fn many_into_chunks( entity_path: EntityPath, chunk_max_rows_if_unsorted: u64, rows: Vec<PendingRow>, ) -> impl Iterator<Item = Result<Chunk, ChunkError>>

This turns a batch of PendingRows into a Chunk.

There are a lot of conditions to fulfill for a Chunk to be valid: this helper makes sure to fulfill all of them by splitting the chunk into one or more pieces as necessary.

In particular, a Chunk cannot:

• contain data for more than one entity path
• contain rows with different sets of timelines
• use more than one datatype for a given component
• contain more rows than a pre-configured threshold if one or more timelines are unsorted

Trait Implementations

impl Clone for PendingRow

fn clone(&self) -> PendingRow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingRow

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

Formats the value using the given formatter.

impl SizeBytes for PendingRow

const IS_POD: bool

fn heap_size_bytes(&self) -> u64

Returns how many bytes self uses on the heap.

fn total_size_bytes(&self) -> u64

Returns the total size of self in bytes, accounting for both stack and heap space.

fn stack_size_bytes(&self) -> u64

Returns the total size of self on the stack, in bytes.