本文整理了Java中io.atomix.copycat.protocol.QueryRequest.sequence
方法的一些代码示例,展示了QueryRequest.sequence
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryRequest.sequence
方法的具体详情如下:
包路径:io.atomix.copycat.protocol.QueryRequest
类名称:QueryRequest
方法名:sequence
暂无
代码示例来源: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
.setTimestamp(System.currentTimeMillis())
.setSession(request.session())
.setSequence(request.sequence())
.setQuery(request.query());
代码示例来源:origin: org.onosproject/onlab-thirdparty
.setTimestamp(System.currentTimeMillis())
.setSession(request.session())
.setSequence(request.sequence())
.setQuery(request.query());
index = context.getStateMachine().getLastApplied();
} else {
index = Math.max(request.sequence(), context.getStateMachine().getLastApplied());
代码示例来源:origin: io.atomix.copycat/copycat-server
.setTimestamp(System.currentTimeMillis())
.setSession(request.session())
.setSequence(request.sequence())
.setQuery(request.query());
内容来源于网络,如有侵权,请联系作者删除!