Skip to content

Commit 0f6b1db

Browse files
Merge pull request #14493 from rabbitmq/md/fifo-overview-smallest-index-detail
rabbit_fifo: Expose each smallest raft index in `overview/1`
2 parents 913d91a + 7f36b01 commit 0f6b1db

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

deps/rabbit/src/rabbit_fifo.erl

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -912,7 +912,8 @@ overview(#?STATE{consumers = Cons,
912912
in_memory_message_bytes => 0, %% backwards compat
913913
num_in_memory_ready_messages => 0, %% backwards compat
914914
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)
916917
},
917918
DlxOverview = rabbit_fifo_dlx:overview(DlxState),
918919
maps:merge(maps:merge(Overview, DlxOverview), SacOverview).
@@ -2826,6 +2827,13 @@ smallest_raft_index(#?STATE{messages = Messages,
28262827
SmallestRaIdx = rabbit_fifo_index:smallest(Indexes),
28272828
min(min(SmallestDlxRaIdx, SmallestMsgsRaIdx), SmallestRaIdx).
28282829

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+
28292837
make_requeue(ConsumerKey, Notify, [{MsgId, Idx, Header, Msg}], Acc) ->
28302838
lists:reverse([{append,
28312839
#requeue{consumer_key = ConsumerKey,

0 commit comments

Comments
 (0)