Module scatter 

Fan-out helpers for array distributed operations.

Two entry points:

• fan_out — broadcast one request to all listed shards (slice, agg, delete, surrogate scan).
• fan_out_partitioned — send a different payload to each shard (used by coord_put where cells are routed by Hilbert prefix).

Both functions dispatch concurrently via FuturesUnordered, apply a per-shard tokio::time::timeout, and wrap each call in the cluster CircuitBreaker. Any shard failure is propagated as Err — partial results are not silently dropped.

Structs

FanOutParams

Parameters governing a single fan-out round.

FanOutPartitionedParams

Parameters for a partitioned fan-out where each shard receives a different payload. per_shard entries are (vshard_id, payload_bytes).

Functions

fan_out

Send req_bytes to every shard listed in params and collect responses.

fan_out_partitioned

Send a distinct payload to each shard and collect responses.