fix

include/message_pb.hrl

@@ -46,6 +46,51 @@
         }).
 -endif.
 
+-ifndef('AUTHREQUEST_PB_H').
+-define('AUTHREQUEST_PB_H', true).
+-record('AuthRequest',
+        {uuid = <<>>            :: iodata() | undefined, % = 1, optional
+         username = <<>>        :: iodata() | undefined, % = 2, optional
+         salt = <<>>            :: iodata() | undefined, % = 3, optional
+         token = <<>>           :: iodata() | undefined, % = 4, optional
+         timestamp = 0          :: integer() | undefined % = 5, optional, 32 bits
+        }).
+-endif.
+
+-ifndef('PUB_PB_H').
+-define('PUB_PB_H', true).
+-record('Pub',
+        {topic = <<>>           :: iodata() | undefined, % = 1, optional
+         qos = 0                :: integer() | undefined, % = 2, optional, 32 bits
+         content = <<>>         :: iodata() | undefined % = 3, optional
+        }).
+-endif.
+
+-ifndef('COMMAND_PB_H').
+-define('COMMAND_PB_H', true).
+-record('Command',
+        {command_type = 0       :: integer() | undefined, % = 1, optional, 32 bits
+         command = <<>>         :: iodata() | undefined % = 2, optional
+        }).
+-endif.
+
+-ifndef('DATA_PB_H').
+-define('DATA_PB_H', true).
+-record('Data',
+        {route_key = <<>>       :: iodata() | undefined, % = 1, optional
+         metric = <<>>          :: iodata() | undefined % = 2, optional
+        }).
+-endif.
+
+-ifndef('TASKEVENTSTREAM_PB_H').
+-define('TASKEVENTSTREAM_PB_H', true).
+-record('TaskEventStream',
+        {task_id = 0            :: integer() | undefined, % = 1, optional, 32 bits
+         type = <<>>            :: iodata() | undefined, % = 2, optional
+         stream = <<>>          :: iodata() | undefined % = 3, optional
+        }).
+-endif.
+
 -ifndef('CONTAINERREF_PB_H').
 -define('CONTAINERREF_PB_H', true).
 -record('ContainerRef',
@@ -230,49 +275,4 @@
         }).
 -endif.
 
--ifndef('AUTHREQUEST_PB_H').
--define('AUTHREQUEST_PB_H', true).
--record('AuthRequest',
-        {uuid = <<>>            :: iodata() | undefined, % = 1, optional
-         username = <<>>        :: iodata() | undefined, % = 2, optional
-         salt = <<>>            :: iodata() | undefined, % = 3, optional
-         token = <<>>           :: iodata() | undefined, % = 4, optional
-         timestamp = 0          :: integer() | undefined % = 5, optional, 32 bits
-        }).
--endif.
-
--ifndef('PUB_PB_H').
--define('PUB_PB_H', true).
--record('Pub',
-        {topic = <<>>           :: iodata() | undefined, % = 1, optional
-         qos = 0                :: integer() | undefined, % = 2, optional, 32 bits
-         content = <<>>         :: iodata() | undefined % = 3, optional
-        }).
--endif.
-
--ifndef('COMMAND_PB_H').
--define('COMMAND_PB_H', true).
--record('Command',
-        {command_type = 0       :: integer() | undefined, % = 1, optional, 32 bits
-         command = <<>>         :: iodata() | undefined % = 2, optional
-        }).
--endif.
-
--ifndef('DATA_PB_H').
--define('DATA_PB_H', true).
--record('Data',
-        {route_key = <<>>       :: iodata() | undefined, % = 1, optional
-         metric = <<>>          :: iodata() | undefined % = 2, optional
-        }).
--endif.
-
--ifndef('TASKEVENTSTREAM_PB_H').
--define('TASKEVENTSTREAM_PB_H', true).
--record('TaskEventStream',
-        {task_id = 0            :: integer() | undefined, % = 1, optional, 32 bits
-         type = <<>>            :: iodata() | undefined, % = 2, optional
-         stream = <<>>          :: iodata() | undefined % = 3, optional
-        }).
--endif.
-
 -endif.

rebar.config

