Module logs 

agents logs — persisted log tier. Leaves:

• open --id <id> — look up a single logged row by its logs.messages."index".
• list --all | --pending — stream logged rows for the targets: --all is every row, --pending is the unfinalized rows only.
• subscribe — long-lived stream of new rows as they land.

Modules

list

agents logs read all — fetch every log row for a target AIH, coalesced into ResponseItem blocks.

open

agents logs read id — fetch one logged row by its logs.messages."index" BIGSERIAL. The handler resolves the row’s target table via the logs.message_table discriminator and returns a typed Response variant carrying that table’s payload — no serde_json::Value anywhere in the public shape.

subscribe

agents logs read subscribe — the live cousin of agents logs read pending. Same Vec<Target> input + same parts-grouped block output, but with a first-ping-or-go-inactive wait loop. Returns either a real block (the EXACT same JSON shape read all / read pending emit) OR the literal string "agents_inactive" when no target has a live agent to wait on.

Enums

Command

Request

ResponseItem

Functions

execute

execute_transform