MCPcopy Create free account
hub / github.com/e2wugui/zeze / walk

Method walk

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2Agent.java:168–179  ·  view source on GitHub ↗
(Binary exclusiveStartKey, int proposeLimit, boolean desc, byte @Nullable [] prefix)

Source from the content-addressed store, hash-verified

166 }
167
168 public Walk walk(Binary exclusiveStartKey, int proposeLimit, boolean desc, byte @Nullable [] prefix) {
169 var r = new Walk();
170 r.Argument.setExclusiveStartKey(exclusiveStartKey);
171 r.Argument.setProposeLimit(proposeLimit);
172 r.Argument.setDesc(desc);
173 if (prefix != null)
174 r.Argument.setPrefix(new Binary(prefix));
175 r.setTimeout(config.getRpcTimeout());
176 raftClient.sendForWait(r).await();
177 // 错误在外面处理。
178 return r;
179 }
180
181 public WalkKey walkKey(Binary exclusiveStartKey, int proposeLimit, boolean desc, byte @Nullable [] prefix) {
182 var r = new WalkKey();

Callers

nothing calls this directly

Calls 8

setTimeoutMethod · 0.80
sendForWaitMethod · 0.80
awaitMethod · 0.65
setExclusiveStartKeyMethod · 0.45
setProposeLimitMethod · 0.45
setDescMethod · 0.45
setPrefixMethod · 0.45
getRpcTimeoutMethod · 0.45

Tested by

no test coverage detected