Struct FunctionExecutor 

pub struct FunctionExecutor { /* private fields */ }

Executes functions with timeout and error handling.

Implementations

impl FunctionExecutor

pub fn new(registry: Arc<FunctionRegistry>, db_pool: PgPool) -> Self

Create a new function executor.

pub fn with_timeout( registry: Arc<FunctionRegistry>, db_pool: PgPool, default_timeout: Duration, ) -> Self

Create a new function executor with custom timeout.

pub fn with_dispatch( registry: Arc<FunctionRegistry>, db_pool: PgPool, job_dispatcher: Option<Arc<dyn JobDispatch>>, workflow_dispatcher: Option<Arc<dyn WorkflowDispatch>>, ) -> Self

Create a new function executor with dispatch capabilities.

pub async fn execute( &self, function_name: &str, args: Value, auth: AuthContext, request: RequestMetadata, ) -> Result<ExecutionResult>

Execute a function call.

pub fn has_function(&self, function_name: &str) -> bool

Check if a function exists.