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

Method walkKey

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

Source from the content-addressed store, hash-verified

179 }
180
181 public WalkKey walkKey(Binary exclusiveStartKey, int proposeLimit, boolean desc, byte @Nullable [] prefix) {
182 var r = new WalkKey();
183 r.Argument.setExclusiveStartKey(exclusiveStartKey);
184 r.Argument.setProposeLimit(proposeLimit);
185 r.Argument.setDesc(desc);
186 if (prefix != null)
187 r.Argument.setPrefix(new Binary(prefix));
188 r.setTimeout(config.getRpcTimeout());
189 raftClient.sendForWait(r).await();
190 // 错误在外面处理。
191 return r;
192 }
193}

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