@@ -10,6 +10,7 @@
 {gpb_opts, [
     {i, "proto"},                 % proto 文件路径
     {src_dirs, ["proto"]},        % 源码目录（必须）
+    {f, ["message.proto", "service.proto"]},
     recursive,                     % 递归查找 proto 文件
     {module_name_suffix, "_pb"},   % 生成模块后缀
     {o_erl, "src/protobuf"},                % .erl 输出目录

src/docker/docker_deploy_manager.erl

@@ -70,8 +70,8 @@ handle_info({'DOWN', _Ref, process, TaskPid, Reason}, State = #state{task_map =
                     logger:debug("[docker_deploy_manager] task_id: ~p, exit normal", [TaskId]);
                 Error0 ->
                     Error = iolist_to_binary(io_lib:format("~p", [Error0])),
-                    efka_task_reporter:stream(TaskId, <<"error">>, <<"任务失败: "/utf8, Error/binary>>),
+                    docker_task_reporter:stream(TaskId, <<"error">>, <<"任务失败: "/utf8, Error/binary>>),
-                    efka_task_reporter:close(TaskId, <<"task exited">>),
+                    docker_task_reporter:close(TaskId, <<"task exited">>),
                     logger:notice("[docker_deploy_manager] task_id: ~p, exit with error: ~p", [TaskId, Error])
             end,
             {noreply, State#state{task_map = NTaskMap}}

src/docker/docker_deployer.erl

@@ -56,21 +56,21 @@ deploy(TaskId, ContainerDir, Params = #'ContainerDeployParams'{
         report_task_event(TaskId, <<"info">>, <<"容器创建成功: "/utf8, ShortContainerId/binary>>),
         report_task_event(TaskId, <<"info">>, <<"任务完成"/utf8>>),
         write_task_summary(TaskId, <<"success">>, ContainerName, Image, ContainerId),
-        efka_task_reporter:close(TaskId, ?TASK_SUCCESS)
+        docker_task_reporter:close(TaskId, ?TASK_SUCCESS)
     catch
         throw:{deploy_error, Reason} ->
             report_task_event(TaskId, <<"error">>, Reason),
             report_task_event(TaskId, <<"error">>, <<"任务失败"/utf8>>),
             write_task_summary(TaskId, <<"fail">>, ContainerName, Image0, undefined),
             write_task_failure_reason(TaskId, Reason),
-            efka_task_reporter:close(TaskId, ?TASK_FAIL);
+            docker_task_reporter:close(TaskId, ?TASK_FAIL);
         Class:Reason:Stacktrace ->
             Error = iolist_to_binary(io_lib:format("deploy crashed: ~p:~p ~p", [Class, Reason, Stacktrace])),
             report_task_event(TaskId, <<"error">>, Error),
             report_task_event(TaskId, <<"error">>, <<"任务失败"/utf8>>),
             write_task_summary(TaskId, <<"fail">>, ContainerName, Image0, undefined),
             write_task_failure_reason(TaskId, Error),
-            efka_task_reporter:close(TaskId, ?TASK_FAIL)
+            docker_task_reporter:close(TaskId, ?TASK_FAIL)
     end.
 
 -spec normalize_image(binary()) -> binary().
@@ -85,7 +85,7 @@ normalize_image(Image) when is_binary(Image) ->
 
 -spec report_task_event(TaskId :: integer(), Level :: binary(), Msg :: binary()) -> ok.
 report_task_event(TaskId, Level, Msg) when is_integer(TaskId), is_binary(Level), is_binary(Msg) ->
-    efka_task_reporter:stream(TaskId, Level, Msg).
+    docker_task_reporter:stream(TaskId, Level, Msg).
 
 -spec write_task_summary(integer(), binary(), binary(), binary(), undefined | binary()) -> ok.
 write_task_summary(TaskId, Status, ContainerName, Image, ContainerId)

src/docker/docker_task_reporter.erl

@@ -6,7 +6,7 @@
 %%% @end
 %%% Created : 20. 4月 2026
 %%%-------------------------------------------------------------------
--module(efka_task_reporter).
+-module(docker_task_reporter).
 -author("anlicheng").
 
 -behaviour(gen_server).

src/efka_sup.erl

@@ -92,12 +92,12 @@ init([]) ->
         },
 
         #{
-            id => 'efka_task_reporter',
+            id => 'docker_task_reporter',
-            start => {'efka_task_reporter', start_link, []},
+            start => {'docker_task_reporter', start_link, []},
             restart => permanent,
             shutdown => 2000,
             type => worker,
-            modules => ['efka_task_reporter']
+            modules => ['docker_task_reporter']
         },
 
         #{