anlicheng/ekfa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
anlicheng 2025-11-14 17:19:42 +08:00
parent 0f8ef428b5
commit dc218e1d4f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/efka/src/channel/ws_channel.erl
View File

@ -244,12 +244,12 @@ search_stream_id(StreamPid, StreamMap) when is_pid(StreamPid), is_map(StreamMap)
-spec map_metric(Metric :: any()) -> {ok, binary()} | error. -spec map_metric(Metric :: any()) -> {ok, binary()} | error.
map_metric(Metric) when is_binary(Metric) -> map_metric(Metric) when is_binary(Metric) ->
Metric; {ok, Metric};
map_metric(Metric) when is_map(Metric) orelse is_list(Metric) -> map_metric(Metric) when is_map(Metric) orelse is_list(Metric) ->
jiffy:encode(Metric, [force_utf8]); {ok, jiffy:encode(Metric, [force_utf8])};
map_metric(Metric) when is_integer(Metric) -> map_metric(Metric) when is_integer(Metric) ->
integer_to_binary(Metric); {ok, integer_to_binary(Metric)};
map_metric(Metric) when is_float(Metric) -> map_metric(Metric) when is_float(Metric) ->
erlang:float_to_binary(Metric, [compact, {decimals, 10}]); {ok, erlang:float_to_binary(Metric, [compact, {decimals, 10}])};
map_metric(_) -> map_metric(_) ->
error. error.