Struct PoolManager

pub struct PoolManager { /* private fields */ }

Manages the pool server process and connections

Implementations

impl PoolManager

pub fn calculate_heap_size(max_concurrency: usize) -> usize

Calculate heap size based on concurrency level.

Formula: BASE_HEAP_MB + ((max_concurrency / CONCURRENCY_DIVISOR) * HEAP_INCREMENT_PER_DIVISOR_MB) Result is capped at MAX_HEAP_MB.

This scales memory allocation with expected load while maintaining a reasonable minimum.

pub fn format_return_value(value: Option<Value>) -> String

Format a result value from the pool response into a string.

If the value is already a string, returns it directly. Otherwise, serializes it to JSON.

pub fn parse_success_response(response: PoolResponse) -> ScriptResult

Parse a successful pool response into a ScriptResult.

Converts logs from PoolLogEntry to LogEntry and extracts the return value.

pub fn parse_error_response(response: PoolResponse) -> PluginError

Parse a failed pool response into a PluginError.

Extracts error details and converts logs for inclusion in the error payload.

pub fn parse_pool_response( response: PoolResponse, ) -> Result<ScriptResult, PluginError>

Parse a pool response into either a success result or an error.

This is the main entry point for response parsing, dispatching to either parse_success_response or parse_error_response based on the success flag.

pub fn parse_health_result(result: &Value) -> ParsedHealthResult

Parse health check result JSON into individual fields.

Extracts status, uptime, memory usage, pool stats, and success rate from the nested JSON structure returned by the pool server.

pub fn new() -> Self

Create a new PoolManager with default socket path

pub fn with_socket_path(socket_path: String) -> Self

Create a new PoolManager with custom socket path

pub async fn is_initialized(&self) -> bool

Check if the pool manager has been initialized.

This is useful for health checks to determine if the plugin pool is expected to be running.

pub async fn ensure_started(&self) -> Result<(), PluginError>

Start the pool server if not already running

pub async fn execute_plugin( &self, plugin_id: String, compiled_code: Option<String>, plugin_path: Option<String>, params: Value, headers: Option<HashMap<String, Vec<String>>>, socket_path: String, http_request_id: Option<String>, timeout_secs: Option<u64>, route: Option<String>, config: Option<Value>, method: Option<String>, query: Option<Value>, ) -> Result<ScriptResult, PluginError>

Execute a plugin via the pool

pub fn is_dead_server_error(err: &PluginError) -> bool

Check if an error indicates the pool server is dead and needs restart

pub async fn precompile_plugin( &self, plugin_id: String, plugin_path: Option<String>, source_code: Option<String>, ) -> Result<String, PluginError>

Precompile a plugin

pub async fn cache_compiled_code( &self, plugin_id: String, compiled_code: String, ) -> Result<(), PluginError>

Cache compiled code in the pool

pub async fn invalidate_plugin( &self, plugin_id: String, ) -> Result<(), PluginError>

Invalidate a cached plugin

pub async fn health_check(&self) -> Result<HealthStatus, PluginError>

pub async fn ensure_healthy(&self) -> Result<bool, PluginError>

Check health and restart if unhealthy

pub async fn restart(&self) -> Result<(), PluginError>

Force restart the pool server (public API - acquires lock)

pub fn circuit_state(&self) -> CircuitState

Get current circuit breaker state for monitoring

pub fn avg_response_time_ms(&self) -> u32

Get average response time in ms (for monitoring)

pub fn is_recovering(&self) -> bool

Check if currently in recovery mode

pub fn recovery_allowance_percent(&self) -> u32

Get current recovery allowance percentage (0-100)

pub async fn shutdown(&self) -> Result<(), PluginError>

Shutdown the pool server gracefully

Trait Implementations

impl Default for PoolManager

fn default() -> Self

Returns the “default value” for a type.

impl Drop for PoolManager

fn drop(&mut self)

Executes the destructor for this type.