(Binary exclusiveStartKey, int proposeLimit, boolean desc, byte @Nullable [] prefix)
| 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 | } |
nothing calls this directly
no test coverage detected