feat: add river jobs

2024-12-30 17:16:13 +08:00
parent afba917fcc
commit 492f64904c
4 changed files with 83 additions and 13 deletions
--- a/cmd_root.go
+++ b/cmd_root.go
@@ -14,12 +14,14 @@ var (
 	GroupGrpcServerServiceName = "grpc_server_services"
 	GroupCommandName           = "command_services"
 	GroupQueueName             = "queue_handler"
+	GroupCronJobName           = "cron_jobs"

 	GroupInitial    = dig.Group(GroupInitialName)
 	GroupRoutes     = dig.Group(GroupRoutesName)
 	GroupGrpcServer = dig.Group(GroupGrpcServerServiceName)
 	GroupCommand    = dig.Group(GroupCommandName)
 	GroupQueue      = dig.Group(GroupQueueName)
+	GroupCronJob    = dig.Group(GroupCronJobName)
 )

 func Serve(opts ...Option) error {