Struct VectorScatterGather 

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

Scatter-gather coordinator for distributed k-NN vector search.

Fields

source_node: u64

Source node ID (this coordinator’s node).

shard_ids: Vec<u32>

Target shard IDs to fan out to.

Implementations

impl VectorScatterGather

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

pub fn build_scatter_envelopes( &self, collection: &str, query_vector: &[f32], top_k: usize, ef_search: usize, filter_bitmap: Option<&[u8]>, ) -> Vec<(u32, VShardEnvelope)>

Build scatter envelopes for a k-NN search query.

Returns one VShardEnvelope per shard. Each contains the query vector + parameters as JSON payload.

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

Record a shard’s response.

pub fn all_responded(&self) -> bool

Whether all shards have responded.

pub fn merge_top_k(&mut self, top_k: usize) -> Vec<VectorHit>

Merge all shard results and return the global top-K.

pub fn response_count(&self) -> usize

Number of shards that have responded.