Optional ReadonlyactivationOptional ReadonlyconcurrencyMax jobs processed concurrently (handler parallelism / backpressure). The
activation loop will not pull faster than handlers drain, and the activation
batch is capped to this value (when it is a finite number) so the worker never
leases more jobs than it can process at once. Default: the value of
ActivateJobsStreamOptions.maxJobsToActivate (or 10).
Optional ReadonlyfetchRestrict activation to these variable names.
ReadonlyhandlerThe Effect job handler.
Optional ReadonlyhandlerSchedule used to retry the handler in-process on a RetryableJobError
before the job is failed back to the broker. Runs on the Effect Clock
(virtual under TestClock). A TerminalJobError is never retried.
Optional ReadonlyjobPer-job activation lock timeout (server-side). Default 60 seconds.
Optional ReadonlymaxMax jobs to activate per poll (the activation batch size). Default 10.
Optional ReadonlypollDelay between polls that returned no jobs, on the Effect Clock (so it is
virtual under TestClock). A poll that returns jobs schedules the next poll
immediately. Default 1 second.
Optional ReadonlyrequestLong-poll request timeout. 0 (the default) lets the broker hold the request
for its configured default; a negative value returns immediately when idle.
ReadonlytypeThe job type to activate.
Optional ReadonlyworkerWorker name recorded on the activation request. Defaults to effect-worker-<type>-<n>, where <n> is an incrementing per-process counter.
Scheduleused to back off and retry a failed activation request (transport outage, broker restart, transient server error). Runs on the EffectClock. When omitted, an activation failure fails the stream.