Struct SpatialScatterGather 

pub struct SpatialScatterGather {
    pub source_node: u64,
    pub shard_ids: Vec<u16>,
    /* private fields */
}

Scatter-gather coordinator for distributed spatial queries.

Fields

source_node: u64

shard_ids: Vec<u16>

Implementations

impl SpatialScatterGather

pub fn new(source_node: u64, shard_ids: Vec<u16>) -> Self

pub fn build_scatter_envelopes( &self, collection: &str, field: &str, predicate: &str, query_geometry_json: &[u8], distance_meters: f64, limit: usize, ) -> Vec<(u16, VShardEnvelope)>

Build scatter envelopes for a spatial query.

Each envelope contains the query geometry + predicate type + distance as JSON payload.

pub fn record_response(&mut self, result: &ShardSpatialResult)

Record a shard’s response.

pub fn all_responded(&self) -> bool

Whether all shards have responded.

pub fn merge_results( &mut self, limit: usize, sort_by_distance: bool, ) -> Vec<SpatialHit>

Merge results from all shards.

pub fn response_count(&self) -> usize