Skip to content

Commit b789772

Browse files
committed
pager: rename statement_info to routing_info
The field `statement_info` in `PagerWorker` was not renamed when `RoutingInfo` was renamed from `StatementInfo`. This commit renames the field to `routing_info` to align with the new name of the type.
1 parent dd05ce4 commit b789772

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

scylla/src/client/pager.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ struct PagerWorker<'a, QueryFunc, SpanCreatorFunc> {
144144
page_query: QueryFunc,
145145

146146
load_balancing_policy: Arc<dyn LoadBalancingPolicy>,
147-
statement_info: RoutingInfo<'a>,
147+
routing_info: RoutingInfo<'a>,
148148
query_is_idempotent: bool,
149149
query_consistency: Consistency,
150150
retry_session: Box<dyn RetrySession>,
@@ -170,7 +170,7 @@ where
170170
// Contract: this function MUST send at least one item through self.sender
171171
async fn work(mut self, cluster_state: Arc<ClusterState>) -> PageSendAttemptedProof {
172172
let load_balancer = Arc::clone(&self.load_balancing_policy);
173-
let statement_info = self.statement_info.clone();
173+
let statement_info = self.routing_info.clone();
174174
let query_plan =
175175
load_balancing::Plan::new(load_balancer.as_ref(), &statement_info, &cluster_state);
176176

@@ -359,7 +359,7 @@ where
359359
self.log_attempt_success();
360360
self.log_request_success();
361361
self.load_balancing_policy
362-
.on_request_success(&self.statement_info, elapsed, node);
362+
.on_request_success(&self.routing_info, elapsed, node);
363363

364364
request_span.record_raw_rows_fields(&rows);
365365

@@ -396,7 +396,7 @@ where
396396
#[cfg(feature = "metrics")]
397397
self.metrics.inc_failed_paged_queries();
398398
self.load_balancing_policy.on_request_failure(
399-
&self.statement_info,
399+
&self.routing_info,
400400
elapsed,
401401
node,
402402
&err,
@@ -424,7 +424,7 @@ where
424424
let err =
425425
RequestAttemptError::UnexpectedResponse(response.response.to_response_kind());
426426
self.load_balancing_policy.on_request_failure(
427-
&self.statement_info,
427+
&self.routing_info,
428428
elapsed,
429429
node,
430430
&err,
@@ -786,7 +786,7 @@ If you are using this API, you are probably doing something wrong."
786786
let worker = PagerWorker {
787787
sender: sender.into(),
788788
page_query,
789-
statement_info: routing_info,
789+
routing_info,
790790
query_is_idempotent: statement.config.is_idempotent,
791791
query_consistency: consistency,
792792
load_balancing_policy,
@@ -914,7 +914,7 @@ If you are using this API, you are probably doing something wrong."
914914
let worker = PagerWorker {
915915
sender: sender.into(),
916916
page_query,
917-
statement_info,
917+
routing_info: statement_info,
918918
query_is_idempotent: config.prepared.config.is_idempotent,
919919
query_consistency: consistency,
920920
load_balancing_policy,

0 commit comments

Comments
 (0)