From 6b3bc9d9448a75374cec2652737e090d35bfc690 Mon Sep 17 00:00:00 2001 From: yanghao05 Date: Mon, 19 Jun 2023 10:14:30 +0800 Subject: [PATCH] add queue --- cmd_root.go | 2 ++ utils/cli/cil.go | 8 ++++++++ 2 files changed, 10 insertions(+) create mode 100644 utils/cli/cil.go diff --git a/cmd_root.go b/cmd_root.go index b238771..e8b04db 100644 --- a/cmd_root.go +++ b/cmd_root.go @@ -19,11 +19,13 @@ var ( GroupRoutesName = "routes" GroupGrpcServerServiceName = "grpc_server_services" GroupCommandName = "command_services" + GroupQueueName = "queue_handler" GroupInitial = dig.Group(GroupInitialName) GroupRoutes = dig.Group(GroupRoutesName) GroupGrpcServer = dig.Group(GroupGrpcServerServiceName) GroupCommand = dig.Group(GroupCommandName) + GroupQueue = dig.Group(GroupQueueName) ) func Serve(providers container.Providers, opts ...Option) error { diff --git a/utils/cli/cil.go b/utils/cli/cil.go new file mode 100644 index 0000000..8b9bfa9 --- /dev/null +++ b/utils/cli/cil.go @@ -0,0 +1,8 @@ +package cli + +func Tap[T any](cmd *T, funcs ...func(*T)) *T { + for _, f := range funcs { + f(cmd) + } + return cmd +}