Skip to main content

nodedb_cluster/distributed_array/
mod.rs

1// SPDX-License-Identifier: BUSL-1.1
2
3pub mod coordinator;
4pub mod handler;
5pub mod local_executor;
6pub mod merge;
7pub mod opcodes;
8pub mod partition;
9pub mod routing;
10pub mod rpc;
11pub mod scatter;
12pub mod wire;
13
14pub use coordinator::{
15    ArrayCoordinator, ArrayWriteCoordParams, CoordSliceResult, coord_delete, coord_put,
16    coord_put_partitioned,
17};
18pub use handler::handle_array_shard_rpc;
19pub use local_executor::ArrayLocalExecutor;
20pub use merge::{
21    ArrayAggPartial, any_truncated_before_horizon_agg, any_truncated_before_horizon_slice,
22    merge_slice_rows, reduce_agg_partials,
23};
24pub use routing::{array_vshard_for_tile, array_vshards_for_slice};
25pub use rpc::ShardRpcDispatch;
26pub use wire::{
27    ArrayShardAggReq, ArrayShardAggResp, ArrayShardDeleteReq, ArrayShardDeleteResp,
28    ArrayShardPutReq, ArrayShardPutResp, ArrayShardSliceReq, ArrayShardSliceResp,
29    ArrayShardSurrogateBitmapReq, ArrayShardSurrogateBitmapResp,
30};