Struct WorkerOptions 

pub struct WorkerOptions {
    pub max_concurrent_work_items: usize,
    pub max_event_names: usize,
    pub max_events_per_name: usize,
    pub max_pending_tasks_per_name: usize,
    pub max_json_payload_size: usize,
    pub max_identifier_length: usize,
    pub reconnect_policy: ReconnectPolicy,
}

Configuration options for TaskHubGrpcWorker.

Fields

max_concurrent_work_items: usize

Maximum number of concurrent work items (orchestrations + activities) processed simultaneously. The worker stops accepting new work items until an in-flight task completes.

max_event_names: usize

Maximum number of distinct event names that can be buffered per orchestration. External events arriving before the orchestrator calls wait_for_external_event are held in a per-name buffer. This cap limits the number of unique event names to prevent memory exhaustion from a flood of differently-named events.

max_events_per_name: usize

Maximum number of events buffered per event name. When an external event arrives but no orchestrator is waiting for it yet, the event payload is queued. This cap bounds the queue depth per event name — excess events are discarded with a warning.

max_pending_tasks_per_name: usize

Maximum number of pending wait_for_external_event tasks per event name. If an orchestrator issues more concurrent waits on the same event name than this limit, additional waits return an incomplete task.

max_json_payload_size: usize

Maximum JSON payload size in bytes for deserialisation. Payloads exceeding this limit are rejected with an error.

max_identifier_length: usize

Maximum allowed length (in bytes) for identifiers such as orchestrator names, activity names, instance IDs, and event names.

reconnect_policy: ReconnectPolicy

Reconnection policy applied when the gRPC connection to the sidecar is unavailable or drops. The policy governs both the initial connection attempt and every subsequent reconnect.

Implementations

impl WorkerOptions

pub fn new() -> Self

Create options with default values.

pub fn with_max_concurrent_work_items(self, limit: usize) -> Self

Set the maximum number of concurrent work items.

pub fn with_max_event_names(self, limit: usize) -> Self

Set the maximum number of distinct event names buffered per orchestration.

pub fn with_max_events_per_name(self, limit: usize) -> Self

Set the maximum number of events buffered per event name.

pub fn with_max_pending_tasks_per_name(self, limit: usize) -> Self

Set the maximum number of pending wait tasks per event name.

pub fn with_max_json_payload_size(self, limit: usize) -> Self

Set the maximum JSON payload size in bytes.

pub fn with_max_identifier_length(self, limit: usize) -> Self

Set the maximum identifier length in bytes.

pub fn with_reconnect_policy(self, policy: ReconnectPolicy) -> Self

Set the reconnect backoff policy.

pub fn with_fast_reconnect(self) -> Self

Convenience: configure a fast reconnect policy suitable for tests.

Sets a 50 ms initial delay, 500 ms maximum delay, ×2 multiplier, and disables jitter.

Trait Implementations

impl Clone for WorkerOptions

fn clone(&self) -> WorkerOptions

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerOptions

fn default() -> Self

Returns the “default value” for a type.