Skip to main content

Module distributed_array

Module distributed_array 

Source

Re-exports§

pub use coordinator::ArrayCoordinator;
pub use coordinator::ArrayWriteCoordParams;
pub use coordinator::CoordSliceResult;
pub use coordinator::coord_delete;
pub use coordinator::coord_put;
pub use coordinator::coord_put_partitioned;
pub use handler::handle_array_shard_rpc;
pub use local_executor::ArrayLocalExecutor;
pub use merge::ArrayAggPartial;
pub use merge::any_truncated_before_horizon_agg;
pub use merge::any_truncated_before_horizon_slice;
pub use merge::merge_slice_rows;
pub use merge::reduce_agg_partials;
pub use routing::array_vshard_for_tile;
pub use routing::array_vshards_for_slice;
pub use rpc::ShardRpcDispatch;
pub use wire::ArrayShardAggReq;
pub use wire::ArrayShardAggResp;
pub use wire::ArrayShardDeleteReq;
pub use wire::ArrayShardDeleteResp;
pub use wire::ArrayShardPutReq;
pub use wire::ArrayShardPutResp;
pub use wire::ArrayShardSliceReq;
pub use wire::ArrayShardSliceResp;
pub use wire::ArrayShardSurrogateBitmapReq;
pub use wire::ArrayShardSurrogateBitmapResp;

Modules§

coordinator
handler
Shard-side RPC handler for incoming array operations.
local_executor
Local Data-Plane execution trait for array shard operations.
merge
Merge functions for distributed array query results.
opcodes
VShardMessageType discriminant constants for array shard RPCs.
partition
Cell-to-tile partitioning for distributed array writes.
routing
vShard routing for array tiles.
rpc
RPC dispatch trait for array shard fan-out.
scatter
Fan-out helpers for array distributed operations.
wire
Wire types for array shard RPC messages.