@@ -36,9 +36,9 @@ type storePool interface {
36
36
UpdateLocalStoreAfterRebalance (storeID roachpb.StoreID , rangeUsageInfo allocator.RangeUsageInfo , changeType roachpb.ReplicaChangeType )
37
37
}
38
38
39
- // mmaAllocator is an interface that defines the methods that the allocator sync
39
+ // mmaState is an interface that defines the methods that the allocator sync
40
40
// needs to call on the mma. Using an interface to simplify testing.
41
- type mmaAllocator interface {
41
+ type mmaState interface {
42
42
// RegisterExternalChanges is called by the allocator sync to register
43
43
// external changes with the mma.
44
44
RegisterExternalChanges (changes []mmaprototype.ReplicaChange ) []mmaprototype.ChangeID
@@ -54,13 +54,13 @@ type mmaAllocator interface {
54
54
// mma is disabled.)
55
55
56
56
// AllocatorSync is a component that coordinates changes from all components
57
- // (including mma/replicate/lease queue) with mma and store pool. When mma is
58
- // disabled, its sole purpose is to track and apply changes to the store pool
59
- // upon success.
57
+ // (including mma-store-rebalancer /replicate/lease queue) with mma and store
58
+ // pool. When mma is disabled, its sole purpose is to track and apply changes
59
+ // to the store pool upon success.
60
60
type AllocatorSync struct {
61
61
sp storePool
62
62
st * cluster.Settings
63
- mmaAllocator mmaAllocator
63
+ mmaAllocator mmaState
64
64
mu struct {
65
65
syncutil.Mutex
66
66
// changeSeqGen is a monotonically increasing sequence number for
@@ -75,7 +75,7 @@ type AllocatorSync struct {
75
75
}
76
76
77
77
func NewAllocatorSync (
78
- sp storePool , mmaAllocator mmaAllocator , st * cluster.Settings ,
78
+ sp storePool , mmaAllocator mmaState , st * cluster.Settings ,
79
79
) * AllocatorSync {
80
80
as := & AllocatorSync {
81
81
sp : sp ,
0 commit comments