Update docs and plugin/ terminology after collocated→plugin rename

Update ARCHITECTURE.md with plugin/ subpackage in the package tree,
three-mode execution diagram, Plugin Server CLI section with all 7
arguments and env variables, and Appendix A/D entries. Update
CONTRIBUTING.md with plugin server CLI example for manual testing.
Update README.md UDF bullet to mention plugin-mode deployment.

Replace remaining "collocated" references in plugin/ source files:
logger names (collocated.* → plugin.*), docstrings, and argparse
description. Files outside plugin/ (config.py, asgi.py, mmap.py)
correctly use "collocated" for their own functionality and are
left unchanged.

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

Author: kesmit13

ARCHITECTURE.md

@@ -99,7 +99,14 @@ singlestoredb/
 │       ├── mmap.py          # Memory-mapped execution
 │       ├── json.py          # JSON serialization
 │       ├── rowdat_1.py      # ROWDAT_1 format
-│       └── arrow.py         # Apache Arrow format
+│       ├── arrow.py         # Apache Arrow format
+│       └── plugin/          # Plugin UDF server (Unix socket)
+│           ├── __main__.py  # CLI entry point
+│           ├── server.py    # Socket server with thread/process pool
+│           ├── connection.py # Connection handling
+│           ├── control.py   # Control protocol
+│           ├── registry.py  # Function registry & discovery
+│           └── wasm.py      # WASM component interface
 │
 ├── ai/                      # AI/ML integration
 │   ├── chat.py              # Chat completion factory
@@ -603,9 +610,9 @@ Located in `singlestoredb/fusion/handlers/`:
 ## External Functions (UDFs)
 
 The functions module (`singlestoredb/functions/`) enables deploying Python functions
-as SingleStore external functions. UDF servers can be deployed as HTTP using
-an ASGI application or a collocated socket server that uses mmap files to
-transfer data.
+as SingleStore external functions. UDF servers can be deployed in three modes: as HTTP using an ASGI application
+(remote), a memory-mapped collocated server (lowest latency), or as a plugin
+server using Unix sockets with a thread/process pool (CLI-driven).
 
 ### Architecture
 
@@ -629,6 +636,7 @@ transfer data.
 ├─────────────────────────────────────────────────────────────────────┤
 │  asgi.py    │  HTTP server via ASGI (Uvicorn; JSON or ROWDAT_1)     │
 │  mmap.py    │  Memory-mapped shared memory (collocated; ROWDAT_1)   │
+│  plugin/    │  Plugin UDF server (Unix socket + thread/process pool) │
 │  json.py    │  JSON serialization over HTTP                         │
 │  rowdat_1.py│  ROWDAT_1 binary format                               │
 │  arrow.py   │  Apache Arrow columnar format                         │
