egommerce/catalog-service
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Fixed entrypoints
All checks were successful
ci/woodpecker/push/workflow Pipeline was successful
Details

Browse Source
This commit is contained in:
Piotr Biernat
2025-11-05 15:26:17 +01:00
parent 8262d6c672
commit a23c289e80
2 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/cmd/scheduler/main.go
View File

@@ -15,10 +15,11 @@ func main() {
}
cnf := app.NewConfig("catalog-scheduler")
a := app.NewApp(app.NewScheduler(cnf))
a.RegisterPlugin(app.CachePlugin(cnf))
a.RegisterPlugin(app.DatabasePlugin(cnf))
a.RegisterPlugin(app.EventbusPlugin(cnf))
srv := app.NewScheduler(cnf)
a := app.NewApp(srv)
a.RegisterPlugin(app.CachePlugin(cnf, srv))
a.RegisterPlugin(app.DatabasePlugin(cnf, srv))
a.RegisterPlugin(app.EventbusPlugin(cnf, srv))
while := make(chan struct{})
err := a.Start(while)

9
src/cmd/worker/main.go
View File

@@ -15,10 +15,11 @@ func main() {
}
cnf := app.NewConfig("catalog-worker")
a := app.NewApp(app.NewWorker(cnf))
a.RegisterPlugin(app.CachePlugin(cnf))
a.RegisterPlugin(app.DatabasePlugin(cnf))
a.RegisterPlugin(app.EventbusPlugin(cnf))
srv := app.NewWorker(cnf)
a := app.NewApp(srv)
a.RegisterPlugin(app.CachePlugin(cnf, srv))
a.RegisterPlugin(app.DatabasePlugin(cnf, srv))
a.RegisterPlugin(app.EventbusPlugin(cnf, srv))
while := make(chan struct{})
err := a.Start(while)