Struct WorkerConfig 

pub struct WorkerConfig {
    pub host: String,
    pub port: u16,
    pub tls: bool,
    pub cluster: bool,
    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.

Fields

host: String

Valkey hostname. Default: "localhost".

port: u16

Valkey port. Default: 6379.

tls: bool

Enable TLS for the Valkey connection.

cluster: bool

Enable Valkey cluster mode.

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 new( host: impl Into<String>, port: u16, worker_id: impl Into<String>, worker_instance_id: impl Into<String>, namespace: impl Into<String>, lane: impl Into<String>, ) -> Self

Create a minimal config for a single-lane worker.

pub fn renewal_interval_ms(&self) -> u64

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