本文整理了Java中io.atomix.copycat.protocol.QueryRequest.builder方法的一些代码示例，展示了QueryRequest.builder的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryRequest.builder方法的具体详情如下：
包路径：io.atomix.copycat.protocol.QueryRequest
类名称：QueryRequest
方法名：builder

QueryRequest.builder介绍

[英]Returns a new query request builder.
[中]返回一个新的查询请求生成器。

代码示例

代码示例来源：origin: io.atomix.copycat/copycat-client

/**
 * Submits a query to the cluster.
 */
private <T> void submitQuery(Query<T> query, CompletableFuture<T> future) {
 QueryRequest request = QueryRequest.builder()
  .withSession(state.getSessionId())
  .withSequence(state.getCommandRequest())
  .withIndex(state.getResponseIndex())
  .withQuery(query)
  .build();
 submitQuery(request, future);
}

代码示例来源：origin: atomix/copycat

/**
 * Submits a query to the cluster.
 */
private <T> void submitQuery(Query<T> query, CompletableFuture<T> future) {
 QueryRequest request = QueryRequest.builder()
  .withSession(state.getSessionId())
  .withSequence(state.getCommandRequest())
  .withIndex(state.getResponseIndex())
  .withQuery(query)
  .build();
 submitQuery(request, future);
}

代码示例来源：origin: atomix/copycat

public void testQueryWithoutLeader() throws Throwable {
 runOnServer(() -> {
  QueryRequest request = QueryRequest.builder().withSession(1).withQuery(new TestQuery()).build();
  QueryResponse response = state.query(request).get();
  assertNoLeaderError(response);
 });
}

代码示例来源：origin: org.onosproject/onlab-thirdparty

/**
 * Submits a query to the cluster.
 */
private <T> void submitQuery(Query<T> query, CompletableFuture<T> future) {
 if (query.consistency() == Query.ConsistencyLevel.CAUSAL) {
  QueryRequest request = QueryRequest.builder()
   .withSession(state.getSessionId())
   .withSequence(state.getCommandResponse())
   .withIndex(state.getResponseIndex())
   .withQuery(query)
   .build();
  submitQuery(request, future);
 } else {
  QueryRequest request = QueryRequest.builder()
   .withSession(state.getSessionId())
   .withSequence(state.getCommandRequest())
   .withIndex(state.getResponseIndex())
   .withQuery(query)
   .build();
  submitQuery(request, future);
 }
}