Struct OperationRegistry 

pub struct OperationRegistry { /* private fields */ }

Typed operation dispatcher with an explicit scope authorizer and schema compatibility window.

Implementations

impl OperationRegistry

pub fn new<A>(scope_authorizer: A) -> Self

where A: ScopeAuthorizer + 'static,

Creates an empty registry. Requiring an authorizer prevents an accidental allow-all scope.

pub fn register<O, H>( &mut self, handler: H, ) -> Result<&mut Self, RegistrationError>

where O: DomainOperation, H: OperationHandler<O> + 'static,

Registers a handler for only its current payload schema.

Errors

Returns RegistrationError::Duplicate when the operation kind is already registered.

pub fn register_with_migration<O, H, M>( &mut self, minimum_schema: u16, handler: H, migrator: M, ) -> Result<&mut Self, RegistrationError>

where O: DomainOperation, H: OperationHandler<O> + 'static, M: PayloadMigrator + 'static,

Registers a handler and direct migration adapter for a bounded historical schema window.

Errors

Returns RegistrationError for duplicate kinds or an invalid compatibility window.

Trait Implementations

impl OperationExecutor for OperationRegistry

fn authorize_scope<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, auth: &'life1 AuthContext, session: &'life2 SessionMetadata, ) -> Pin<Box<dyn Future<Output = Result<(), ExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Authorizes a requested partial sync scope before any entity or journal data is read.

fn authorize<'a, 'life0, 'life1, 'async_trait>( &'life0 self, auth: &'life1 AuthContext, operation: AuthenticatedOperation<'a>, ) -> Pin<Box<dyn Future<Output = Result<AuthorizedOperation<'a>, ExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Authorizes an operation before authoritative state is disclosed or conflict-tested.

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, auth: &'life1 AuthContext, operation: ExecutableOperation<'life2>, current: Option<&'life3 CurrentEntity>, ) -> Pin<Box<dyn Future<Output = Result<AuthoritativeMutation, ExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Validates business rules and executes an authorized operation into a store-independent mutation.