@@ -185,20 +185,6 @@ class leader_balancer {
185
185
186
186
config::binding<model::leaders_preference> _default_preference;
187
187
188
- struct last_known_leader {
189
- model::broker_shard shard;
190
- clock_type::time_point expires;
191
- };
192
- absl::btree_map<raft::group_id, last_known_leader> _last_leader;
193
-
194
- leader_balancer_probe _probe;
195
- bool _need_controller_refresh{true };
196
- bool _throttled{false };
197
- absl::btree_map<raft::group_id, clock_type::time_point> _muted;
198
- cluster::notification_id_type _leader_notify_handle;
199
- std::optional<cluster::notification_id_type>
200
- _leadership_change_notify_handle;
201
- cluster::notification_id_type _maintenance_state_notify_handle;
202
188
topic_table& _topics;
203
189
partition_leaders_table& _leaders;
204
190
members_table& _members;
@@ -209,15 +195,33 @@ class leader_balancer {
209
195
ss::sharded<partition_manager>& _partition_manager;
210
196
ss::sharded<ss::abort_source>& _as;
211
197
consensus_ptr _raft0;
198
+
199
+ cluster::notification_id_type _leader_notify_handle;
200
+ std::optional<cluster::notification_id_type>
201
+ _leadership_change_notify_handle;
202
+ cluster::notification_id_type _maintenance_state_notify_handle;
203
+
212
204
ss::gate _gate;
213
205
ss::timer<clock_type> _timer;
214
206
207
+ struct last_known_leader {
208
+ model::broker_shard shard;
209
+ clock_type::time_point expires;
210
+ };
211
+ absl::btree_map<raft::group_id, last_known_leader> _last_leader;
212
+
213
+ bool _need_controller_refresh{true };
214
+ bool _throttled{false };
215
+ absl::btree_map<raft::group_id, clock_type::time_point> _muted;
216
+
215
217
struct in_flight_reassignment {
216
218
reassignment value;
217
219
clock_type::time_point expires;
218
220
};
219
221
absl::flat_hash_map<raft::group_id, in_flight_reassignment>
220
222
_in_flight_changes;
223
+
224
+ leader_balancer_probe _probe;
221
225
};
222
226
223
227
} // namespace cluster
0 commit comments