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

QueryRequest.index介绍

[英]Returns the query index.
[中]返回查询索引。

代码示例

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

@Override
public CompletableFuture<QueryResponse> query(final QueryRequest request) {
 Query query = request.query();
 final long timestamp = System.currentTimeMillis();
 context.checkThread();
 logRequest(request);
 QueryEntry entry = context.getLog().create(QueryEntry.class)
  .setIndex(request.index())
  .setTerm(context.getTerm())
  .setTimestamp(timestamp)
  .setSession(request.session())
  .setSequence(request.sequence())
  .setQuery(query);
 return query(entry).thenApply(this::logResponse);
}

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

@Override
public CompletableFuture<QueryResponse> query(final QueryRequest request) {
 Query query = request.query();
 final long timestamp = System.currentTimeMillis();
 context.checkThread();
 logRequest(request);
 QueryEntry entry = context.getLog().create(QueryEntry.class)
  .setIndex(request.index())
  .setTerm(context.getTerm())
  .setTimestamp(timestamp)
  .setSession(request.session())
  .setSequence(request.sequence())
  .setQuery(query);
 return query(entry).thenApply(this::logResponse);
}

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

@Override
protected CompletableFuture<QueryResponse> query(final QueryRequest request) {
 Query query = request.query();
 final long timestamp = System.currentTimeMillis();
 context.checkThread();
 logRequest(request);
 QueryEntry entry = context.getLog().create(QueryEntry.class)
  .setIndex(request.index())
  .setTerm(context.getTerm())
  .setTimestamp(timestamp)
  .setSession(request.session())
  .setSequence(request.sequence())
  .setQuery(query);
 Query.ConsistencyLevel consistency = query.consistency();
 if (consistency == null)
  return submitQueryLinearizable(entry);
 switch (consistency) {
  case CAUSAL:
  case SEQUENTIAL:
   return submitQueryLocal(entry);
  case BOUNDED_LINEARIZABLE:
   return submitQueryBoundedLinearizable(entry);
  case LINEARIZABLE:
   return submitQueryLinearizable(entry);
  default:
   throw new IllegalStateException("unknown consistency level");
 }
}

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

.setIndex(request.index())
.setTerm(context.getTerm())
.setTimestamp(System.currentTimeMillis())

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

.setIndex(request.index())
.setTerm(context.getTerm())
.setTimestamp(System.currentTimeMillis())

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

.setIndex(request.index())
.setTerm(context.getTerm())
.setTimestamp(System.currentTimeMillis())