List subscriptions

curl --request GET \
  --url https://streaming-hub.sandbox.lerian.net/v1/subscriptions \
  --header 'Authorization: Bearer <token>'

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://streaming-hub.sandbox.lerian.net/v1/subscriptions"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://streaming-hub.sandbox.lerian.net/v1/subscriptions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "subscriptions": [
    {
      "id": "0192f1a0-0000-7000-8000-00000000c001",
      "name": "orders-webhook",
      "sink_kind": "webhook",
      "endpoint_display": "https://hooks.example.com",
      "signature_version": 1,
      "plan_tier": "standard",
      "enabled": true,
      "verification_state": "pending_verification",
      "credential_kind": "signing_secret",
      "secret_configured": true,
      "secret_rotated_at": "2026-01-15T12:00:00Z",
      "secret_overlap_until": "2026-01-16T12:00:00Z",
      "created_at": "2026-01-15T12:00:00Z",
      "updated_at": "2026-01-15T12:00:00Z",
      "event_types": [
        "account.created",
        "account.updated"
      ],
      "origin": "midaz",
      "timeout_ms": 20000,
      "schema_major": 2,
      "delegated_scope": "Rk9ORE8tQQ=="
    }
  ],
  "next_cursor": "0192f1a0-0000-7000-8000-00000000c002"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "code": 503,
  "title": "service_unavailable",
  "message": "rate limiter temporarily unavailable"
}

GET

subscriptions

List subscriptions

curl --request GET \
  --url https://streaming-hub.sandbox.lerian.net/v1/subscriptions \
  --header 'Authorization: Bearer <token>'

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://streaming-hub.sandbox.lerian.net/v1/subscriptions"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://streaming-hub.sandbox.lerian.net/v1/subscriptions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

{
  "subscriptions": [
    {
      "id": "0192f1a0-0000-7000-8000-00000000c001",
      "name": "orders-webhook",
      "sink_kind": "webhook",
      "endpoint_display": "https://hooks.example.com",
      "signature_version": 1,
      "plan_tier": "standard",
      "enabled": true,
      "verification_state": "pending_verification",
      "credential_kind": "signing_secret",
      "secret_configured": true,
      "secret_rotated_at": "2026-01-15T12:00:00Z",
      "secret_overlap_until": "2026-01-16T12:00:00Z",
      "created_at": "2026-01-15T12:00:00Z",
      "updated_at": "2026-01-15T12:00:00Z",
      "event_types": [
        "account.created",
        "account.updated"
      ],
      "origin": "midaz",
      "timeout_ms": 20000,
      "schema_major": 2,
      "delegated_scope": "Rk9ORE8tQQ=="
    }
  ],
  "next_cursor": "0192f1a0-0000-7000-8000-00000000c002"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "title": "Not Found",
  "status": 404,
  "type": "https://errors.lerian.studio/v1/not_found",
  "detail": "subscription not found",
  "code": "not_found"
}

{
  "code": 503,
  "title": "service_unavailable",
  "message": "rate limiter temporarily unavailable"
}

Authorizations

Authorization

string

header

required

A bearer JWT issued by Access Manager. The /v1 surface never reads a tenant from the body, path, or query. Machine callers obtain a token with the Access Manager client-credentials flow. The /admin surface authorizes against an operator scope and carries no tenant context.

Query Parameters

sink_kind

enum<string>

Optional filter restricting results to one sink kind. Any other value returns 422 validation_error. The delivery destination kind. webhook posts signed HTTPS requests; pull exposes an inbox read over GET /v1/events; sqs, rabbitmq, and eventbridge fan out to the named queue or bus.

Available options:

webhook,

pull,

sqs,

rabbitmq,

eventbridge

limit

integer

Page size, clamped to a server maximum. A non-positive value uses the server default.

after

string

Keyset cursor — the id of the last row from the previous page (subscriptions are ordered DESC by id). A value that is not a UUID returns 422 validation_error.

name

string

Optional exact-name filter, trimmed before matching. It matches in your scope, the same scope the create checks for a name conflict, so a hit is a page of one. A value that is only whitespace returns 422 validation_error.

enabled

boolean

Optional filter on the enabled flag, true or false. Any other value returns 422 validation_error.

verification_state

enum<string>

Optional filter on the verification state. The subscription's position in the destination verification state machine. Only an active subscription is deliverable. A pull subscription is born active — it has no destination to probe. Every other kind is born pending_verification and reaches active on a successful probe: POST /v1/subscriptions/{id}/ping for a webhook, and PUT /v1/subscriptions/{id}/credential for any queue sink (sqs, rabbitmq, eventbridge). An sqs or eventbridge sink has a second path: register a delegated grant — which persists the coordinates and leaves this field unchanged — then call POST /v1/subscriptions/{id}/verify. An active subscription whose probe later fails becomes degraded. The same successful probe returns this field to active. This field is one half of deliverability: enabled is the other half, and both must hold. No probe changes enabled except POST /v1/subscriptions/{id}/verify, which on a probe success clears an auto-disable in the same transaction as the state move.

Available options:

pending_verification,

active,

degraded

Response

A page of subscriptions.

subscriptions

object[]

required

Show child attributes

next_cursor

string

required

Keyset cursor for the next page (the id of the last row). Non-empty only on a full page; an empty string marks the final page.

Example:

"0192f1a0-0000-7000-8000-00000000c002"

Catalog

Subscriptions

Event Delivery

Dashboard

Admin

Operational

Error handling

List subscriptions

Authorizations

Query Parameters

Response