Struct ReloadDispatcher 

pub struct ReloadDispatcher<'a> { /* private fields */ }

Orchestrates per-kind reload discipline between drain and commit.

Construct with ReloadDispatcher::new, optionally populate live resources via ReloadKindHandlers, then call Self::dispatch. Failures abort the reload before the new plugin’s registrations commit.

Implementations

impl<'a> ReloadDispatcher<'a>

pub fn new( old: &'a PluginRecordSnapshot, new_registry: &'a PluginRegistry, ) -> Self

Construct a dispatcher over the old plugin’s snapshot and the new plugin’s already-committed surface registry.

pub fn with_handlers(self, handlers: ReloadKindHandlers) -> Self

Attach per-kind live-resource handoffs.

pub fn check_compat( &self, old_providers: &OldProviders, ) -> Result<(), ReloadError>

Pre-flight check: run schema-compat checks for CRDT kinds and logical types that both old and new plugin register.

old_providers supplies the pre-swap views of the providers the old plugin owned. The dispatcher cannot recover those from the registry once the swap has happened, so the host snapshots them immediately before evicting the old plugin.

Errors

Returns ReloadError::SchemaIncompat when any pair fails its compat check.

pub fn dispatch(self) -> Result<ReloadOutcome, ReloadError>

Drive the per-instance handoffs: persist & reopen index handles; checkpoint & restart CDC streams.

Errors

Returns ReloadError::Persist if a handoff fails. The old resources are dropped on failure — the host must be prepared to surface the failure and continue serving against the new providers’ freshly-initialized resources.

Trait Implementations

impl<'a> Debug for ReloadDispatcher<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.