Struct DeclaredCommandExecutor 

pub struct DeclaredCommandExecutor { /* private fields */ }

Executes a declared body at the server: the process-group-contained command, its transcript, its cancel-path registration, and the bound the dispatch authored. Owns no routing decision — a caller has already looked the body up — so it is the ONE implementation both the direct dispatch decorator above and the outbox row decorator (super::declared_body_outbox) run, and the two paths cannot execute a body differently.

Implementations

impl DeclaredCommandExecutor

pub fn new( attempts: DeclaredCommandAttempts, tokio: Handle, workspace_root: WorkspaceRoot, transcript: ActivityEventPublisher, ) -> Self

Build an executor: registering every attempt it executes in attempts so the run’s cancel can reach it, expanding {workspace_root} with the server-resolved workspace_root, and streaming each executed command’s output onto transcript.

pub fn execute( &self, request: &ActivityDispatch, contract: &ActionBodyContract, ) -> Result<String, String>

Run the body contract declares for request and encode how the attempt ended onto the FFI string contract — the same string the direct path returns to the engine, produced by the same code.

Errors

The prefixed failure string (terminal: / retryable: / policy_refused: / timeout:), or the parked-activity sentinel when this server is draining and starts no new work.