Struct WorkerBuilder 

pub struct WorkerBuilder { /* private fields */ }

Builder for a configured worker and its registered typed activities.

Implementations

impl WorkerBuilder

pub fn new(config: WorkerConfig) -> Self

Creates a builder for a worker using the supplied config.

pub fn register_activity<Input, Output, Handler>( self, activity_type: impl Into<String>, handler: Handler, ) -> Result<Self, WorkerError>

where Input: Serialize + DeserializeOwned + Send + Sync + 'static, Output: Serialize + Send + Sync + 'static, Handler: for<'context> Fn(Input, &'context ActivityContext) -> HandlerFuture<'context, Output> + Send + Sync + 'static,

Registers one typed activity handler on the builder.

Errors

Returns WorkerError::Registration when the activity type is duplicate.

pub fn register_activity_with_contract<Input, Output, Handler>( self, activity_type: impl Into<String>, handler: Handler, ) -> Result<Self, WorkerError>

where Input: Serialize + DeserializeOwned + JsonSchema + Send + Sync + 'static, Output: Serialize + JsonSchema + Send + Sync + 'static, Handler: for<'context> Fn(Input, &'context ActivityContext) -> HandlerFuture<'context, Output> + Send + Sync + 'static,

Registers one typed activity and commits mechanically derived schemas to every registration handshake.

Errors

Returns WorkerError for duplicate activity names or schema encoding.

pub fn register_activity_with_descriptor<Input, Output, Handler>( self, activity_type: impl Into<String>, descriptor: ActivityDescriptor, handler: Handler, ) -> Result<Self, WorkerError>

where Input: Serialize + DeserializeOwned + Send + Sync + 'static, Output: Serialize + Send + Sync + 'static, Handler: for<'context> Fn(Input, &'context ActivityContext) -> HandlerFuture<'context, Output> + Send + Sync + 'static,

Registers one activity with an EXPLICIT wire descriptor, for schemas owned by a declaration rather than by Rust types.

See ActivityRegistry::register_activity_with_descriptor: this is how a declaration-driven worker (one whose types live in an .awl document) advertises a real action surface instead of an empty one.

Errors

Returns WorkerError::Registration for a duplicate activity name or a descriptor naming a different activity.

pub fn build(self) -> Result<Worker, WorkerError>

Builds the worker after validating that it has at least one activity.

Errors

Returns WorkerError::Registration when no activities are registered.