Rename collocated UDF package to plugin

Rename the `singlestoredb.functions.ext.collocated` package to
`singlestoredb.functions.ext.plugin` and update all related naming:

- CLI args: --extension -> --plugin-name, --extension-path -> --search-path
- Env vars: EXTERNAL_UDF_* -> PLUGIN_*
- Class: FunctionHandler -> Plugin
- WIT: singlestore:udf/function-handler -> singlestore:plugin/plugin
- WIT world: external-udf -> plugin-server
- pyproject.toml entry point updated to new module path

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: kesmit13

pyproject.toml

@@ -75,7 +75,7 @@ dev = [
 ]
 
 [project.scripts]
-python-udf-server = "singlestoredb.functions.ext.collocated.__main__:main"
+python-udf-server = "singlestoredb.functions.ext.plugin.__main__:main"
 
 [project.entry-points.pytest11]
 singlestoredb = "singlestoredb.pytest"

…edb/functions/ext/collocated/__init__.py …storedb/functions/ext/plugin/__init__.pysinglestoredb/functions/ext/collocated/__init__.py renamed to singlestoredb/functions/ext/plugin/__init__.py singlestoredb/functions/ext/collocated/__init__.py renamed to singlestoredb/functions/ext/plugin/__init__.py

@@ -3,9 +3,9 @@
 
 Usage::
 
-    python -m singlestoredb.functions.ext.collocated \\
-        --extension myfuncs \\
-        --extension-path /home/user/libs \\
+    python -m singlestoredb.functions.ext.plugin \\
+        --plugin-name myfuncs \\
+        --search-path /home/user/libs \\
         --socket /tmp/my-udf.sock
 
 Arguments match the Rust wasm-udf-server CLI for drop-in compatibility.
@@ -26,92 +26,92 @@
 
 def main(argv: Any = None) -> None:
     parser = argparse.ArgumentParser(
-        prog='python -m singlestoredb.functions.ext.collocated',
+        prog='python -m singlestoredb.functions.ext.plugin',
         description='High-performance collocated Python UDF server',
     )
     parser.add_argument(
-        '--extension',
-        default=os.environ.get('EXTERNAL_UDF_EXTENSION', ''),
+        '--plugin-name',
+        default=os.environ.get('PLUGIN_NAME', ''),
         help=(
             'Python module to import (e.g. myfuncs). '
-            'Env: EXTERNAL_UDF_EXTENSION'
+            'Env: PLUGIN_NAME'
         ),
     )
     parser.add_argument(
-        '--extension-path',
-        default=os.environ.get('EXTERNAL_UDF_EXTENSION_PATH', ''),
+        '--search-path',
+        default=os.environ.get('PLUGIN_SEARCH_PATH', ''),
         help=(
             'Colon-separated search dirs for the module. '
-            'Env: EXTERNAL_UDF_EXTENSION_PATH'
+            'Env: PLUGIN_SEARCH_PATH'
         ),
     )
     parser.add_argument(
         '--socket',
         default=os.environ.get(
-            'EXTERNAL_UDF_SOCKET_PATH',
+            'PLUGIN_SOCKET_PATH',
             os.path.join(
                 tempfile.gettempdir(),
                 f'singlestore-udf-{os.getpid()}-{secrets.token_hex(4)}.sock',
             ),
         ),
         help=(
             'Unix socket path. '
-            'Env: EXTERNAL_UDF_SOCKET_PATH'
+            'Env: PLUGIN_SOCKET_PATH'
         ),
     )
     parser.add_argument(
         '--n-workers',
         type=int,
-        default=int(os.environ.get('EXTERNAL_UDF_N_WORKERS', '0')),
+        default=int(os.environ.get('PLUGIN_N_WORKERS', '0')),
         help=(
             'Worker threads (0 = CPU count). '
-            'Env: EXTERNAL_UDF_N_WORKERS'
+            'Env: PLUGIN_N_WORKERS'
         ),
     )
     parser.add_argument(
         '--max-connections',
         type=int,
-        default=int(os.environ.get('EXTERNAL_UDF_MAX_CONNECTIONS', '32')),
+        default=int(os.environ.get('PLUGIN_MAX_CONNECTIONS', '32')),
         help=(
             'Socket backlog. '
-            'Env: EXTERNAL_UDF_MAX_CONNECTIONS'
+            'Env: PLUGIN_MAX_CONNECTIONS'
         ),
     )
     parser.add_argument(
         '--log-level',
-        default=os.environ.get('EXTERNAL_UDF_LOG_LEVEL', 'info'),
+        default=os.environ.get('PLUGIN_LOG_LEVEL', 'info'),
         choices=['debug', 'info', 'warning', 'error'],
         help=(
             'Logging level. '
-            'Env: EXTERNAL_UDF_LOG_LEVEL'
+            'Env: PLUGIN_LOG_LEVEL'
         ),
     )
     parser.add_argument(
         '--process-mode',
-        default=os.environ.get('EXTERNAL_UDF_PROCESS_MODE', 'process'),
+        default=os.environ.get('PLUGIN_PROCESS_MODE', 'process'),
         choices=['thread', 'process'],
         help=(
             'Concurrency mode: "thread" uses a thread pool, '
             '"process" uses pre-fork workers for true CPU '
-            'parallelism. Env: EXTERNAL_UDF_PROCESS_MODE'
+            'parallelism. Env: PLUGIN_PROCESS_MODE'
         ),
     )
 
     args = parser.parse_args(argv)
 
