@@ -55,8 +55,8 @@ start_link() ->
5555
5656init ([]) ->
5757 {ok , Descs } = reload_metrics (),
58- { ok , CT } = erlang :send_after (get_interval (collect ), self (), collect ),
59- { ok , RT } = erlang :send_after (get_interval (reload ), self (), reload ),
58+ CT = erlang :send_after (get_interval (collect ), self (), collect ),
59+ RT = erlang :send_after (get_interval (reload ), self (), reload ),
6060 {ok , # st {descriptions = Descs , stats = [], collect_timer = CT , reload_timer = RT }}.
6161
6262handle_call (fetch , _from , # st {stats = Stats }= State ) ->
@@ -66,7 +66,7 @@ handle_call(flush, _From, State) ->
6666handle_call (reload , _from , # st {reload_timer = OldRT } = State ) ->
6767 timer :cancel (OldRT ),
6868 {ok , Descriptions } = reload_metrics (),
69- { ok , RT } = update_timer (reload ),
69+ RT = update_timer (reload ),
7070 {reply , ok , State # st {descriptions = Descriptions , reload_timer = RT }};
7171handle_call (Msg , _From , State ) ->
7272 {stop , {unknown_call , Msg }, error , State }.
@@ -149,15 +149,12 @@ collect(#st{collect_timer=OldCT} = State) ->
149149 end ,
150150 State # st .descriptions
151151 ),
152- { ok , CT } = update_timer (collect ),
152+ CT = update_timer (collect ),
153153 State # st {stats = Stats , collect_timer = CT }.
154154
155- update_timer (collect ) ->
156- Interval = get_interval (collect ),
157- erlang :send_after (Interval , self (), collect );
158- update_timer (reload ) ->
159- Interval = get_interval (reload ),
160- erlang :send_after (Interval , self (), reload ).
155+ update_timer (Type ) ->
156+ Interval = get_interval (Type ),
157+ erlang :send_after (Interval , self (), Type ).
161158
162159get_interval (reload ) -> 1000 * ? RELOAD_INTERVAL ;
163160get_interval (collect ) -> 1000 * config :get_integer (" stats" , " interval" , ? DEFAULT_INTERVAL ).
0 commit comments