Struct WorkerBuilder 

pub struct WorkerBuilder<S: State = Empty> { /* private fields */ }

Use builder syntax to set the inputs and finish with build().

Implementations

impl<S: State> WorkerBuilder<S>

pub fn build(self) -> Worker

where S: IsComplete,

Finish building and return the requested object

pub fn permissions(self, value: String) -> WorkerBuilder<SetPermissions<S>>

where S::Permissions: IsUnset,

Required.

Permission profile name that defines the permissions granted to this worker. This references a profile defined in the stack’s permission definitions.

pub fn code(self, value: WorkerCode) -> WorkerBuilder<SetCode<S>>

where S::Code: IsUnset,

Required.

Code for the worker, either a pre-built image or source code to be built.

pub fn memory_mb(self, value: u32) -> WorkerBuilder<SetMemoryMb<S>>

where S::MemoryMb: IsUnset,

Optional (Some / Option setters). Default: default_memory_mb().

Memory allocated to the worker in megabytes (MB). Default: 256

Platform-specific constraints:

• AWS Lambda: 128–10240 MB in 1 MB increments
• GCP Cloud Run: 128–32768 MB
• Azure Container Apps: fixed CPU/memory pairs — 512, 1024, 1536, 2048, 2560, 3072, 3584, 4096 MB. Values below 512 are automatically rounded up at deploy time.

pub fn maybe_memory_mb( self, value: Option<u32>, ) -> WorkerBuilder<SetMemoryMb<S>>

where S::MemoryMb: IsUnset,

Optional (Some / Option setters). Default: default_memory_mb().

Memory allocated to the worker in megabytes (MB). Default: 256

Platform-specific constraints:

• AWS Lambda: 128–10240 MB in 1 MB increments
• GCP Cloud Run: 128–32768 MB
• Azure Container Apps: fixed CPU/memory pairs — 512, 1024, 1536, 2048, 2560, 3072, 3584, 4096 MB. Values below 512 are automatically rounded up at deploy time.

pub fn timeout_seconds(self, value: u32) -> WorkerBuilder<SetTimeoutSeconds<S>>

where S::TimeoutSeconds: IsUnset,

Optional (Some / Option setters). Default: default_timeout_seconds().

Maximum execution time for the worker in seconds. Constraints: 1‑3600 seconds (platform-specific limits may apply) Default: 30

pub fn maybe_timeout_seconds( self, value: Option<u32>, ) -> WorkerBuilder<SetTimeoutSeconds<S>>

where S::TimeoutSeconds: IsUnset,

Optional (Some / Option setters). Default: default_timeout_seconds().

Maximum execution time for the worker in seconds. Constraints: 1‑3600 seconds (platform-specific limits may apply) Default: 30

pub fn environment( self, value: HashMap<String, String>, ) -> WorkerBuilder<SetEnvironment<S>>

where S::Environment: IsUnset,

Optional (Some / Option setters). Default: <HashMap<String, String> as Default>::default().

Key-value pairs to set as environment variables for the worker.

pub fn maybe_environment( self, value: Option<HashMap<String, String>>, ) -> WorkerBuilder<SetEnvironment<S>>

where S::Environment: IsUnset,

Optional (Some / Option setters). Default: <HashMap<String, String> as Default>::default().

Key-value pairs to set as environment variables for the worker.

pub fn ingress(self, value: Ingress) -> WorkerBuilder<SetIngress<S>>

where S::Ingress: IsUnset,

Optional (Some / Option setters). Default: default_ingress().

Controls network accessibility of the worker.

pub fn maybe_ingress( self, value: Option<Ingress>, ) -> WorkerBuilder<SetIngress<S>>

where S::Ingress: IsUnset,

Optional (Some / Option setters). Default: default_ingress().

Controls network accessibility of the worker.

pub fn commands_enabled( self, value: bool, ) -> WorkerBuilder<SetCommandsEnabled<S>>

where S::CommandsEnabled: IsUnset,

Optional (Some / Option setters). Default: default_commands_enabled().

Whether the worker can receive remote commands via the Commands protocol. When enabled, the runtime polls the manager for pending commands and executes registered handlers.

pub fn maybe_commands_enabled( self, value: Option<bool>, ) -> WorkerBuilder<SetCommandsEnabled<S>>

where S::CommandsEnabled: IsUnset,

Optional (Some / Option setters). Default: default_commands_enabled().

Whether the worker can receive remote commands via the Commands protocol. When enabled, the runtime polls the manager for pending commands and executes registered handlers.

pub fn concurrency_limit( self, value: u32, ) -> WorkerBuilder<SetConcurrencyLimit<S>>

where S::ConcurrencyLimit: IsUnset,

Optional (Some / Option setters). Maximum number of concurrent executions allowed for the worker. None means platform default applies.

pub fn maybe_concurrency_limit( self, value: Option<u32>, ) -> WorkerBuilder<SetConcurrencyLimit<S>>

where S::ConcurrencyLimit: IsUnset,

Optional (Some / Option setters). Maximum number of concurrent executions allowed for the worker. None means platform default applies.

pub fn readiness_probe( self, value: ReadinessProbe, ) -> WorkerBuilder<SetReadinessProbe<S>>

where S::ReadinessProbe: IsUnset,

Optional (Some / Option setters). Optional readiness probe configuration. Only applicable for workers with Public ingress. When configured, the probe will be executed after provisioning/update to verify the worker is ready.

pub fn maybe_readiness_probe( self, value: Option<ReadinessProbe>, ) -> WorkerBuilder<SetReadinessProbe<S>>

where S::ReadinessProbe: IsUnset,

Optional (Some / Option setters). Optional readiness probe configuration. Only applicable for workers with Public ingress. When configured, the probe will be executed after provisioning/update to verify the worker is ready.

impl<S: State> WorkerBuilder<S>

pub fn link<R: ?Sized>(self, resource: &R) -> Self

where for<'a> &'a R: Into<ResourceRef>,

Links the worker to another resource with specified permissions. Accepts a reference to any type R where &R can be converted into ResourceRef.

pub fn trigger(self, trigger: WorkerTrigger) -> Self

Adds a trigger to the worker. Workers can have multiple triggers. Each trigger will independently invoke the worker when its conditions are met.

Examples

let worker = Worker::new("my-worker".to_string())
    .code(WorkerCode::Image { image: "test:latest".to_string() })
    .permissions("execution".to_string())
    .trigger(WorkerTrigger::queue(&queue1))
    .trigger(WorkerTrigger::queue(&queue2))
    .build();