Add timestamps to telemetry throttle events

guides/telemetry.md

@@ -31,42 +31,40 @@ metadata: #{monotonic_time => integer(), scenario => module(), type => add | rem
 ### Init
 
 Raised when a throttle mechanism is initialised.
-
 ```erlang
 event_name: [amoc, throttle, init]
 measurements: #{count => 1}
-metadata: #{name => atom()}
+metadata: #{monotonic_time => integer(), name => atom()}
 ```
 
 ### Rate
 
 Raised when a throttle mechanism is initialised or its configured rate is changed.
 This event is raised only on the master node.
-
 ```erlang
 event_name: [amoc, throttle, rate]
 measurements: #{rate => non_neg_integer()}
-metadata: #{name => atom()}
+metadata: #{monotonic_time => integer(), name => atom()}
 ```
 
 ### Request
 
 Raised when a process client requests to be allowed pass through a throttled mechanism.
-
+This event is raised only on the master node.
 ```erlang
 event_name: [amoc, throttle, request]
 measurements: #{count => 1}
-metadata: #{name => atom()}
+metadata: #{monotonic_time => integer(), name => atom()}
 ```
 
 ### Execute
 
 Raised when a process client is allowed to execute after a throttled mechanism.
-
+This event is raised only on the master node.
 ```erlang
 event_name: [amoc, throttle, execute]
 measurements: #{count => 1}
-metadata: #{name => atom()}
+metadata: #{monotonic_time => integer(), name => atom()}
 ```
 
 ## Coordinator

src/amoc_throttle/amoc_throttle_controller.erl

@@ -202,7 +202,14 @@ maybe_raise_event(Name, Event) ->
     end.
 
 raise_event(Name, Event) when Event =:= request; Event =:= execute; Event =:= init ->
-    telemetry:execute([amoc, throttle, Event], #{count => 1}, #{name => Name}).
+    telemetry:execute([amoc, throttle, Event],
+                      #{count => 1},
+                      #{monotonic_time => erlang:monotonic_time(), name => Name}).
+
+report_rate(Name, RatePerMinute) ->
+    telemetry:execute([amoc, throttle, rate],
+                      #{rate => RatePerMinute},
+                      #{monotonic_time => erlang:monotonic_time(), name => Name}).
 
 -spec change_rate_and_stop_plan(name(), state()) -> state().
 change_rate_and_stop_plan(Name, State) ->
@@ -325,6 +332,3 @@ run_cmd(Pid, pause) ->
     amoc_throttle_process:pause(Pid);
 run_cmd(Pid, resume) ->
     amoc_throttle_process:resume(Pid).
-
-report_rate(Name, RatePerMinute) ->
-    telemetry:execute([amoc, throttle, rate], #{rate => RatePerMinute}, #{name => Name}).