Struct ActivityRegistry 

pub struct ActivityRegistry { /* private fields */ }

Registry of typed activity handlers keyed by activity-type name.

Implementations

impl ActivityRegistry

pub fn new() -> Self

Creates an empty activity registry.

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 under an activity-type name.

Errors

Returns WorkerError::Registration when the name is already registered.

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 a typed handler and mechanically derives its wire contract from the same concrete serde types used at dispatch.

Errors

Returns WorkerError::Registration for a duplicate name or WorkerError::Encode if a generated schema cannot be represented as JSON.

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 a typed handler together with an EXPLICIT wire descriptor.

For an activity whose schemas are owned by a declaration rather than by Rust types, Self::register_activity_with_contract cannot help: there is no schemars type to derive from, because the types live in the .awl document. The handler is therefore untyped (serde_json::Value in and out) while the advertisement is exact, supplied by whoever read the declaration.

Registering a handler with no descriptor is what makes a worker invisible to contract admission — it advertises nothing, and a queue carrying any deployed contract refuses it. This is the path that keeps a declaration-driven worker admissible.

Errors

Returns WorkerError::Registration when the name is already registered, or when descriptor names a different activity than activity_type — a descriptor advertised under the wrong name would promise one action’s schema for another’s handler.

pub fn is_empty(&self) -> bool

Returns true when no activity handlers have been registered.

pub fn activity_types(&self) -> BTreeSet<String>

Returns the registered activity-type names in deterministic order.

pub fn activity_descriptors(&self) -> Vec<ActivityDescriptor>

Returns committed typed activity descriptors in deterministic name order.

Trait Implementations

impl ActivityDispatcher for ActivityRegistry

fn dispatch<'life0, 'async_trait>( &'life0 self, task: ActivityTask, context: ActivityContext, ) -> Pin<Box<dyn Future<Output = Result<DispatchOutcome, WorkerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes one decoded activity task with the provided handler context.

fn activity_types(&self) -> BTreeSet<String>

Activity type names this dispatcher can serve.

impl DeclaredCommands for ActivityRegistry

fn register_declared_command( self, activity_type: impl Into<String>, action: ShellAction, ) -> Result<Self, WorkerError>

Register action to be served under activity_type.

impl Default for ActivityRegistry

fn default() -> ActivityRegistry

Returns the “default value” for a type.