Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Shard aware batching - add Session::shard_for_statement & Batch::enforce_target_node #738

Open
wants to merge 17 commits into
base: main
Choose a base branch
from
Open

Shard aware batching - add Session::shard_for_statement & Batch::enforce_target_node #738

Changes from 1 commit
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
738b1e1
Add Session::first_shard_for_statement
Ten0 Jun 3, 2023
7ac1759
silence type-complexity lint on first_shard_for_statement
Ten0 Jun 3, 2023
20c32b8
routing_info -> routing_info_from_prepared_statement
Ten0 Jul 2, 2023
146655e
add enforce_target_node on batch
Ten0 Jul 2, 2023
6406e70
Filter that node is alive
Ten0 Jul 2, 2023
bab56d3
Merge remote-tracking branch 'upstream/main' into easier_access_to_sh…
Ten0 Jul 2, 2023
84ee6aa
less qualifying more use
Ten0 Jul 3, 2023
a651fed
fix doc being missing for ExecutionProfileHandle::load_balancing_policy
Ten0 Jul 3, 2023
128f741
Merge remote-tracking branch 'upstream/main' into easier_access_to_sh…
Ten0 Aug 5, 2023
59ced8f
wip example test
Ten0 Aug 6, 2023
a5b8b87
Merge remote-tracking branch 'upstream/main' into easier_access_to_sh…
Ten0 May 25, 2024
f81d87f
adapt after master merge
Ten0 May 25, 2024
fe8af81
test shard-awareness following pattern usage
Ten0 May 25, 2024
515417e
fix doclink
Ten0 May 25, 2024
f062b4d
Fix Cargo.lock.msrv
Ten0 May 25, 2024
10a8a86
test fixes
Ten0 May 25, 2024
d5f71a9
make test deterministic
Ten0 May 25, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions scylla/src/transport/session.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1815,6 +1815,7 @@ impl Session {
/// Get the first node/shard that the load balancer would target if running this query
///
/// This may help constituting shard-aware batches
#[allow(clippy::type_complexity)]
pub fn first_shard_for_statement(
&self,
prepared: &PreparedStatement,
Ten0 marked this conversation as resolved.
Show resolved Hide resolved
Expand Down