Struct ArrayShardSliceReq 

pub struct ArrayShardSliceReq {
    pub array_id_msgpack: Vec<u8>,
    pub slice_msgpack: Vec<u8>,
    pub attr_projection: Vec<u32>,
    pub limit: u32,
    pub cell_filter_msgpack: Vec<u8>,
    pub prefix_bits: u8,
    pub slice_hilbert_ranges: Vec<(u64, u64)>,
    pub shard_hilbert_range: Option<(u64, u64)>,
    pub system_as_of: Option<i64>,
    pub valid_at_ms: Option<i64>,
}

Scatter request: coordinator asks a shard to execute a coord-range slice.

slice_msgpack is a zerompk encoding of nodedb_array::query::Slice. attr_projection is the attribute index list; empty means all attributes.

Fields

array_id_msgpack: Vec<u8>

Array scoped by tenant + name (zerompk encoding of nodedb_array::types::ArrayId).

slice_msgpack: Vec<u8>

Zerompk encoding of nodedb_array::query::Slice.

attr_projection: Vec<u32>

limit: u32

cell_filter_msgpack: Vec<u8>

Optional surrogate pre-filter bitmap bytes (zerompk encoding of SurrogateBitmap). Empty slice means no filter.

prefix_bits: u8

Prefix bits used for Hilbert routing (1–16). 0 means no routing validation.

When non-zero the shard verifies that its local_vshard_id is covered by the Hilbert ranges in slice_hilbert_ranges before executing the scan. A mismatch returns ClusterError::WrongOwner so the coordinator can retry against a refreshed routing table.

slice_hilbert_ranges: Vec<(u64, u64)>

Inclusive Hilbert-prefix ranges (lo, hi) that this slice covers, pre-computed by the coordinator from the slice predicate. Each entry is encoded as two consecutive u64 values (little-endian). Empty means unbounded (no routing validation is performed).

shard_hilbert_range: Option<(u64, u64)>

Hilbert-prefix range [lo, hi] that this shard owns. The shard applies this as a pre-filter so it only returns cells whose Hilbert prefix falls within the range. None means unbounded (return all matching cells). Used by the distributed shard handler to prevent duplicate rows in single-node harnesses where all vShards share one Data Plane.

system_as_of: Option<i64>

Bitemporal system-time cutoff forwarded from ArrayOp::Slice::system_as_of. None = live read.

valid_at_ms: Option<i64>

Bitemporal valid-time point forwarded from ArrayOp::Slice::valid_at_ms. None = no valid-time filter.

Trait Implementations

impl Clone for ArrayShardSliceReq

fn clone(&self) -> ArrayShardSliceReq

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ArrayShardSliceReq

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

Formats the value using the given formatter.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ArrayShardSliceReq

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl ToMessagePack for ArrayShardSliceReq

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.