99"time" 
1010
1111"print-service/internal/core/services" 
12+ "print-service/internal/infrastructure/logger" 
1213"print-service/internal/pkg/config" 
1314"print-service/internal/pkg/pool" 
14- "print-service/internal/infrastructure/logger" 
1515)
1616
1717func  main () {
@@ -22,23 +22,23 @@ func main() {
2222}
2323
2424// Initialize logger 
25- logger  :=  logger .NewStructuredLogger (cfg .Logger )
26- defer  logger .Sync ()
25+ log  :=  logger .NewStructuredLogger (& cfg .Logger )
26+ defer  func () {  _   =   log .Sync () } ()
2727
2828// Create worker pool 
29- workerPool  :=  pool .NewWorkerPool (cfg .Worker .PoolSize , logger )
29+ workerPool  :=  pool .NewWorkerPool (cfg .Worker .PoolSize , log )
3030
3131// Initialize queue service 
32- queueService , err  :=  services .NewQueueService (cfg .Queue , logger )
32+ queueService , err  :=  services .NewQueueService (cfg .Queue , log )
3333if  err  !=  nil  {
34- logger .Error ("Failed to initialize queue service" , "error" , err )
34+ log .Error ("Failed to initialize queue service" , "error" , err )
3535os .Exit (1 )
3636}
3737
3838// Initialize print service 
39- printService , err  :=  services .NewPrintService (cfg .Print , logger )
39+ printService , err  :=  services .NewPrintService (cfg .Print , log )
4040if  err  !=  nil  {
41- logger .Error ("Failed to initialize print service" , "error" , err )
41+ log .Error ("Failed to initialize print service" , "error" , err )
4242os .Exit (1 )
4343}
4444
@@ -53,21 +53,21 @@ func main() {
5353
5454// Start queue consumer 
5555go  func () {
56- logger .Info ("Starting queue consumer" )
56+ log .Info ("Starting queue consumer" )
5757if  err  :=  queueService .StartConsumer (ctx , workerPool .Submit ); err  !=  nil  {
58- logger .Error ("Queue consumer failed" , "error" , err )
58+ log .Error ("Queue consumer failed" , "error" , err )
5959cancel ()
6060}
6161}()
6262
63- logger .Info ("Worker started" , "pool_size" , cfg .Worker .PoolSize )
63+ log .Info ("Worker started" , "pool_size" , cfg .Worker .PoolSize )
6464
6565// Wait for interrupt signal 
6666quit  :=  make (chan  os.Signal , 1 )
6767signal .Notify (quit , syscall .SIGINT , syscall .SIGTERM )
6868<- quit 
6969
70- logger .Info ("Shutting down worker..." )
70+ log .Info ("Shutting down worker..." )
7171
7272// Cancel context to stop all workers 
7373cancel ()
@@ -79,5 +79,5 @@ func main() {
7979workerPool .Stop (shutdownCtx )
8080queueService .Stop (shutdownCtx )
8181
82- logger .Info ("Worker exited" )
82+ log .Info ("Worker exited" )
8383}
0 commit comments