Module pending 

agents queue read pending — stream every pending (i.e. active = TRUE) message_queue row for the resolved targets, coalesced into parts-grouped ResponseItem blocks. Symmetric with agents logs read all’s ClientNotification shape — same Target input, same per-part type tag, same id shape (an i64 you pass to the matching read id verb to drill into the body).

Re-exports

pub use super::super::super::logs::read::all::ClientNotificationPartType as QueuePartType;

pub use super::super::super::logs::read::all::Target;

Modules

request_schema

response_schema

Structs

Args

Command

QueuePart

One row inside a ResponseItem block — a message_queue_contents entry. The id is the message_queue_contents.id, which you pass to agents queue read id <n> to drill into the body. timestamp_queued is on the enclosing block, not here (one block = one message_queue parent row, sharing one enqueued_at).

Request

Enums

Path

ResponseItem

One pending message_queue row, with its content rows grouped as parts. Two variants — direct AIH target or tag target — both flat (no nested LookupState).

Schema

Functions

execute

execute_transform