app.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. package app
  2. import (
  3. "context"
  4. "github.com/go-nunu/nunu-layout-advanced/pkg/server"
  5. "log"
  6. "os"
  7. "os/signal"
  8. "syscall"
  9. )
  10. type App struct {
  11. name string
  12. servers []server.Server
  13. }
  14. type Option func(a *App)
  15. func NewApp(opts ...Option) *App {
  16. a := &App{}
  17. for _, opt := range opts {
  18. opt(a)
  19. }
  20. return a
  21. }
  22. func WithServer(servers ...server.Server) Option {
  23. return func(a *App) {
  24. a.servers = servers
  25. }
  26. }
  27. func WithName(name string) Option {
  28. return func(a *App) {
  29. a.name = name
  30. }
  31. }
  32. func (a *App) Run(ctx context.Context) error {
  33. var cancel context.CancelFunc
  34. ctx, cancel = context.WithCancel(ctx)
  35. defer cancel()
  36. signals := make(chan os.Signal, 1)
  37. signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM)
  38. for _, srv := range a.servers {
  39. go func(srv server.Server) {
  40. err := srv.Start(ctx)
  41. if err != nil {
  42. log.Printf("Server start err: %v", err)
  43. }
  44. }(srv)
  45. }
  46. select {
  47. case <-signals:
  48. // Received termination signal
  49. log.Println("Received termination signal")
  50. case <-ctx.Done():
  51. // Context canceled
  52. log.Println("Context canceled")
  53. }
  54. // Gracefully stop the servers
  55. for _, srv := range a.servers {
  56. err := srv.Stop(ctx)
  57. if err != nil {
  58. log.Printf("Server stop err: %v", err)
  59. }
  60. }
  61. return nil
  62. }