feat(api): add healthcheck routes (#191)

api-contracts/openapi/openapi.yaml

@@ -20,6 +20,10 @@ components:
   schemas:
     $ref: "./components/schemas/_index.yaml"
 paths:
+  /api/ready:
+    $ref: "./paths/metadata/metadata.yaml#/readiness"
+  /api/live:
+    $ref: "./paths/metadata/metadata.yaml#/liveness"
   /api/v1/meta:
     $ref: "./paths/metadata/metadata.yaml#/metadata"
   /api/v1/meta/integrations:

api-contracts/openapi/paths/metadata/metadata.yaml

@@ -1,3 +1,29 @@
+readiness:
+  get:
+    description: Gets the readiness status
+    operationId: readiness:get
+    responses:
+      "200":
+        description: Healthy
+      "500":
+        description: Not ready to accept traffic
+    security: []
+    summary: Get readiness
+    tags:
+      - Healthcheck
+liveness:
+  get:
+    description: Gets the liveness status
+    operationId: liveness:get
+    responses:
+      "200":
+        description: Healthy
+      "500":
+        description: Not liveness
+    security: []
+    summary: Get liveness
+    tags:
+      - Healthcheck
 metadata:
   get:
     description: Gets metadata for the Hatchet instance

api/v1/server/handlers/metadata/health.go

@@ -0,0 +1,25 @@
+package metadata
+
+import (
+	"fmt"
+
+	"github.com/labstack/echo/v4"
+
+	"github.com/hatchet-dev/hatchet/api/v1/server/oas/gen"
+)
+
+func (u *MetadataService) LivenessGet(ctx echo.Context, request gen.LivenessGetRequestObject) (gen.LivenessGetResponseObject, error) {
+	return gen.LivenessGet200Response{}, nil
+}
+
+func (u *MetadataService) ReadinessGet(ctx echo.Context, request gen.ReadinessGetRequestObject) (gen.ReadinessGetResponseObject, error) {
+	if !u.config.Repository.Health().IsHealthy() {
+		return nil, fmt.Errorf("repository is not healthy")
+	}
+
+	if !u.config.TaskQueue.IsReady() {
+		return nil, fmt.Errorf("task queue is not healthy")
+	}
+
+	return gen.ReadinessGet200Response{}, nil
+}