@@ -912,7 +912,8 @@ overview(#?STATE{consumers = Cons,
912
912
in_memory_message_bytes => 0 , % % backwards compat
913
913
num_in_memory_ready_messages => 0 , % % backwards compat
914
914
release_cursor_enqueue_counter => EnqCount ,
915
- smallest_raft_index => smallest_raft_index (State )
915
+ smallest_raft_index => smallest_raft_index (State ),
916
+ smallest_raft_index_overview => smallest_raft_index_overview (State )
916
917
},
917
918
DlxOverview = rabbit_fifo_dlx :overview (DlxState ),
918
919
maps :merge (maps :merge (Overview , DlxOverview ), SacOverview ).
@@ -2826,6 +2827,13 @@ smallest_raft_index(#?STATE{messages = Messages,
2826
2827
SmallestRaIdx = rabbit_fifo_index :smallest (Indexes ),
2827
2828
min (min (SmallestDlxRaIdx , SmallestMsgsRaIdx ), SmallestRaIdx ).
2828
2829
2830
+ smallest_raft_index_overview (#? STATE {messages = Messages ,
2831
+ ra_indexes = Indexes ,
2832
+ dlx = DlxState }) ->
2833
+ #{message => rabbit_fifo_q :get_lowest_index (Messages ),
2834
+ checked_out => rabbit_fifo_index :smallest (Indexes ),
2835
+ dlx => rabbit_fifo_dlx :smallest_raft_index (DlxState )}.
2836
+
2829
2837
make_requeue (ConsumerKey , Notify , [{MsgId , Idx , Header , Msg }], Acc ) ->
2830
2838
lists :reverse ([{append ,
2831
2839
# requeue {consumer_key = ConsumerKey ,
0 commit comments