Struct WorkerBuilder 

pub struct WorkerBuilder { /* private fields */ }

Builder for configuring and creating a Worker.

Examples

use std::sync::Arc;
use std::time::Duration;
use ironflow_worker::WorkerBuilder;
use ironflow_core::providers::claude::ClaudeCodeProvider;

let worker = WorkerBuilder::new("http://localhost:3000", "my-token")
    .provider(Arc::new(ClaudeCodeProvider::new()))
    .concurrency(4)
    .poll_interval(Duration::from_secs(2))
    .build()?;

worker.run().await?;

Implementations

impl WorkerBuilder

pub fn new(api_url: &str, worker_token: &str) -> Self

Create a new builder targeting the given API server.

pub fn provider(self, provider: Arc<dyn AgentProvider>) -> Self

Set the agent provider for AI operations.

pub fn register(self, handler: impl WorkflowHandler + 'static) -> Self

Register a workflow handler.

pub fn concurrency(self, n: usize) -> Self

Set the maximum number of concurrent workflow executions.

pub fn poll_interval(self, interval: Duration) -> Self

Set the interval between polls for new runs.

pub fn build(self) -> Result<Worker, WorkerError>

Build the worker.

Errors

Returns WorkerError::Internal if no provider has been set. Returns WorkerError::Engine if a handler registration fails.