StemWorkerConfig class
Worker configuration used by the bootstrap helpers.
Constructors
-
StemWorkerConfig({String queue = 'default', String? consumerName = 'default-worker', int? concurrency, int prefetchMultiplier = 2, int? prefetch, RateLimiter? rateLimiter, List<
Middleware> ? middleware, RevokeStore? revokeStore, UniqueTaskCoordinator? uniqueTaskCoordinator, RetryStrategy? retryStrategy, RoutingSubscription? subscription, Duration heartbeatInterval = const Duration(seconds: 10), Duration? workerHeartbeatInterval, HeartbeatTransport? heartbeatTransport, String heartbeatNamespace = 'stem', WorkerAutoscaleConfig? autoscale, WorkerLifecycleConfig? lifecycle, ObservabilityConfig? observability, PayloadSigner? signer}) -
Creates a worker configuration snapshot for bootstrap helpers.
const
Properties
- autoscale → WorkerAutoscaleConfig?
-
Optional autoscale configuration for the worker.
final
- concurrency → int?
-
Optional concurrency override for worker tasks.
final
- consumerName → String?
-
Optional consumer name override for the worker.
final
- hashCode → int
-
The hash code for this object.
no setterinherited
- heartbeatInterval → Duration
-
Interval between task heartbeats.
final
- heartbeatNamespace → String
-
Namespace for worker heartbeat/control events.
final
- heartbeatTransport → HeartbeatTransport?
-
Optional transport for emitting worker heartbeats.
final
- lifecycle → WorkerLifecycleConfig?
-
Optional lifecycle configuration for the worker.
final
-
middleware
→ List<
Middleware> ? -
Optional middleware chain applied by the worker.
final
- observability → ObservabilityConfig?
-
Optional observability configuration for the worker.
final
- prefetch → int?
-
Optional prefetch override for the worker.
final
- prefetchMultiplier → int
-
Multiplier used when calculating prefetch size.
final
- queue → String
-
Queue name used by the worker.
final
- rateLimiter → RateLimiter?
-
Optional rate limiter used by the worker.
final
- retryStrategy → RetryStrategy?
-
Optional retry strategy used by the worker.
final
- revokeStore → RevokeStore?
-
Optional revoke store used for worker control.
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- signer → PayloadSigner?
-
Optional payload signer used to verify envelopes.
final
- subscription → RoutingSubscription?
-
Optional routing subscription for the worker.
final
- uniqueTaskCoordinator → UniqueTaskCoordinator?
-
Optional unique task coordinator used by the worker.
final
- workerHeartbeatInterval → Duration?
-
Optional override for worker-level heartbeat cadence.
final
Methods
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited