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

fix tcp_channel

Browse Source
This commit is contained in:
anlicheng 2025-04-30 11:07:55 +08:00
parent 46f7524141
commit a77efa9d11
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/efka/src/tcp_channel.erl
View File

@ -57,16 +57,19 @@
%%% API
%%%===================================================================
-spec push_param(ChannelPid :: pid(), Params :: binary()) -> {ok, Ref :: reference()}.
push_param(ChannelPid, Params) when is_pid(ChannelPid), is_binary(Params) ->
Ref = make_ref(),
gen_server:cast(ChannelPid, {push_param, Ref, self(), Params}),
{ok, Ref}.
-spec push_metric(ChannelPid :: pid(), Metrics :: binary()) -> {ok, Ref :: reference()}.
push_metric(ChannelPid, Metrics) when is_pid(ChannelPid), is_binary(Metrics) ->
Ref = make_ref(),
gen_server:cast(ChannelPid, {push_metric, Ref, self(), Metrics}),
{ok, Ref}.
-spec poll(ChannelPid :: pid(), Command :: binary()) -> {ok, Ref :: reference()}.
poll(ChannelPid, Command) when is_pid(ChannelPid), is_binary(Command) ->
Ref = make_ref(),
gen_server:cast(ChannelPid, {poll, Ref, self(), Command}),