Skip to content

Commit 34e076a

Browse files
committed
Remove compatibility code for management agent feature flags
Remove compatibility code for feature flags * drop_unroutable_metric * empty_basic_get_metric since they are required in 3.12.0. See #7219
1 parent 5045fce commit 34e076a

File tree

4 files changed

+5
-70
lines changed

4 files changed

+5
-70
lines changed

deps/rabbitmq_management_agent/src/rabbit_mgmt_data.erl

Lines changed: 3 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -356,8 +356,7 @@ lookup_smaller_sample(Table, Id) ->
356356
[] ->
357357
not_found;
358358
[{_, Slide}] ->
359-
Slide1 = exometer_slide:optimize(Slide),
360-
maybe_convert_for_compatibility(Table, Slide1)
359+
exometer_slide:optimize(Slide)
361360
end.
362361

363362
-spec lookup_samples(atom(), any(), #range{}) -> maybe_slide().
@@ -366,8 +365,7 @@ lookup_samples(Table, Id, Range) ->
366365
[] ->
367366
not_found;
368367
[{_, Slide}] ->
369-
Slide1 = exometer_slide:optimize(Slide),
370-
maybe_convert_for_compatibility(Table, Slide1)
368+
exometer_slide:optimize(Slide)
371369
end.
372370

373371
lookup_all(Table, Ids, SecondKey) ->
@@ -383,39 +381,9 @@ lookup_all(Table, Ids, SecondKey) ->
383381
[] ->
384382
not_found;
385383
_ ->
386-
Slide = exometer_slide:sum(Slides, empty(Table, 0)),
387-
maybe_convert_for_compatibility(Table, Slide)
384+
exometer_slide:sum(Slides, empty(Table, 0))
388385
end.
389386

390-
maybe_convert_for_compatibility(Table, Slide)
391-
when Table =:= channel_stats_fine_stats orelse
392-
Table =:= channel_exchange_stats_fine_stats orelse
393-
Table =:= vhost_stats_fine_stats ->
394-
ConversionNeeded = rabbit_feature_flags:is_disabled(
395-
drop_unroutable_metric),
396-
case ConversionNeeded of
397-
false ->
398-
Slide;
399-
true ->
400-
%% drop_drop because the metric is named "drop_unroutable"
401-
rabbit_mgmt_data_compat:drop_drop_unroutable_metric(Slide)
402-
end;
403-
maybe_convert_for_compatibility(Table, Slide)
404-
when Table =:= channel_queue_stats_deliver_stats orelse
405-
Table =:= channel_stats_deliver_stats orelse
406-
Table =:= queue_stats_deliver_stats orelse
407-
Table =:= vhost_stats_deliver_stats ->
408-
ConversionNeeded = rabbit_feature_flags:is_disabled(
409-
empty_basic_get_metric),
410-
case ConversionNeeded of
411-
false ->
412-
Slide;
413-
true ->
414-
rabbit_mgmt_data_compat:drop_get_empty_queue_metric(Slide)
415-
end;
416-
maybe_convert_for_compatibility(_, Slide) ->
417-
Slide.
418-
419387
get_table_keys(Table, Id0) ->
420388
ets:select(Table, match_spec_keys(Id0)).
421389

deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl

Lines changed: 1 addition & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,8 @@
88
-module(rabbit_mgmt_data_compat).
99

1010
-export([fill_get_empty_queue_metric/1,
11-
drop_get_empty_queue_metric/1,
1211
fill_consumer_active_fields/1,
13-
fill_drop_unroutable_metric/1,
14-
drop_drop_unroutable_metric/1]).
12+
fill_drop_unroutable_metric/1]).
1513

1614
fill_get_empty_queue_metric(Slide) ->
1715
exometer_slide:map(
@@ -26,21 +24,6 @@ fill_get_empty_queue_metric(Slide) ->
2624
Value
2725
end, Slide).
2826

29-
drop_get_empty_queue_metric(Slide) ->
30-
exometer_slide:map(
31-
fun
32-
(Value) when is_tuple(Value) andalso size(Value) =:= 8 ->
33-
%% We want to remove the last element, which is
34-
%% the count of basic.get on empty queues.
35-
list_to_tuple(
36-
lists:sublist(
37-
tuple_to_list(Value), size(Value) - 1));
38-
(Value) when is_tuple(Value) andalso size(Value) =:= 7 ->
39-
Value;
40-
(Value) ->
41-
Value
42-
end, Slide).
43-
4427
fill_drop_unroutable_metric(Slide) ->
4528
exometer_slide:map(
4629
fun
@@ -54,20 +37,6 @@ fill_drop_unroutable_metric(Slide) ->
5437
Value
5538
end, Slide).
5639

57-
drop_drop_unroutable_metric(Slide) ->
58-
exometer_slide:map(
59-
fun
60-
(Value) when is_tuple(Value) andalso size(Value) =:= 4 ->
61-
%% Remove the last element.
62-
list_to_tuple(
63-
lists:sublist(
64-
tuple_to_list(Value), size(Value) - 1));
65-
(Value) when is_tuple(Value) andalso size(Value) =:= 3 ->
66-
Value;
67-
(Value) ->
68-
Value
69-
end, Slide).
70-
7140
fill_consumer_active_fields(ConsumersStatsList) ->
7241
[case proplists:get_value(active, ConsumerStats) of
7342
undefined ->

deps/rabbitmq_management_agent/src/rabbit_mgmt_ff.erl

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,13 +10,11 @@
1010
-rabbit_feature_flag(
1111
{empty_basic_get_metric,
1212
#{desc => "Count AMQP `basic.get` on empty queues in stats",
13-
%%TODO remove compatibility code
1413
stability => required
1514
}}).
1615

1716
-rabbit_feature_flag(
1817
{drop_unroutable_metric,
1918
#{desc => "Count unroutable publishes to be dropped in stats",
20-
%%TODO remove compatibility code
2119
stability => required
2220
}}).

deps/rabbitmq_mqtt/src/rabbit_mqtt_ff.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,4 +26,4 @@
2626

2727
-spec track_client_id_in_ra() -> boolean().
2828
track_client_id_in_ra() ->
29-
not rabbit_feature_flags:is_enabled(delete_ra_cluster_mqtt_node).
29+
rabbit_feature_flags:is_disabled(delete_ra_cluster_mqtt_node).

0 commit comments

Comments
 (0)