List the event catalog
curl --request GET \
--url https://streaming-hub.sandbox.lerian.net/v1/catalog \
--header 'Authorization: Bearer <token>'package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://streaming-hub.sandbox.lerian.net/v1/catalog"
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/catalog', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));import requests
url = "https://streaming-hub.sandbox.lerian.net/v1/catalog"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text){
"events": [
{
"eventKey": "transaction.posted",
"source": "ledger",
"resourceType": "transaction",
"eventType": "posted",
"topic": "lerian.streaming.ledger",
"schemaVersion": "1.0.0",
"schemaMajor": 1,
"description": "A transaction was posted.",
"dataSchema": "https://schemas.example.com/transaction/posted/1.json"
}
],
"producers": [
{
"target": "ledger.internal",
"source": "ledger",
"fetched_at": "2026-06-02T09:00:00Z",
"last_refresh_failed_at": "2026-06-04T09:00:00Z",
"last_refresh_error_class": "fetch_failed"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}List the event catalog
Returns the manifest-fed catalog snapshot — the last-known-good aggregation of the producer manifests Streaming Hub tracks. The catalog is global in v1 (byte-identical regardless of which tenant authenticates) and control-plane only; the data plane never consults it. An empty snapshot returns 200 with events: [] (fail-closed to last-known-good — never an error on an empty catalog).
GET
/
v1
/
catalog
List the event catalog
curl --request GET \
--url https://streaming-hub.sandbox.lerian.net/v1/catalog \
--header 'Authorization: Bearer <token>'package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://streaming-hub.sandbox.lerian.net/v1/catalog"
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/catalog', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));import requests
url = "https://streaming-hub.sandbox.lerian.net/v1/catalog"
headers = {"Authorization": "Bearer <token>"}
response = requests.get(url, headers=headers)
print(response.text){
"events": [
{
"eventKey": "transaction.posted",
"source": "ledger",
"resourceType": "transaction",
"eventType": "posted",
"topic": "lerian.streaming.ledger",
"schemaVersion": "1.0.0",
"schemaMajor": 1,
"description": "A transaction was posted.",
"dataSchema": "https://schemas.example.com/transaction/posted/1.json"
}
],
"producers": [
{
"target": "ledger.internal",
"source": "ledger",
"fetched_at": "2026-06-02T09:00:00Z",
"last_refresh_failed_at": "2026-06-04T09:00:00Z",
"last_refresh_error_class": "fetch_failed"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}{
"title": "Not Found",
"status": 404,
"type": "https://errors.lerian.studio/v1/not_found",
"detail": "subscription not found",
"code": "not_found",
"instance": "4bf92f3577b34da6a3ce929d0e0e4736",
"errors": [
{
"location": "event_types/2",
"message": "\"transaction.creatd\" has no catalog entry at schema major 1"
}
]
}Autorizações
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.
Resposta
The catalog snapshot.
The catalog entries, ordered by topic, schema major, event type, and resource type. An event published at several majors appears once per major. Empty when the snapshot is empty.
Show child attributes
Show child attributes
The refresh freshness of each producer the hub tracks, ordered by target. Join an event to its producer on source. Always present; an empty list is [].
Show child attributes
Show child attributes
Esta página foi útil?