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 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.