pub struct WorkflowRunRouterBuilder { /* private fields */ }Expand description
Builds the run-service router (POST /runs, GET /runs/{id}).
Implementations§
Source§impl WorkflowRunRouterBuilder
impl WorkflowRunRouterBuilder
Sourcepub fn with_authenticator(self, authenticator: Arc<dyn Authenticator>) -> Self
pub fn with_authenticator(self, authenticator: Arc<dyn Authenticator>) -> Self
Required — the credential verifier for every route.
Sourcepub fn with_app(self, app: Arc<App>) -> Self
pub fn with_app(self, app: Arc<App>) -> Self
Required — the App that mints an AgentContext per run. Its LLM is
unused (each agent node swaps to its registry model); it supplies the
bus, kv, tools, and memory a run needs.
Sourcepub fn with_registry(self, registry: Registry) -> Self
pub fn with_registry(self, registry: Registry) -> Self
Required — the allow-list a submitted definition compiles against.
Sourcepub fn with_run_store(self, run_store: RunStore) -> Self
pub fn with_run_store(self, run_store: RunStore) -> Self
Required — the run-status poll cache.
Sourcepub fn with_provenance(self, provenance: Arc<dyn ProvenanceRepository>) -> Self
pub fn with_provenance(self, provenance: Arc<dyn ProvenanceRepository>) -> Self
Required — the durable, authoritative audit chain. Audit is mandatory;
Self::build errors without it. Supply a durable
SqliteProvenanceRepository::open(path) in production.
Sourcepub fn with_run_timeout(self, timeout: Duration) -> Self
pub fn with_run_timeout(self, timeout: Duration) -> Self
Override the per-run wall-clock cap. Defaults to MAX_RUN_DURATION.
Sourcepub fn with_max_concurrent_runs(self, max: usize) -> Self
pub fn with_max_concurrent_runs(self, max: usize) -> Self
Override the concurrency cap. Defaults to MAX_CONCURRENT_RUNS.
Sourcepub fn build(self) -> Result<Router, WorkflowRunBuilderError>
pub fn build(self) -> Result<Router, WorkflowRunBuilderError>
Assemble the router.
§Errors
Returns a WorkflowRunBuilderError variant naming the first
required port that was not configured.