Add elysium_buffering_strategy:queue_status/1 and queue_status_reset/1

Author: jaynel

src/elysium_bs_parallel.erl

@@ -34,7 +34,10 @@
          pending_request_count/1,
          checkin_pending_request/3,
          checkout_pending_request/1,
-         checkout_pending_error/4
+         checkout_pending_error/4,
+
+         queue_status/1,
+         queue_status_reset/1
         ]).
 
 %% Buffering audit API
@@ -131,6 +134,13 @@ checkout_pending_error(Config, ?MODULE, Pending_Queue, Error) ->
     Error.
 
 
+-spec queue_status       (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+-spec queue_status_reset (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+
+queue_status       (_Queue_Name) -> {status, []}.
+queue_status_reset (_Queue_Name) -> {status, []}.
+
+
 %%%-----------------------------------------------------------------------
 %%% Custom audit count functions
 %%%-----------------------------------------------------------------------

src/elysium_bs_serial.erl

@@ -30,7 +30,10 @@
          pending_request_count/1,
          checkin_pending_request/3,
          checkout_pending_request/1,
-         checkout_pending_error/4
+         checkout_pending_error/4,
+
+         queue_status/1,
+         queue_status_reset/1
         ]).
 
 %% Buffering Audit API
@@ -101,6 +104,13 @@ checkout_pending_error(_Config, ?MODULE, Pending_Queue, Error) ->
     Error.
 
 
+-spec queue_status       (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+-spec queue_status_reset (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+
+queue_status       (Queue_Name) -> elysium_serial_queue:status       (Queue_Name).
+queue_status_reset (Queue_Name) -> elysium_serial_queue:status_reset (Queue_Name).
+    
+
 %%%-----------------------------------------------------------------------
 %%% Custom audit count functions
 %%%-----------------------------------------------------------------------

src/elysium_buffering_strategy.erl

@@ -37,6 +37,8 @@
 %% External API supplied for behaviour implementations to share.
 -export([
          status/1,
+         queue_status/2,
+         queue_status_reset/2,
 
          create_connection/3,
          checkin_connection/4,
@@ -69,6 +71,9 @@
 -callback checkout_pending_error(config_type(), buffering_strategy_module(), requests_queue_name(), Error)
                       -> retry | Error when Error::any().
 
+-callback queue_status       (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+-callback queue_status_reset (connection_queue_name() | requests_queue_name()) -> {status, proplists:proplist()}.
+
 
 %%%-----------------------------------------------------------------------
 %%% Buffering strategy provided functions
@@ -87,7 +92,12 @@
 -spec decay_causes_death (config_type(), connection_id()) -> boolean().
 -spec decay_connection   (config_type(), buffering_strategy_module(), connection_id()) -> true.
 
--spec status        (config_type()) -> status_reply().
+-spec status             (config_type()) -> status_reply().
+-spec queue_status       (config_type(), connection_queue_name() | requests_queue_name())
+                         -> {status, proplists:proplist()}.
+-spec queue_status_reset (config_type(), connection_queue_name() | requests_queue_name())
+                         -> {status, proplists:proplist()}.
+
 -spec report_available_resources(Queue, Connections, Max_Or_Timeout) -> {Queue, Connections, Max_Or_Timeout}
                                        when Queue          :: queue_name(),
                                             Connections    :: max_connections() | pending_count(),
@@ -375,6 +385,14 @@ status(Config) ->
     {status, {idle_connections(Config),
               pending_requests(Config)}}.
 
+queue_status(Config, Queue_Name) ->
+    {_Buffering, BS_Module} = elysium_connection:get_buffer_strategy_module(Config),
+    BS_Module:queue_status(Config, Queue_Name).
+
+queue_status_reset(Config, Queue_Name) ->
+    {_Buffering, BS_Module} = elysium_connection:get_buffer_strategy_module(Config),
+    BS_Module:queue_status_reset(Config, Queue_Name).
+
 report_available_resources(Queue_Name, {missing_ets_buffer, Queue_Name}, Max) ->
     {Queue_Name, {missing_ets_buffer, 0, Max}};
 report_available_resources(Queue_Name, Num_Sessions, Max) ->