@@ -659,6 +667,33 @@ python -m singlestoredb.functions.ext.asgi \
     my_functions
 ```
 
+### Plugin Server CLI
+
+The plugin server can be launched via the CLI for Unix socket-based UDF serving:
+
+```bash
+# Launch the plugin server
+python -m singlestoredb.functions.ext.plugin \
+    --plugin-name myfuncs \
+    --search-path /home/user/libs \
+    --socket /tmp/my-udf.sock
+
+# Or use the console_scripts entry point
+python-udf-server --plugin-name myfuncs
+```
+
+**CLI Arguments:**
+
+| Argument | Env Variable | Default | Description |
+|----------|-------------|---------|-------------|
+| `--plugin-name` | `PLUGIN_NAME` | (required) | Python module to import |
+| `--search-path` | `PLUGIN_SEARCH_PATH` | `""` | Colon-separated search dirs for the module |
+| `--socket` | `PLUGIN_SOCKET_PATH` | auto-generated | Unix socket path |
+| `--n-workers` | `PLUGIN_N_WORKERS` | `0` (CPU count) | Worker threads/processes |
+| `--max-connections` | `PLUGIN_MAX_CONNECTIONS` | `32` | Socket backlog |
+| `--log-level` | `PLUGIN_LOG_LEVEL` | `info` | Logging level (debug/info/warning/error) |
+| `--process-mode` | `PLUGIN_PROCESS_MODE` | `process` | Concurrency mode: `thread` or `process` |
+
 ### Type Mapping
 
 The `signature.py` module maps Python types to SQL types:
@@ -682,29 +717,30 @@ The `signature.py` module maps Python types to SQL types:
 ┌─────────────────────────────────────────────────────────────────────┐
 │                      SingleStore Database                           │
 └─────────────────────────────────────────────────────────────────────┘
-                   │                    │
-                   │ ASGI/HTTP          │ Memory-mapped
-                   │ (remote)           │ (collocated)
-                   ▼                    ▼
-             ┌─────────────┐      ┌─────────────┐
-             │   asgi.py   │      │   mmap.py   │
-             │   Uvicorn   │      │   Shared    │
-             │   HTTP/2    │      │   Memory    │
-             └─────────────┘      └─────────────┘
-                   │                    │
-                   └────────────────────┘
-                              │
-                              ▼
-                      ┌─────────────────┐
-                      │  Python UDF     │
-                      │  Functions      │
-                      └─────────────────┘
+                   │                    │                    │
+                   │ ASGI/HTTP          │ Memory-mapped      │ Plugin
+                   │ (remote)           │ (collocated)       │ (Unix socket)
+                   ▼                    ▼                    ▼
+             ┌─────────────┐      ┌─────────────┐      ┌─────────────┐
+             │   asgi.py   │      │   mmap.py   │      │   plugin/   │
+             │   Uvicorn   │      │   Shared    │      │   Unix sock │
+             │   HTTP/2    │      │   Memory    │      │   + pool    │
+             └─────────────┘      └─────────────┘      └─────────────┘
+                   │                    │                    │
+                   └────────────────────┴────────────────────┘
+                                        │
+                                        ▼
+                                ┌─────────────────┐
+                                │  Python UDF     │
+                                │  Functions      │
+                                └─────────────────┘
 ```
 
 | Mode | File | Use Case |
 |------|------|----------|
 | ASGI | `asgi.py` | Remote execution via HTTP, scalable |
 | Memory-mapped | `mmap.py` | Collocated execution, lowest latency |
+| Plugin | `plugin/` | Unix socket server, thread/process pool, CLI-driven |
 | JSON | `json.py` | Simple serialization, debugging |
 | ROWDAT_1 | `rowdat_1.py` | Binary format, efficient |
 | Arrow | `arrow.py` | Columnar format, analytics |
@@ -1043,6 +1079,13 @@ with free_tier.start() as server:
 | `SINGLESTOREDB_MANAGEMENT_TOKEN` | Management API token | None |
 | `SINGLESTORE_LICENSE` | License key for Docker | None |
 | `USE_DATA_API` | Use HTTP API for tests | 0 |
+| `PLUGIN_NAME` | Plugin server: Python module to import | None |
+| `PLUGIN_SEARCH_PATH` | Plugin server: colon-separated module search dirs | `""` |
+| `PLUGIN_SOCKET_PATH` | Plugin server: Unix socket path | auto-generated |
+| `PLUGIN_N_WORKERS` | Plugin server: worker count (0 = CPU count) | `0` |
+| `PLUGIN_MAX_CONNECTIONS` | Plugin server: socket backlog | `32` |
+| `PLUGIN_LOG_LEVEL` | Plugin server: logging level | `info` |
+| `PLUGIN_PROCESS_MODE` | Plugin server: `thread` or `process` | `process` |
 
 ### B. Cursor Type Matrix
 
@@ -1096,4 +1139,5 @@ Feature options:
 | Management API | `singlestoredb/management/workspace.py` |
 | Fusion handlers | `singlestoredb/fusion/handler.py` |
 | UDF decorator | `singlestoredb/functions/decorator.py` |
+| Plugin UDF server | `singlestoredb/functions/ext/plugin/server.py` |
 | Test fixtures | `singlestoredb/pytest.py` |

CONTRIBUTING.md

