[ardabot] SDK changes for upstash/qstash-server#884

client.go

@@ -123,6 +123,10 @@ func (c *Client) Queues() *Queues {
 	return &Queues{client: c}
 }
 
+func (c *Client) Readiness() *Readiness {
+	return &Readiness{client: c}
+}
+
 type requestOptions struct {
 	method string
 	path   string

readiness.go

@@ -0,0 +1,30 @@
+package qstash
+
+import (
+	"net/http"
+)
+
+// Readiness provides access to the readiness endpoint.
+type Readiness struct {
+	client *Client
+}
+
+// ReadinessResponse represents the response from the readiness endpoint.
+type ReadinessResponse struct {
+	// Ready indicates whether QStash is ready to accept requests.
+	Ready bool `json:"ready"`
+}
+
+// Check retrieves the readiness status of QStash.
+func (r *Readiness) Check() (ReadinessResponse, error) {
+	opts := requestOptions{
+		method: http.MethodGet,
+		path:   "/v2/readiness",
+	}
+	response, _, err := r.client.fetchWith(opts)
+	if err != nil {
+		return ReadinessResponse{}, err
+	}
+	readiness, err := parse[ReadinessResponse](response)
+	return readiness, err
+}

readiness_test.go

@@ -0,0 +1,14 @@
+package qstash
+
+import (
+	"github.com/stretchr/testify/assert"
+	"testing"
+)
+
+func TestReadiness(t *testing.T) {
+	client := NewClientWithEnv()
+
+	readiness, err := client.Readiness().Check()
+	assert.NoError(t, err)
+	assert.True(t, readiness.Ready)
+}