Struct ProcedureRegistry 

pub struct ProcedureRegistry { /* private fields */ }

Thread-safe registry of procedures.

M4 bridge: The legacy procedures hashmap holds test-only RegisteredProcedure mock rows used by TCK step definitions. The new plugin_registry field holds an Arc<uni_plugin::PluginRegistry> that the M4 cutover commits route real procedure dispatch through. Both coexist during the M4 coexistence window; once every consumer switches to plugin-path dispatch, the legacy hashmap is removed.

Implementations

impl ProcedureRegistry

pub fn new() -> Self

Creates an empty registry.

pub fn register(&self, proc_def: RegisteredProcedure)

Registers a procedure, replacing any existing one with the same name.

pub fn get(&self, name: &str) -> Option<RegisteredProcedure>

Looks up a procedure by fully qualified name (legacy path).

pub fn clear(&self)

Removes all registered procedures.

pub fn set_plugin_registry(&self, pr: Arc<PluginRegistry>)

Attach an uni_plugin::PluginRegistry for plugin-path dispatch.

M4 bridge: callers configure this once at executor construction, and the procedure dispatch site consults the plugin registry for any qname not present in the legacy procedures hashmap.

pub fn plugin_registry(&self) -> Option<Arc<PluginRegistry>>

Snapshot of the currently attached plugin registry, if any.

Used by the read executor to thread the host’s PluginRegistry into the physical planner so consultation sites like plan_vector_knn can look up registered IndexHandles. Returns None if set_plugin_registry was never called (e.g., low-level test setups that bypass Uni::build).

pub fn get_plugin(&self, qname: &QName) -> Option<Arc<ProcedureEntry>>

Look up a procedure through the attached PluginRegistry, if any.

Dual-consult (M8.6): checks the per-task session-local plugin registry first (set by host crates via crate::scoped_with_session_plugin_registry) and falls back to the executor’s instance-attached plugin registry. Returns None if neither has qname.

pub fn resolve_user_procedure( &self, user_qname: &str, ) -> Option<Arc<ProcedureEntry>>

Resolve a user-facing procedure name (as written in CALL X.Y.Z(...)) to a registered plugin entry, applying the framework’s namespace resolution rules:

1. If user_qname parses as <namespace>.<local>, try that exact qname against the plugin registry.
2. Strip a leading uni. prefix if present, then try each known built-in plugin namespace (builtin, apoc-core) with the stripped local name. This lets user-facing names like uni.bitwise.and route to plugins that registered under the apoc-core namespace as apoc-core.bitwise.and.

Future user plugins that want their qnames reachable as uni.* can declare their own namespace; the resolver will try the declared namespace before falling through.

Trait Implementations

impl Debug for ProcedureRegistry

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

Formats the value using the given formatter.

impl Default for ProcedureRegistry

fn default() -> ProcedureRegistry

Returns the “default value” for a type.