@@ -182,6 +182,10 @@ pytest -v --cov=singlestoredb.connection singlestoredb/tests/test_connection.py
 # Test UDF functionality
 pytest singlestoredb/tests/test_udf.py
 
+# Manual testing of the plugin UDF server
+python -m singlestoredb.functions.ext.plugin \
+    --plugin-name myfuncs --search-path /path/to/modules
+
 # Test against specific server (skips Docker)
 SINGLESTOREDB_URL=admin:pass@localhost:3306 pytest -v singlestoredb/tests
 

README.md

@@ -18,7 +18,7 @@ analytics and vector search.
 - **Vector Store**: Pinecone-compatible vector database API for similarity search
   applications with built-in connection pooling
 - **User-Defined Functions**: Deploy Python functions as SingleStore UDFs with
-  automatic type mapping
+  automatic type mapping (HTTP/ASGI or plugin-mode via CLI)
 - **SQLAlchemy Support**: Integrate with SQLAlchemy through the optional
   `sqlalchemy-singlestoredb` adapter
 - **Fusion SQL**: Extend SQL with custom client-side command handlers

singlestoredb/functions/ext/plugin/__init__.py

@@ -1 +1 @@
-"""High-performance collocated Python UDF server for SingleStoreDB."""
+"""High-performance plugin Python UDF server for SingleStoreDB."""

singlestoredb/functions/ext/plugin/__main__.py

@@ -1,5 +1,5 @@
 """
-CLI entry point for the collocated Python UDF server.
+CLI entry point for the plugin Python UDF server.
 
 Usage::
 
@@ -21,13 +21,13 @@
 from .registry import setup_logging
 from .server import Server
 
-logger = logging.getLogger('collocated')
+logger = logging.getLogger('plugin')
 
 
 def main(argv: Any = None) -> None:
     parser = argparse.ArgumentParser(
         prog='python -m singlestoredb.functions.ext.plugin',
-        description='High-performance collocated Python UDF server',
+        description='High-performance plugin Python UDF server',
     )
     parser.add_argument(
         '--plugin-name',

singlestoredb/functions/ext/plugin/connection.py

@@ -27,7 +27,7 @@
 if TYPE_CHECKING:
     from .server import SharedRegistry
 
-logger = logging.getLogger('collocated.connection')
+logger = logging.getLogger('plugin.connection')
 
 # Protocol constants
 PROTOCOL_VERSION = 1

singlestoredb/functions/ext/plugin/control.py

@@ -15,7 +15,7 @@
 if TYPE_CHECKING:
     from .server import SharedRegistry
 
-logger = logging.getLogger('collocated.control')
+logger = logging.getLogger('plugin.control')
 
 
 @dataclass

singlestoredb/functions/ext/plugin/registry.py

@@ -4,7 +4,7 @@
 This module contains the core FunctionRegistry class (moved from
 wasm/udf_handler.py) plus standalone call_function() and
 describe_functions_json() helpers. Both the WASM handler and the
-collocated server use these directly.
+plugin server use these directly.
 """
 import inspect
 import json
@@ -450,7 +450,7 @@ def call_function(
     """Call a registered UDF by name using the C accelerator or fallback.
 
     This is the hot-path function used by both the WASM handler and
-    the collocated server.
+    the plugin server.
     """
     if name not in registry.functions:
         raise ValueError(f'unknown function: {name}')

singlestoredb/functions/ext/plugin/server.py

@@ -28,7 +28,7 @@
 from .connection import handle_connection
 from .registry import FunctionRegistry
 
-logger = logging.getLogger('collocated.server')
+logger = logging.getLogger('plugin.server')
 
 
 def _read_pipe_message(fd: int) -> Optional[bytes]:
@@ -151,7 +151,7 @@ def _build_fresh_registry(self) -> FunctionRegistry:
 
 
 class Server:
-    """Collocated UDF server with Unix socket + thread pool."""
+    """Plugin UDF server with Unix socket + thread pool."""
 
     def __init__(self, config: Dict[str, Any]) -> None:
         self.config = config