format

Author: markus812498

deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl

@@ -213,6 +213,12 @@
         {2, undefined, stream_publisher_error_messages, counter, "Total errored published messages", errored}
     ]},
 
+    {stream_consumer_metrics, [
+        {2, undefined, stream_consumer_offset, counter, "Total nunber of offset", offset},
+        {2, undefined, stream_consumer_offset_lag, counter, "Total offset lag of connection", offset_lag},
+        {2, undefined, stream_consumer_consumed_total, counter, "Total number of messages consumed on connection", consumed}
+    ]},
+
     {connection_metrics, [
         {2, undefined, connection_incoming_packets_total, counter, "Total number of packets received on a connection", recv_cnt},
         {2, undefined, connection_outgoing_packets_total, counter, "Total number of packets sent on a connection", send_cnt},
@@ -538,25 +544,23 @@ get_data(rabbit_stream_publisher_created = Table, false, _, _) ->
 get_data(stream_publisher_metrics = Table, false, _, _) ->
   RealTable = rabbit_stream_publisher_created, %% real table name
   {Table, A1, A2, A3} = ets:foldl(fun({_, Props}, {T, A1, A2, A3}) ->
-    {T, 
+    {T,
       sum(proplists:get_value(published, Props), A1),
       sum(proplists:get_value(confirmed, Props), A2),
       sum(proplists:get_value(errored, Props), A3)
     }
                       end, empty(Table), RealTable),
   [{Table, [{published, A1}, {confirmed, A2}, {errored, A3}]}];
-
 get_data(stream_consumer_metrics = Table, false, _, _) ->
   RealTable = rabbit_stream_consumer_created, %% real table name
   {Table, A1, A2, A3} = ets:foldl(fun({_, Props}, {T, A1, A2, A3}) ->
-    {T, 
+    {T,
       sum(proplists:get_value(offset, Props), A1),
       sum(proplists:get_value(offset_lag, Props), A2),
       sum(proplists:get_value(consumed, Props), A3)
     }
                       end, empty(Table), RealTable),
   [{Table, [{offset, A1}, {offset_lag, A2}, {consumed, A3}]}];
-
 get_data(queue_consumer_count = MF, false, VHostsFilter, QueuesFilter) ->
     Table = queue_metrics, %% Real table name
     {_, A1} = ets:foldl(fun