diff options
| author | Ulf Wiger <ulf@feuerlabs.com> | 2016-03-18 09:38:22 -0700 |
|---|---|---|
| committer | Ulf Wiger <ulf@feuerlabs.com> | 2016-03-23 02:09:08 -0700 |
| commit | 7f592ce0b8a7305ca381ae6f982b11039494ac70 (patch) | |
| tree | da5c93d9fc0ed8fd5d11be0cf5d32778c9ff7fef | |
| parent | c2a5df3cc9fa58bfbf3237f2025c6e5401aee93b (diff) | |
| download | rvi_core-7f592ce0b8a7305ca381ae6f982b11039494ac70.tar.gz | |
Add get_node_service_prefix rpc
| -rw-r--r-- | components/service_edge/src/service_edge_rpc.erl | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/components/service_edge/src/service_edge_rpc.erl b/components/service_edge/src/service_edge_rpc.erl index 4a61088..46a64d0 100644 --- a/components/service_edge/src/service_edge_rpc.erl +++ b/components/service_edge/src/service_edge_rpc.erl @@ -300,6 +300,12 @@ handle_ws_json_rpc(WSock, <<"unregister_service">>, Params, _Arg ) -> gen_server:call(?SERVER, { rvi, unregister_local_service, [ SvcName ]}), { ok, [ { status, rvi_common:json_rpc_status(ok)} ]}; +handle_ws_json_rpc(WSock, <<"get_node_service_prefix">>, [], _Arg) -> + ?debug("websocket_get_node_service_prefix(~p)", [WSock]), + { ok, [ { status, rvi_common:json_rpc_status(ok) }, + { node_service_prefix, rvi_common:local_service_prefix() }, + { method, <<"get_node_service_prefix">> } ]}; + handle_ws_json_rpc(_Ws , <<"get_available_services">>, _Params, _Arg ) -> ?debug("service_edge_rpc:websocket_get_available()"), [ ok, Services ] = @@ -343,6 +349,10 @@ handle_rpc(<<"unregister_service">>, Args) -> { method, <<"unregister_service">>} ]}; +handle_rpc(<<"get_node_service_prefix">>, []) -> + { ok, [ { status, rvi_common:json_rpc_status(ok) }, + { node_service_prefix, rvi_common:local_service_prefix() }, + { method, <<"get_node_service_prefix">> } ]}; handle_rpc(<<"get_available_services">>, _Args) -> [ Status, Services ] = gen_server:call(?SERVER, { rvi, get_available_services, []}), |