diff --git a/apps/efka/src/channel/ws_channel.erl b/apps/efka/src/channel/ws_channel.erl index 38ea1e5..20875f3 100644 --- a/apps/efka/src/channel/ws_channel.erl +++ b/apps/efka/src/channel/ws_channel.erl @@ -244,12 +244,12 @@ search_stream_id(StreamPid, StreamMap) when is_pid(StreamPid), is_map(StreamMap) -spec map_metric(Metric :: any()) -> {ok, binary()} | error. map_metric(Metric) when is_binary(Metric) -> - Metric; + {ok, 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) -> - integer_to_binary(Metric); + {ok, integer_to_binary(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(_) -> error. \ No newline at end of file