Struct FunctionRouter 

pub struct FunctionRouter { /* private fields */ }

Routes function calls to the appropriate handler.

Implementations

impl FunctionRouter

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

Create a new function router.

pub fn with_http_client( registry: Arc<FunctionRegistry>, db_pool: PgPool, http_client: Client, ) -> Self

Create a new function router with a custom HTTP client.

pub fn with_job_dispatcher(self, dispatcher: Arc<dyn JobDispatch>) -> Self

Set the job dispatcher for this router.

pub fn with_workflow_dispatcher( self, dispatcher: Arc<dyn WorkflowDispatch>, ) -> Self

Set the workflow dispatcher for this router.

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

Route and execute a function call.

pub fn get_function_kind(&self, function_name: &str) -> Option<FunctionKind>

Get the function kind by name.

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

Check if a function exists.