Operational Health

Report the transactional outbox's health

Reports how much work the accounts service’s outbox is holding, broken down by status and event type, and how old the oldest row in each state is. Covers the whole queue rather than one organization, and carries no organization id, account id, payload, vault object or error text: it says how much work is stuck and what kind, not whose. A failed row is terminal and will not be retried, so a non-zero failed count is work the platform has dropped and needs an operator. A processing row older than a few seconds means no worker is running to reclaim it. Readable by a client credential holding the credential:read scope and by an organization admin of a configured internal organization. API keys and every other organization are refused.

GET

accounts

outbox

health

Report the transactional outbox's health

curl --request GET \
  --url https://api.anthid.com/v1/accounts/outbox/health \
  --header 'Authorization: Bearer <token>'

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

fetch('https://api.anthid.com/v1/accounts/outbox/health', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.anthid.com/v1/accounts/outbox/health",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://api.anthid.com/v1/accounts/outbox/health"

	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))

}

require 'uri'
require 'net/http'

url = URI("https://api.anthid.com/v1/accounts/outbox/health")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "completed": 4718,
  "entries": [
    {
      "count": 2,
      "event_type": "credential.deleted",
      "max_attempts": 10,
      "oldest_claimed_at": "2026-08-25T15:08:41Z",
      "oldest_created_at": "2026-08-25T15:07:59Z",
      "status": "failed"
    },
    {
      "count": 1,
      "event_type": "account.created",
      "max_attempts": 0,
      "oldest_claimed_at": null,
      "oldest_created_at": "2026-08-26T11:59:02Z",
      "status": "pending"
    }
  ],
  "failed": 2,
  "oldest_claim_at": null,
  "oldest_failed_at": "2026-08-25T15:07:59Z",
  "oldest_pending_at": "2026-08-26T11:59:02Z",
  "pending": 1,
  "processing": 0
}

"<string>"

"<string>"

"<string>"

"<string>"

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Response

The queue's current health

The queue's health, as the endpoint reports it.

Lives here rather than in api::accounts_api::response with its siblings, because it is built on [OutboxStatus] and [OutboxEventType], which are this service's own Postgres enums and belong to the worker that drains the queue. Moving them into the shared crate to put the response there would hand every other service a vocabulary for a table only this one has.

entries is the raw grouping and the rolled-up fields below are derived from it, rather than the other way round. A reader wanting "how bad is it" gets the totals without doing arithmetic; a reader wanting "what kind of work is stuck" gets the breakdown without a second request.

completed

integer<int64>

required

entries

object[]

required

Every status and event type that has at least one row, counted.

Show child attributes

failed

integer<int64>

required

pending

integer<int64>

required

processing

integer<int64>

required

oldest_claim_at

string<date-time> | null

The oldest outstanding claim.

A processing row is reclaimed after five seconds, so anything much older than that means no worker is running to reclaim it. This is how "the outbox worker is down" looks from the outside.

oldest_failed_at

string<date-time> | null

When the oldest terminally failed row was queued.

failed is terminal: a row reaches it only after the attempt limit, and the claim query deliberately does not take it back. Nothing will retry it, so this figure only ever grows until somebody acts on it.

oldest_pending_at

string<date-time> | null

When the oldest row still waiting was queued.

The figure worth alerting on. A healthy queue drains in under a second, so a pending row minutes old means the worker is behind or gone.

Report the transactional outbox's health

curl --request GET \
  --url https://api.anthid.com/v1/accounts/outbox/health \
  --header 'Authorization: Bearer <token>'

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

fetch('https://api.anthid.com/v1/accounts/outbox/health', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.anthid.com/v1/accounts/outbox/health",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

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

func main() {

	url := "https://api.anthid.com/v1/accounts/outbox/health"

	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))

}

require 'uri'
require 'net/http'

url = URI("https://api.anthid.com/v1/accounts/outbox/health")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "completed": 4718,
  "entries": [
    {
      "count": 2,
      "event_type": "credential.deleted",
      "max_attempts": 10,
      "oldest_claimed_at": "2026-08-25T15:08:41Z",
      "oldest_created_at": "2026-08-25T15:07:59Z",
      "status": "failed"
    },
    {
      "count": 1,
      "event_type": "account.created",
      "max_attempts": 0,
      "oldest_claimed_at": null,
      "oldest_created_at": "2026-08-26T11:59:02Z",
      "status": "pending"
    }
  ],
  "failed": 2,
  "oldest_claim_at": null,
  "oldest_failed_at": "2026-08-25T15:07:59Z",
  "oldest_pending_at": "2026-08-26T11:59:02Z",
  "pending": 1,
  "processing": 0
}

"<string>"

"<string>"

"<string>"

"<string>"

Connections

Organizations

Controls

Accounts

Intents

Ledger

Stream

MCP

Report the transactional outbox's health

Authorizations

Response