Graceful Shutdown Go App

graceful_shutdown.go

package main

// operation is a clean up function on shutting down
type operation func(ctx context.Context) error

// gracefulShutdown waits for termination syscalls and doing clean up operations after received it
func gracefulShutdown(ctx context.Context, timeout time.Duration, ops map[string]operation) <-chan struct{} {
	wait := make(chan struct{})
	go func() {
		s := make(chan os.Signal, 1)

		// add any other syscalls that you want to be notified with
		signal.Notify(s, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
		<-s

		log.Println("shutting down")

    // set timeout for the ops to be done to prevent system hang
		timeoutFunc := time.AfterFunc(timeout, func() {
			log.Printf("timeout %d ms has been elapsed, force exit", timeout.Milliseconds())
			os.Exit(0)
		})

		defer timeoutFunc.Stop()

		var wg sync.WaitGroup

		// Do the operations asynchronously to save time
		for key, op := range ops {
			wg.Add(1)
			innerOp := op
			innerKey := key
			go func() {
				defer wg.Done()

				log.Printf("cleaning up: %s", innerKey)
				if err := innerOp(ctx); err != nil {
					log.Printf("%s: clean up failed: %s", innerKey, err.Error())
          return
				}
        
        log.Printf("%s was shutdown gracefully", innerKey)
			}()
		}

		wg.Wait()

		close(wait)
	}()

	return wait
}

main.go

package main

func main() {
  // initialize some resources
  // e.g: 
  // db, err := database.Initialize()
  // server, err := http.Initialize()
  
  // wait for termination signal and register database & http server clean-up operations
  wait := gracefulShutdown(context.Background(), 2 * time.Second, map[string]operation{
    "database": func(ctx context.Context) error {
      return db.Shutdown()
		},
    "http-server": func(ctx context.Context) error {
      return server.Shutdown()
		},
	// Add other cleanup operations here
  })
  
  <-wait
}

is it possible to modify this to use -

// NotifyContext
ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)