Skip to content

Commit 77b2d9a

Browse files
committed
kvserver: rename & unexport RangeID iterator
Epic: none Release note: none
1 parent c4912f0 commit 77b2d9a

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

pkg/kv/kvserver/kvstorage/init.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -148,14 +148,14 @@ func checkCanInitializeEngine(ctx context.Context, eng storage.Engine) error {
148148
type readKeyFn func(roachpb.Key, protoutil.Message) (bool, error)
149149
type scanRangeIDFn func(roachpb.RangeID, readKeyFn) error
150150

151-
// IterateIDPrefixKeys helps visit system keys that use RangeID prefixing (such
151+
// iterateRangeIDKeys helps visit system keys that use RangeID prefixing (such
152152
// as RaftHardStateKey, RangeTombstoneKey, and many others). Such keys could in
153153
// principle exist at any RangeID, and this helper efficiently discovers all the
154154
// keys of the desired type (as specified by the supplied `keyFn`) and, for each
155155
// key-value pair discovered, unmarshals it into `msg` and then invokes `f`.
156156
//
157157
// Iteration stops on the first error (and will pass through that error).
158-
func IterateIDPrefixKeys(
158+
func iterateRangeIDKeys(
159159
ctx context.Context, reader storage.Reader, scanRangeID scanRangeIDFn,
160160
) error {
161161
// NB: Range-ID local keys have no versions and no intents.
@@ -509,7 +509,7 @@ func loadReplicas(ctx context.Context, eng storage.Engine) ([]Replica, error) {
509509
// entire raft state (i.e. HardState, TruncatedState, Log).
510510
logEvery := log.Every(10 * time.Second)
511511
var i int
512-
if err := IterateIDPrefixKeys(ctx, eng, func(id roachpb.RangeID, get readKeyFn) error {
512+
if err := iterateRangeIDKeys(ctx, eng, func(id roachpb.RangeID, get readKeyFn) error {
513513
if logEvery.ShouldLog() && i > 0 { // only log if slow
514514
log.KvExec.Infof(ctx, "loaded state for %d/%d replicas", i, len(s))
515515
}

pkg/kv/kvserver/kvstorage/init_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import (
2323
"github.com/stretchr/testify/require"
2424
)
2525

26-
// TestIterateIDPrefixKeys lays down a number of tombstones (at keys.RangeTombstoneKey) interspersed
27-
// with other irrelevant keys (both chosen randomly). It then verifies that IterateIDPrefixKeys
26+
// TestIterateRangeIDKeys lays down a number of tombstones (at keys.RangeTombstoneKey) interspersed
27+
// with other irrelevant keys (both chosen randomly). It then verifies that iterateRangeIDKeys
2828
// correctly returns only the relevant keys and values.
29-
func TestIterateIDPrefixKeys(t *testing.T) {
29+
func TestIterateRangeIDKeys(t *testing.T) {
3030
defer leaktest.AfterTest(t)()
3131
defer log.Scope(t).Close(t)
3232

@@ -100,7 +100,7 @@ func TestIterateIDPrefixKeys(t *testing.T) {
100100
})
101101

102102
var seen []seenT
103-
require.NoError(t, IterateIDPrefixKeys(ctx, eng, func(id roachpb.RangeID, get readKeyFn) error {
103+
require.NoError(t, iterateRangeIDKeys(ctx, eng, func(id roachpb.RangeID, get readKeyFn) error {
104104
var tombstone kvserverpb.RangeTombstone
105105
if ok, err := get(keys.RangeTombstoneKey(id), &tombstone); err != nil {
106106
return err

0 commit comments

Comments
 (0)