Struct Registry 

pub struct Registry { /* private fields */ }

Registry for orchestrator and activity functions.

Functions must be registered before the worker is started. Versioned orchestrators can be registered with add_versioned_orchestrator and a specific version string, or with add_latest_orchestrator to mark a version as the default when no exact version match is found.

Implementations

impl Registry

pub fn new() -> Self

Create an empty registry.

pub fn add_named_orchestrator<F, Fut>(&mut self, name: &str, f: F)

where F: Fn(OrchestrationContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = OrchestratorResult> + Send + 'static,

Register an unversioned orchestrator function with the given name.

This is the simplest registration path. When versioning is not required, prefer this method.

pub fn add_versioned_orchestrator<F, Fut>( &mut self, name: &str, version: &str, f: F, )

where F: Fn(OrchestrationContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = OrchestratorResult> + Send + 'static,

Register a versioned orchestrator function.

The version is matched against the version field of incoming ExecutionStarted history events. Use this when you need to run multiple versions of the same orchestrator simultaneously.

Examples

use dapr_durabletask::worker::Registry;

let mut reg = Registry::new();
reg.add_versioned_orchestrator("my_orch", "v1", |ctx| async move { Ok(None) });
reg.add_versioned_orchestrator("my_orch", "v2", |ctx| async move { Ok(None) });

pub fn add_latest_orchestrator<F, Fut>( &mut self, name: &str, version: &str, f: F, )

where F: Fn(OrchestrationContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = OrchestratorResult> + Send + 'static,

Register a versioned orchestrator and mark it as the latest.

The latest entry is selected when no exact version match is found. If multiple entries are marked as latest for the same name, the last one registered wins.

Examples

use dapr_durabletask::worker::Registry;

let mut reg = Registry::new();
reg.add_versioned_orchestrator("my_orch", "v1", |ctx| async move { Ok(None) });
reg.add_latest_orchestrator("my_orch", "v2", |ctx| async move { Ok(None) });
// Requests for "v1" → v1 handler; any other version → v2 handler.

pub fn add_named_activity<F, Fut>(&mut self, name: &str, f: F)

where F: Fn(ActivityContext, Option<String>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ActivityResult> + Send + 'static,

Register an activity function with the given name.

pub fn get_orchestrator(&self, name: &str) -> Option<&OrchestratorFn>

Look up a registered orchestrator by name and optional version.

Resolution order:

1. Exact version match (when version is Some).
2. The entry marked as is_latest for this name.
3. The single unversioned entry (registered via add_named_orchestrator).

Returns None if no suitable entry is found.

pub fn get_orchestrator_version( &self, name: &str, version: Option<&str>, ) -> Option<&OrchestratorFn>

Look up a registered orchestrator by name, optionally constraining the version. See get_orchestrator for the resolution rules.

pub fn get_activity(&self, name: &str) -> Option<&ActivityFn>

Look up a registered activity by name.

Trait Implementations

impl Default for Registry

fn default() -> Self

Returns the “default value” for a type.