Graceful shutdown

Setiap deploy mematikan container lama. Tanpa penutupan yang rapi, setiap deploy juga memotong setiap permintaan yang sedang berjalan — dan di ECS itu terjadi puluhan kali sehari.

Bentuk lengkapnya

func main() {
	// SIGINT (Ctrl-C) dan SIGTERM (ECS, Kubernetes) → pembatalan context.
	ctx, hentikanSinyal := signal.NotifyContext(context.Background(),
		os.Interrupt, syscall.SIGTERM)
	defer hentikanSinyal()

	srv := &http.Server{Addr: ":8080", Handler: handler, /* timeout ... */}

	go func() {
		if err := srv.ListenAndServe(); err != nil &&
			!errors.Is(err, http.ErrServerClosed) {
			log.Error("server berhenti tak terduga", "err", err)
			hentikanSinyal()
		}
	}()
	log.Info("server siap", "addr", srv.Addr)

	<-ctx.Done()                       // menunggu sinyal
	hentikanSinyal()                    // sinyal kedua = mati paksa
	log.Info("sinyal berhenti diterima, menutup rapi")

	// 1. Beri load balancer waktu menyadari kita mau berhenti.
	siap.Store(false)                   // /siap mulai membalas 503
	time.Sleep(5 * time.Second)

	// 2. Tutup server HTTP: tolak koneksi baru, tunggu yang berjalan.
	ctxMati, batal := context.WithTimeout(context.Background(), 20*time.Second)
	defer batal()

	if err := srv.Shutdown(ctxMati); err != nil {
		log.Error("shutdown melebihi tenggat, memutus paksa", "err", err)
		_ = srv.Close()
	}

	// 3. Hentikan pekerja latar, lalu tunggu mereka.
	pekerja.Berhenti()
	pekerja.Tunggu(ctxMati)

	// 4. Terakhir: tutup koneksi keluar.
	db.Close()
	rdb.Close()
	_ = penyedia.Shutdown(ctxMati)      // OpenTelemetry: kirim sisa trace

	log.Info("selesai")
}

Kenapa harus tidur dulu

t=0.0  ECS mengirim SIGTERM
t=0.0  ❌ Kalau langsung Shutdown():
       ALB masih menganggap task ini sehat dan MASIH mengirim
       permintaan baru → koneksi ditolak → pengguna melihat 502.

t=0.0  ✅ Dengan jeda:
       /siap mulai membalas 503
t=2.0  ALB gagal health check, menandai target unhealthy
t=5.0  ALB berhenti mengirim permintaan baru → baru Shutdown()
t=5–25 Permintaan yang sedang berjalan diselesaikan
t=25   Proses keluar dengan kode 0

Selaras dengan ECS

Dua endpoint kesehatan, bukan satu

// Liveness: "prosesnya masih hidup?" — JANGAN menyentuh database.
mux.HandleFunc("GET /sehat", func(w http.ResponseWriter, r *http.Request) {
	w.WriteHeader(http.StatusOK)
	w.Write([]byte(`{"status":"ok"}`))
})

// Readiness: "boleh dikirimi lalu lintas?" — boleh memeriksa dependensi,
// dan inilah yang berubah saat shutdown dimulai.
mux.HandleFunc("GET /siap", func(w http.ResponseWriter, r *http.Request) {
	if !siap.Load() {
		http.Error(w, "sedang berhenti", http.StatusServiceUnavailable)
		return
	}
	ctx, batal := context.WithTimeout(r.Context(), time.Second)
	defer batal()
	if err := db.PingContext(ctx); err != nil {
		http.Error(w, "database tidak siap", http.StatusServiceUnavailable)
		return
	}
	w.WriteHeader(http.StatusOK)
})

Yang membuat shutdown menggantung