-    if not args.extension:
+    if not args.plugin_name:
         parser.error(
-            '--extension is required '
-            '(or set EXTERNAL_UDF_EXTENSION env var)',
+            '--plugin-name is required '
+            '(or set PLUGIN_NAME env var)',
         )
 
     # Setup logging
     level = getattr(logging, args.log_level.upper())
     setup_logging(level)
 
     config = {
-        'extension': args.extension,
-        'extension_path': args.extension_path,
+        'plugin_name': args.plugin_name,
+        'search_path': args.search_path,
         'socket': args.socket,
         'n_workers': args.n_workers,
         'max_connections': args.max_connections,

…edb/functions/ext/collocated/__main__.py …storedb/functions/ext/plugin/__main__.pysinglestoredb/functions/ext/collocated/__main__.py renamed to singlestoredb/functions/ext/plugin/__main__.py singlestoredb/functions/ext/collocated/__main__.py renamed to singlestoredb/functions/ext/plugin/__main__.py

@@ -181,13 +181,13 @@ def _discover_udf_functions(self) -> None:
         """Discover @udf functions by scanning sys.modules.
 
         Uses a two-pass approach: first, identify candidate modules
-        that import FunctionHandler (the convention for UDF modules).
+        that import Plugin (the convention for UDF modules).
         Then extract @udf-decorated functions from those modules.
         Modules without a __file__ (built-in/frozen) and stdlib/
         infrastructure modules are skipped automatically.
         """
         # Import here to avoid circular dependency at module level
-        from .wasm import FunctionHandler
+        from .wasm import Plugin
 
         found_modules = []
         for mod_name, mod in list(sys.modules.items()):
@@ -200,9 +200,9 @@ def _discover_udf_functions(self) -> None:
                 continue
 
             # Short-circuit: only scan modules that import
-            # FunctionHandler (the convention for UDF modules)
+            # Plugin (the convention for UDF modules)
             if not any(
-                obj is FunctionHandler
+                obj is Plugin
                 for obj in vars(mod).values()
             ):
                 continue

…b/functions/ext/collocated/connection.py …oredb/functions/ext/plugin/connection.pysinglestoredb/functions/ext/collocated/connection.py renamed to singlestoredb/functions/ext/plugin/connection.py singlestoredb/functions/ext/collocated/connection.py renamed to singlestoredb/functions/ext/plugin/connection.py

@@ -467,21 +467,21 @@ def _worker_signal_handler(
                 pass
 
     def _initialize_registry(self) -> FunctionRegistry:
-        """Import the extension module and discover @udf functions."""
-        extension = self.config['extension']
-        extension_path = self.config.get('extension_path', '')
+        """Import the plugin module and discover @udf functions."""
+        plugin_name = self.config['plugin_name']
+        search_path = self.config.get('search_path', '')
 
-        # Prepend extension path directories to sys.path
-        if extension_path:
-            for p in reversed(extension_path.split(':')):
+        # Prepend search path directories to sys.path
+        if search_path:
+            for p in reversed(search_path.split(':')):
                 p = p.strip()
                 if p and p not in sys.path:
                     sys.path.insert(0, p)
                     logger.info(f'Added to sys.path: {p}')
 
-        # Import the extension module
-        logger.info(f'Importing extension module: {extension}')
-        importlib.import_module(extension)
+        # Import the plugin module
+        logger.info(f'Importing plugin module: {plugin_name}')
+        importlib.import_module(plugin_name)
 
         # Initialize registry (discovers @udf functions from sys.modules)
         registry = FunctionRegistry()
@@ -490,7 +490,7 @@ def _initialize_registry(self) -> FunctionRegistry:
         func_count = len(registry.functions)
         if func_count == 0:
             raise RuntimeError(
-                f'No @udf functions found after importing {extension!r}',
+                f'No @udf functions found after importing {plugin_name!r}',
             )
         logger.info(f'Discovered {func_count} function(s)')
         for name in sorted(registry.functions):

…redb/functions/ext/collocated/control.py …estoredb/functions/ext/plugin/control.pysinglestoredb/functions/ext/collocated/control.py renamed to singlestoredb/functions/ext/plugin/control.py singlestoredb/functions/ext/collocated/control.py renamed to singlestoredb/functions/ext/plugin/control.py

@@ -1,8 +1,8 @@
 """
 Thin WIT adapter over FunctionRegistry.
 
-This module provides the FunctionHandler class that implements the
-singlestore:udf/function-handler WIT interface by delegating to the
+This module provides the Plugin class that implements the
+singlestore:plugin/plugin WIT interface by delegating to the
 shared FunctionRegistry in registry.py.
 """
 import logging
@@ -21,8 +21,8 @@
 _registry = FunctionRegistry()
 
 
-class FunctionHandler:
-    """Implementation of the singlestore:udf/function-handler interface."""
+class Plugin:
+    """Implementation of the singlestore:plugin/plugin interface."""
 
     def initialize(self) -> None:
         """Initialize and discover UDF functions from loaded modules."""

…edb/functions/ext/collocated/registry.py …storedb/functions/ext/plugin/registry.pysinglestoredb/functions/ext/collocated/registry.py renamed to singlestoredb/functions/ext/plugin/registry.py singlestoredb/functions/ext/collocated/registry.py renamed to singlestoredb/functions/ext/plugin/registry.py

@@ -1,6 +1,6 @@
-package singlestore:udf;
+package singlestore:plugin;
 
-interface function-handler {
+interface plugin {
     /// Initialize the handler and discover pre-imported UDF modules.
     /// Must be called before any other functions.
     initialize: func() -> result<_, string>;
@@ -21,6 +21,6 @@ interface function-handler {
     create-function: func(signature: string, code: string, replace: bool) -> result<_, string>;
 }
 
-world external-udf {
-    export function-handler;
+world plugin-server {
+    export plugin;
 }