feat(api): Add health check endpoint for services

Author: saulmaldonado

api/routers/routers.go

@@ -10,10 +10,14 @@ import (
 
 	"agones-minecraft/config"
 	v1Controllers "agones-minecraft/controllers/api/v1"
+	"agones-minecraft/db"
 	apiErr "agones-minecraft/middleware/errors"
 	"agones-minecraft/middleware/jwt"
 	ginzap "agones-minecraft/middleware/log"
 	"agones-minecraft/middleware/session"
+	jwtServicev1 "agones-minecraft/services/auth/jwt"
+	"agones-minecraft/services/k8s/agones"
+
 	twitchMiddleware "agones-minecraft/middleware/twitch"
 )
 
@@ -28,7 +32,28 @@ func NewRouter() *gin.Engine {
 	engine.Use(ginzap.RecoveryWithZap(zap.L(), false))
 
 	engine.GET("/health", func(c *gin.Context) {
-		c.JSON(http.StatusOK, gin.H{"status": "ok"})
+		var database bool
+		var memorystore bool
+		var cluster bool
+
+		if err := db.Ping(); err == nil {
+			database = true
+		}
+
+		if err := jwtServicev1.Get().Ping(); err == nil {
+			memorystore = true
+		}
+
+		if err := agones.Client().Ping(); err == nil {
+			cluster = true
+		}
+
+		c.JSON(http.StatusOK, gin.H{
+			"api":         true,
+			"database":    database,
+			"memorystore": memorystore,
+			"cluster":     cluster,
+		})
 	})
 
 	AddV1Router(engine)

api/services/auth/jwt/store.go

@@ -69,5 +69,8 @@ func (r *RedisStore) Delete(userId string) error {
 }
 
 func (r *RedisStore) Ping() error {
-	return r.redis.Ping(context.Background()).Err()
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
+	defer cancel()
+
+	return r.redis.Ping(ctx).Err()
 }

api/services/k8s/agones/agones.go

@@ -70,6 +70,23 @@ func New(config *rest.Config) (*AgonesClient, error) {
 	return &AgonesClient{agonesClient, gameServerInformer, recordStore}, nil
 }
 
+func (c *AgonesClient) Ping() error {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
+	defer cancel()
+
+	res, err := c.clientSet.RESTClient().Get().AbsPath("/healthz").DoRaw(ctx)
+	if err != nil {
+		return err
+	}
+
+	content := string(res)
+	if content != "ok" {
+		return fmt.Errorf("not ok, error: %s", content)
+	}
+
+	return nil
+}
+
 // Gets a GameServer by name
 func (c *AgonesClient) Get(serverName string) (*agonesv1.GameServer, error) {
 	return c.informer.Lister().GameServers(metav1.NamespaceDefault).Get(serverName)