summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2010-08-02 17:21:27 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2010-08-02 17:21:27 +0100
commitb9bc0e250c3bae6611b84a65b4bf9bb50ac0a32d (patch)
treef934ce42a009ee326e909e36b605d98e38ce453e
parenta211fd73ce5b7a2fdc7129cc3b341faf55de64c5 (diff)
downloadrabbitmq-server-bug21387.tar.gz
Corrections to specs and export suitable event specsbug21387
-rw-r--r--src/rabbit_event.erl25
1 files changed, 21 insertions, 4 deletions
diff --git a/src/rabbit_event.erl b/src/rabbit_event.erl
index e9406c12..709709a3 100644
--- a/src/rabbit_event.erl
+++ b/src/rabbit_event.erl
@@ -38,8 +38,27 @@
-export([stats_level/1]).
-export([notify/2]).
+%%----------------------------------------------------------------------------
+
+-record(state, {level, timer}).
+
+%%----------------------------------------------------------------------------
+
-ifdef(use_specs).
+-export_type([event_type/0, event_props/0, event_timestamp/0, event/0]).
+
+-type(event_type() :: atom()).
+-type(event_props() :: term()).
+-type(event_timestamp() ::
+ {non_neg_integer(), non_neg_integer(), non_neg_integer()}).
+
+-type(event() :: #event {
+ type :: event_type(),
+ props :: event_props(),
+ timestamp :: event_timestamp()
+ }).
+
-type(level() :: 'none' | 'coarse' | 'fine').
-opaque(state() :: #state {
@@ -53,14 +72,12 @@
-spec(ensure_stats_timer/3 :: (state(), timer_fun(), timer_fun()) -> state()).
-spec(stop_stats_timer/2 :: (state(), timer_fun()) -> state()).
-spec(ensure_stats_timer_after/2 :: (state(), timer_fun()) -> state()).
--spec(reset_stats_timer_after/1 :: (state()) -> 'ok').
+-spec(reset_stats_timer_after/1 :: (state()) -> state()).
-spec(stats_level/1 :: (state()) -> level()).
--spec(notify/2 :: (atom(), term()) -> 'ok').
+-spec(notify/2 :: (event_type(), event_props()) -> 'ok').
-endif.
--record(state, {level, timer}).
-
%%----------------------------------------------------------------------------
init_stats_timer() ->