executions.protocol
Kde je WebSocket, jak se vyjadřuje odběr a opětovné připojení, co server zapisuje a JSON Schema každé zprávy — odvozeno z typů Rustu, které jej implementují, takže klient validující proti tomuto validuje proti implementaci. OpenAPI nedokáže popsat socket; zde žije tento kontrakt.
Kde je WebSocket, jak se vyjadřuje odběr a opětovné připojení, co server zapisuje a JSON Schema každé zprávy — odvozeno z typů Rustu, které jej implementují, takže klient validující proti tomuto validuje proti implementaci. OpenAPI nedokáže popsat socket; zde žije tento kontrakt.
- query
- behaviorally_verified
- provádění modulů
- #executions
- #control-plane
- #protocol
Zpřístupnění
Kde je tato jedna definice dosažitelná. Absence je explicitní: povrch, který není uveden, ji nenese.
| povrch | jako |
|---|---|
| MCP | nástroj majordomus_execution_protocol zdroj majordomus://executions/protocol |
| HTTP | GET /api/v1/executions/protocol operationId executions.protocol |
| příkazová řádka | majordomus executions protocol |
Schémata
Kanonický vstup a výstup z typů Rustu; schéma nástroje MCP a parametry a odpovědi OpenAPI se odvozují z nich.
vstup · Prázdné
Žádný vstup.
Žádné vlastnosti: schopnost nebere žádný vstup.
JSON Schema
{
"additionalProperties": false,
"description": "No input.",
"title": "Empty",
"type": "object"
}výstup · ProtocolReport
Odpověď
executions.protocol: celá smlouva živého kanálu, odvozená z typů, které ji implementují.| vlastnost | typ | povinné | popis |
|---|---|---|---|
| event_schema | object | ano | JSON Schema události, odvozené z typu v Rustu. |
| event_types | array | ano | Typy událostí, které klient smí přijmout, z jednoho enumu, který je definuje. |
| heartbeat_seconds | integer | ano | Kolik sekund ticha, než server pošle ping. |
| limity | reference | ano | Co úložiště uchovává, aby klient věděl, na co se smí ptát. |
| max_connections | integer | ano | Kolik živých kanálů tento proces obsluhuje současně. |
| max_replay | integer | ano | Kolik uchovaných událostí přehraje omezené spojení, než přejde do živého režimu. |
| protocol_version | string | ano | Verze protokolu událostí, kterým tento server mluví. |
| stream_schema | object | ano | Schéma JSON řídicí zprávy, odvozené z typu Rustu. |
| stream_types | array | ano | Vlastní řídicí zprávy streamu. |
| odběr | array | ano | Jak se předplatné vyjadřuje a co posílá opětovné připojení. |
| websocket | string | ano | Kde je živý kanál: cesta na tomtéž serveru, ne druhý démon. |
JSON Schema
{
"$defs": {
"LimitsView": {
"description": "What this process's execution store keeps.",
"properties": {
"max_events": {
"description": "How many events are retained per execution.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"max_executions": {
"description": "How many executions are remembered.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"max_log_chars": {
"description": "The longest a single log line may be.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"max_running": {
"description": "How many executions run at once.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"max_subscriber_queue": {
"description": "How far a live channel may fall behind before it is told to resynchronise.",
"format": "uint",
"minimum": 0,
"type": "integer"
}
},
"required": [
"max_executions",
"max_events",
"max_log_chars",
"max_running",
"max_subscriber_queue"
],
"type": "object"
},
"ParameterView": {
"description": "One query parameter of the live channel.",
"properties": {
"description": {
"description": "What it does.",
"type": "string"
},
"name": {
"description": "Its name.",
"type": "string"
},
"required": {
"description": "Whether it must be given.",
"type": "boolean"
}
},
"required": [
"name",
"description",
"required"
],
"type": "object"
}
},
"description": "The answer of `executions.protocol`: the live channel's whole contract, derived from\nthe types that implement it.",
"properties": {
"event_schema": {
"description": "The JSON Schema of an event, derived from the Rust type."
},
"event_types": {
"description": "The event types a client may receive, from the one enum that defines them.",
"items": {
"type": "string"
},
"type": "array"
},
"heartbeat_seconds": {
"description": "How many seconds of quiet before the server pings.",
"format": "uint64",
"minimum": 0,
"type": "integer"
},
"limits": {
"$ref": "#/$defs/LimitsView",
"description": "What the store keeps, so a client knows what it may ask for."
},
"max_connections": {
"description": "How many live channels this process serves at once.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"max_replay": {
"description": "How many retained events a scoped connection replays before going live.",
"format": "uint",
"minimum": 0,
"type": "integer"
},
"protocol_version": {
"description": "The version of the event protocol this server speaks.",
"type": "string"
},
"stream_schema": {
"description": "The JSON Schema of a control message, derived from the Rust type."
},
"stream_types": {
"description": "The stream's own control messages.",
"items": {
"type": "string"
},
"type": "array"
},
"subscription": {
"description": "How the subscription is expressed, and what a reconnect sends.",
"items": {
"$ref": "#/$defs/ParameterView"
},
"type": "array"
},
"websocket": {
"description": "Where the live channel is: a path on this same server, not a second daemon.",
"type": "string"
}
},
"required": [
"protocol_version",
"websocket",
"subscription",
"heartbeat_seconds",
"max_connections",
"max_replay",
"event_types",
"stream_types",
"event_schema",
"stream_schema",
"limits"
],
"title": "ProtocolReport",
"type": "object"
}Politiky
- benchmark
- povinné — cíl na každém transportu, který expozice deklaruje; případy jsou ty ze vstupního typu
- cache
- vypnuto — každé volání spustí handler
Cíle benchmarku
Odvozeno z registru pro tento repozitář: jeden požadavek na transport a případy, které poskytuje typ vstupu. Celá matice je na stránce měření výkonu.