Packages
snakepit
0.12.0
0.13.0
0.12.0
0.11.1
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.9
0.8.8
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.7
0.7.6
0.7.5
0.7.4
0.7.3
0.7.2
0.7.1
0.7.0
0.6.11
0.6.10
0.6.9
0.6.8
0.6.7
0.6.6
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.1
0.5.0
0.4.3
0.4.2
0.4.1
0.4.0
0.3.3
0.3.2
0.3.1
0.3.0
0.2.1
0.2.0
0.1.2
0.1.1
0.1.0
High-performance pooler and session manager for external language integrations. Supports Python, Node.js, Ruby, and more with gRPC streaming, session management, and production-ready process cleanup.
Current section
Files
Jump to
Current section
Files
lib/snakepit/adapter.ex
defmodule Snakepit.Adapter do
@moduledoc """
Behaviour for implementing adapters in Snakepit.
Adapters define how to communicate with external processes (Python, Node.js, etc.).
This allows Snakepit to be truly generalized and support multiple ML frameworks
or external systems.
## Required Callbacks
- `executable_path/0` - Returns the path to the runtime executable (python3, node, etc.)
- `script_path/0` - Returns the path to the external script to execute
- `script_args/0` - Returns additional arguments for the script
## Example Implementation
defmodule MyApp.PythonMLAdapter do
@behaviour Snakepit.Adapter
def executable_path, do: System.find_executable("python3") || System.find_executable("python")
def script_path, do: Path.join(:code.priv_dir(:my_app), "python/ml_bridge.py")
def script_args, do: ["--mode", "pool-worker"]
end
"""
@doc """
Returns the path to the runtime executable.
This is the interpreter or runtime that will execute the script.
Examples: "python3", "node", "ruby", "R", etc.
"""
@callback executable_path() :: String.t()
@doc """
Returns the path to the external script that will be executed.
This should be an absolute path to a script that implements the
bridge protocol for communication with Snakepit.
"""
@callback script_path() :: String.t()
@doc """
Returns additional command-line arguments for the script.
These arguments will be passed to the script when it's started.
Common examples: ["--mode", "pool-worker"], ["--config", "prod"]
"""
@callback script_args() :: [String.t()]
@doc """
Optional callback to get a command-specific timeout in milliseconds.
This allows adapters to specify appropriate timeouts for different
commands based on their expected execution time.
"""
@callback command_timeout(command :: String.t(), args :: map()) :: pos_integer()
@optional_callbacks [command_timeout: 2]
end