mbx_catchup
Catch up on what this identity missed
Bounded history replay for this identity’s mailbox, independent of ack: pages from the stored checkpoint (or an explicit cursor) like mbx_replay. Fetching never advances the checkpoint; after durably capturing a page, pass its next_cursor as commit to advance (monotonic, never a rewind; re-committing the same cursor is a no-op). Catch-up never acks, never marks read, and grants no authority; mbx_inbox stays the what-needs-handling view. restart re-anchors after a store restore/reset: “all” replays from the beginning, “now” skips to the current end. Next: mbx_inbox for what needs handling, then mbx_reply/mbx_ack per message.
Annotations
Section titled “Annotations”| Field | Value |
|---|---|
idempotentHint |
false |
execution.taskSupport |
"forbidden" |
| Parameter | Type | Required | Default | Constraints | Description |
|---|---|---|---|---|---|
cursor |
string |
no | length ≤ 2048; pattern ^[A-Za-z0-9_-]+$ |
page cursor from a previous mbx_catchup or mbx_replay page of this mailbox | |
limit |
integer |
no | 1–200 | ||
max_bytes |
integer |
no | 2048–262144 | ||
commit |
string |
no | length ≤ 2048 | next_cursor of a page you have durably captured; advances the checkpoint | |
restart |
string |
no | one of all, now |
explicit re-anchor after CURSOR_EXPIRED (store restored or reset) |
Input JSON schema
Section titled “Input JSON schema”{ "$schema": "http://json-schema.org/draft-07/schema#", "type": "object", "properties": { "cursor": { "description": "page cursor from a previous mbx_catchup or mbx_replay page of this mailbox", "type": "string", "maxLength": 2048, "pattern": "^[A-Za-z0-9_-]+$" }, "limit": { "type": "integer", "minimum": 1, "maximum": 200 }, "max_bytes": { "type": "integer", "minimum": 2048, "maximum": 262144 }, "commit": { "description": "next_cursor of a page you have durably captured; advances the checkpoint", "type": "string", "maxLength": 2048 }, "restart": { "description": "explicit re-anchor after CURSOR_EXPIRED (store restored or reset)", "type": "string", "enum": [ "all", "now" ] } }}