diff options
| author | Magnus Ahltorp <map@kth.se> | 2017-03-02 12:52:16 +0100 |
|---|---|---|
| committer | Magnus Ahltorp <map@kth.se> | 2017-03-08 23:23:13 +0100 |
| commit | 64daaf148cd59bf19942014bc754992b6bc6d86d (patch) | |
| tree | 816bf5c7180283cd43d0c19ef15e2815a097aab6 /statsserver/src/statsserver.erl | |
| parent | 12e08090358383c5678417ae8929fca1f03ca8bc (diff) | |
Rename to statusserver
Diffstat (limited to 'statsserver/src/statsserver.erl')
| -rw-r--r-- | statsserver/src/statsserver.erl | 71 |
1 files changed, 0 insertions, 71 deletions
diff --git a/statsserver/src/statsserver.erl b/statsserver/src/statsserver.erl deleted file mode 100644 index 1d42b27..0000000 --- a/statsserver/src/statsserver.erl +++ /dev/null @@ -1,71 +0,0 @@ -%%% Copyright (c) 2014-2016, NORDUnet A/S. -%%% See LICENSE for licensing information. - -%%% @doc Frontend node API - --module(statsserver). --export([init_module/0]). -%% API (URL) --export([request/4]). - --define(APPURL_PLOP_STATUS, "plop/v1/status"). - -request(post, ?APPURL_PLOP_STATUS, Service, Input) -> - case (catch mochijson2:decode(Input)) of - {error, E} -> - html("bad input:", E); - Entries when is_list(Entries) -> - lists:foreach(fun ({struct, PropList}) -> - Target = proplists:get_value(<<"target">>, PropList), - Variable = proplists:get_value(<<"key">>, PropList), - Status = proplists:get_value(<<"value">>, PropList), - set_status(Service, Target, Variable, Status) - end, Entries) - end, - success({[{result, <<"ok">>}]}); -request(get, "", "status", Input) -> - Now = erlang:monotonic_time(millisecond), - Variables = [{struct, [ - {service, list_to_binary(Service)}, - {target, Target}, - {variable, Variable}, - {status, Status}, - {age, (Now - Timestamp) / 1000} - ]} || {{Service, Target, Variable}, Status, Timestamp} <- get_status()], - success({[{result, Variables}]}). - - -success(Data) -> - {200, [{"Content-Type", "text/json"}, {"Access-Control-Allow-Origin", "*"}], mochijson2:encode(Data)}. - -html(Text, Input) -> - {400, [{"Content-Type", "text/html"}], - io_lib:format( - "<html><body><p>~n" ++ - "~s~n" ++ - "~p~n" ++ - "</body></html>~n", [Text, Input])}. - --define(STATUSDB_TABLE, statsserver_statusdb). - -init_module() -> - create_statusdb(). - -create_statusdb() -> - case ets:info(?STATUSDB_TABLE) of - undefined -> - ok; - _ -> - ets:delete(?STATUSDB_TABLE) - end, - ets:new(?STATUSDB_TABLE, [set, public, named_table]). - -get_status() -> - [E || [E] <- ets:match(?STATUSDB_TABLE, '$1')]. - -set_status(Service, Target, Variable, Status) -> - lager:info("status: ~p ~p ~p ~p", [Service, Target, Variable, Status]), - Timestamp = erlang:monotonic_time(millisecond), - true = ets:insert(?STATUSDB_TABLE, - {{Service, Target, Variable}, Status, Timestamp}), - ok. |