5 commented on code in PR #198:
URL: https://github.com/apache/cassandra-sidecar/pull/198#discussion_r1987923135
##########
client/src/main/java/org/apache/cassandra/sidecar/client/SidecarClient.java:
##########
@@ -567,6 +566,28 @@ public void streamCdcSegments(SidecarInstance
sidecarInstance,
.build(), streamConsumer);
}
+ /**
+ * Sends a request to trigger an immediate, synchronous schema
+ * conversion and report on the specified instance of the Sidecar
+ * regardless of the periodic task schedule or status
+ *
+ * @param instance the {@link SidecarInstance} to receive the request
+ * @return a {@link CompletableFuture} for the request
+ */
+ public CompletableFuture<Void> reportSchema(SidecarInstance instance)
+ {
+ // Create an instance of {@link RequestContext.Builder} using its
+ // constructor instead of the {@link this.requestBuilder()} method,
+ // since {@link NoRetryPolicy} is the preferred behavior here
+
+ RequestContext context = new RequestContext.Builder()
+ .singleInstanceSelectionPolicy(instance)
+ .reportSchemaRequest()
+ .build();
+
+ return executor.executeRequestAsync(context);
Review Comment:
Added a convenience method for policy overrides following the existing
pattern.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
