Struct WorkerConfig 

pub struct WorkerConfig {
    pub backend: BackendConfig,
    pub worker_id: WorkerId,
    pub worker_instance_id: WorkerInstanceId,
    pub namespace: Namespace,
    pub lanes: Vec<LaneId>,
    pub capabilities: Vec<String>,
    pub lease_ttl_ms: u64,
    pub claim_poll_interval_ms: u64,
    pub max_concurrent_tasks: usize,
}

Configuration for a FlowFabric worker.

RFC-012 Stage 1c tranche 1. Valkey-specific connection parameters (host, port, tls, cluster) moved to the nested BackendConfig field, which also carries BackendTimeouts and BackendRetry policy. Build one with BackendConfig::valkey for the common standalone case; for TLS / cluster / tuned retry, construct the ValkeyConnection and BackendConfig fields directly.

Worker-policy fields (lease_ttl_ms, claim_poll_interval_ms, capability set, lane list, identity) stay on WorkerConfig — those are orthogonal to the storage backend choice.

WorkerConfig::new was removed in this stage (pre-1.0 clean break); construct via struct literal.

Fields

backend: BackendConfig

Backend connection + shared timeouts / retry policy.

worker_id: WorkerId

Logical worker identity (e.g., “gpu-worker-pool-1”).

worker_instance_id: WorkerInstanceId

Concrete worker process/runtime instance identity (e.g., container ID).

namespace: Namespace

Namespace this worker operates in.

lanes: Vec<LaneId>

Lanes this worker claims work from.

capabilities: Vec<String>

Capabilities this worker advertises for routing.

lease_ttl_ms: u64

Lease TTL in milliseconds. Default: 30,000 (30s).

claim_poll_interval_ms: u64

Interval between claim attempts when idle, in milliseconds. Default: 1,000 (1s).

max_concurrent_tasks: usize

Maximum concurrent tasks. Default: 1.

Implementations

impl WorkerConfig

pub fn renewal_interval_ms(&self) -> u64

Lease renewal interval: TTL / 3 (renew at 1/3 of TTL, leaving 2/3 margin).