Skip to content

Commit fc46ecb

Browse files
committed
kvserver: address nits in TestReplicaLifecycleDataDriven
Nits from #155143. Epic: none Release note: None
1 parent e3751cf commit fc46ecb

File tree

1 file changed

+13
-19
lines changed

1 file changed

+13
-19
lines changed

pkg/kv/kvserver/replica_lifecycle_datadriven_test.go

Lines changed: 13 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -182,9 +182,9 @@ func TestReplicaLifecycleDataDriven(t *testing.T) {
182182
return sb.String()
183183

184184
case "create-split":
185-
rangeID := dd.ScanArg[int](t, d, "range-id")
185+
rangeID := dd.ScanArg[roachpb.RangeID](t, d, "range-id")
186186
splitKey := dd.ScanArg[string](t, d, "split-key")
187-
rs := tc.mustGetRangeState(t, roachpb.RangeID(rangeID))
187+
rs := tc.mustGetRangeState(t, rangeID)
188188
desc := rs.desc
189189
require.True(
190190
t,
@@ -202,18 +202,15 @@ func TestReplicaLifecycleDataDriven(t *testing.T) {
202202
LeftDesc: leftDesc,
203203
RightDesc: rightDesc,
204204
}
205-
tc.splits[roachpb.RangeID(rangeID)] = split
205+
tc.splits[rangeID] = split
206206
return "ok"
207207

208208
case "set-lease":
209-
rangeID := dd.ScanArg[int](t, d, "range-id")
210-
replicaNodeID := dd.ScanArg[int](t, d, "replica")
211-
leaseType := "leader-lease" // default to a leader-lease
212-
if d.HasArg("lease-type") {
213-
leaseType = dd.ScanArg[string](t, d, "lease-type")
214-
}
215-
rs := tc.mustGetRangeState(t, roachpb.RangeID(rangeID))
216-
targetReplica := rs.getReplicaDescriptor(t, roachpb.NodeID(replicaNodeID))
209+
rangeID := dd.ScanArg[roachpb.RangeID](t, d, "range-id")
210+
replicaNodeID := dd.ScanArg[roachpb.NodeID](t, d, "replica")
211+
leaseType := dd.ScanArgOr(t, d, "lease-type", "leader-lease")
212+
rs := tc.mustGetRangeState(t, rangeID)
213+
targetReplica := rs.getReplicaDescriptor(t, replicaNodeID)
217214
// NB: The details of the lease are not important to the test;
218215
// only the type is.
219216
var lease roachpb.Lease
@@ -241,10 +238,10 @@ func TestReplicaLifecycleDataDriven(t *testing.T) {
241238
return "ok"
242239

243240
case "run-split-trigger":
244-
rangeID := dd.ScanArg[int](t, d, "range-id")
245-
split, ok := tc.splits[roachpb.RangeID(rangeID)]
241+
rangeID := dd.ScanArg[roachpb.RangeID](t, d, "range-id")
242+
split, ok := tc.splits[rangeID]
246243
require.True(t, ok, "split trigger not found for range-id %d", rangeID)
247-
rs := tc.mustGetRangeState(t, roachpb.RangeID(rangeID))
244+
rs := tc.mustGetRangeState(t, rangeID)
248245
desc := rs.desc
249246
batch := tc.storage.NewBatch()
250247
defer batch.Close()
@@ -272,7 +269,7 @@ func TestReplicaLifecycleDataDriven(t *testing.T) {
272269

273270
// Update the test context's notion of the range state after the
274271
// split.
275-
tc.updatePostSplitRangeState(t, ctx, batch, roachpb.RangeID(rangeID), split)
272+
tc.updatePostSplitRangeState(t, ctx, batch, rangeID, split)
276273
// Print the state of the batch (all keys/values written as part
277274
// of the split trigger).
278275
output, err := print.DecodeWriteBatch(batch.Repr())
@@ -292,10 +289,7 @@ func TestReplicaLifecycleDataDriven(t *testing.T) {
292289
return "no ranges in test context"
293290
}
294291

295-
sortByKeys := false
296-
if d.HasArg("sort-keys") {
297-
sortByKeys = dd.ScanArg[bool](t, d, "sort-keys")
298-
}
292+
sortByKeys := dd.ScanArgOr(t, d, "sort-keys", false)
299293

300294
rangeIDs := maps.Keys(tc.ranges)
301295
slices.SortFunc(rangeIDs, func(a, b roachpb.RangeID) int {

0 commit comments

Comments
 (0)