补全api、rpc在k8s中读取当前环境变量

app/mqueue/cmd/job/mqueue.go

@@ -19,7 +19,7 @@ func main() {
 	flag.Parse()
 	var c config.Config
 
-	conf.MustLoad(*configFile, &c)
+	conf.MustLoad(*configFile, &c, conf.UseEnv())
 
 	// log、prometheus、trace、metricsUrl
 	if err := c.SetUp(); err != nil {
@@ -28,15 +28,13 @@ func main() {
 
 	//logx.DisableStat()
 
-
 	svcContext := svc.NewServiceContext(c)
 	ctx := context.Background()
 	cronJob := logic.NewCronJob(ctx, svcContext)
 	mux := cronJob.Register()
 
-
 	if err := svcContext.AsynqServer.Run(mux); err != nil {
-		logx.WithContext(ctx).Errorf("!!!CronJobErr!!! run err:%+v",err)
+		logx.WithContext(ctx).Errorf("!!!CronJobErr!!! run err:%+v", err)
 		os.Exit(1)
 	}
 }