Skip to main content

Module request

Module request 

Source
Expand description

user request — broadcast an outbound request to every connected user stream (GET /user) and BLOCK until the first ACCEPTED reply (or the base --timeout elapses).

The daemon holds the request PENDING even with zero connected streams — a user surface that connects later receives it on replay. An optional --validate-python snippet gates replies: it runs with the full reply ({"identity": …, "reply": …}) as its input and must end in a trailing expression evaluating True for the reply to be accepted; anything else (False, no output, an exception) rejects it and the request stays pending. Without the base --timeout the wait is UNCAPPED.

Modules§

request_schema
response_schema

Structs§

Args
Command
ListenerExecution
One /listen broadcast run of user request: the actual Request, the producer’s AgentArguments, and the unary response future. See crate::cli::broadcast_listener.
Request
Response
The winning reply.

Enums§

Path
Schema

Functions§

execute
execute_transform