rogee/atom
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add queue

Browse Source
This commit is contained in:
yanghao05
2023-06-19 10:14:30 +08:00
parent d9d62a0bab
commit 6b3bc9d944
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmd_root.go
View File

@@ -19,11 +19,13 @@ var (
GroupRoutesName = "routes" GroupRoutesName = "routes"
GroupGrpcServerServiceName = "grpc_server_services" GroupGrpcServerServiceName = "grpc_server_services"
GroupCommandName = "command_services" GroupCommandName = "command_services"
GroupQueueName = "queue_handler"
GroupInitial = dig.Group(GroupInitialName) GroupInitial = dig.Group(GroupInitialName)
GroupRoutes = dig.Group(GroupRoutesName) GroupRoutes = dig.Group(GroupRoutesName)
GroupGrpcServer = dig.Group(GroupGrpcServerServiceName) GroupGrpcServer = dig.Group(GroupGrpcServerServiceName)
GroupCommand = dig.Group(GroupCommandName) GroupCommand = dig.Group(GroupCommandName)
GroupQueue = dig.Group(GroupQueueName)
) )
func Serve(providers container.Providers, opts ...Option) error { func Serve(providers container.Providers, opts ...Option) error {

8
utils/cli/cil.go Normal file
View File

@@ -0,0 +1,8 @@
package cli
func Tap[T any](cmd *T, funcs ...func(*T)) *T {
for _, f := range funcs {
f(cmd)
}
return cmd
}