Struct Registry 

pub struct Registry { /* private fields */ }

Validates and stores all Flow definitions used by a Client or Worker.

Registration checks unique Flow, Step, RPC, and persistence names; starting-Step constraints; Attribute index consistency; RPC locks; and handler options. Cloning is cheap because it shares the registered data.

Examples

use dex_sdk::{Flow, Registry};

struct OrderFlow;
impl Flow for OrderFlow { type StartInput = String; }

let registry = Registry::new().register(OrderFlow)?;

Implementations

impl Registry

pub fn new() -> Self

Creates an empty registry.

pub fn register<SomeFlow: Flow>(self, flow: SomeFlow) -> SdkResult<Self>

Validates and adds one owned Flow definition.

Errors

Returns SdkError::FlowDefinition for invalid or conflicting names, schemas, indexes, Steps, RPCs, locks, or options.

Trait Implementations

impl Clone for Registry

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Registry

fn default() -> Self

Returns the “default value” for a type.