Struct FunctionRouter 

pub struct FunctionRouter { /* private fields */ }

Routes and executes function calls with timeout, rate limiting, and observability.

Implementations

impl FunctionRouter

pub fn new(registry: Arc<FunctionRegistry>, db: Database) -> Self

Create a new function router.

pub fn with_http_client( registry: Arc<FunctionRegistry>, db: Database, http_client: CircuitBreakerClient, ) -> Self

Create a new function router with a custom HTTP client.

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

Create a router with dispatch capabilities.

pub fn with_dispatch_and_issuer( registry: Arc<FunctionRegistry>, db: Database, job_dispatcher: Option<Arc<dyn JobDispatch>>, workflow_dispatcher: Option<Arc<dyn WorkflowDispatch>>, token_issuer: Option<Arc<dyn TokenIssuer>>, ) -> Self

Create a router with dispatch and token issuer.

pub fn with_role_resolver(self, resolver: SharedRoleResolver) -> Self

Set a custom role resolver for RBAC extension.

pub fn set_role_resolver(&mut self, resolver: SharedRoleResolver)

Set a custom role resolver (mutable reference version).

pub fn with_rate_limiter( self, rate_limiter: Arc<dyn RateLimiterBackend>, ) -> Self

Override the default HybridRateLimiter with a custom backend (e.g. crate::rate_limit::StrictRateLimiter for cluster-correct quotas).

pub fn set_rate_limiter(&mut self, rate_limiter: Arc<dyn RateLimiterBackend>)

Replace the rate-limiter backend (mutable variant for late binding).

pub fn with_token_issuer(self, issuer: Arc<dyn TokenIssuer>) -> Self

Set the token issuer for this router (enables ctx.issue_token() in mutations).

pub fn with_token_ttl(self, ttl: AuthTokenTtl) -> Self

Set the token TTL config for this router (configures ctx.issue_token_pair() durations).

pub fn set_token_ttl(&mut self, ttl: AuthTokenTtl)

Set the token TTL config (mutable reference version).

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 fn with_kv(self, kv: Arc<dyn KvHandle>) -> Self

Attach a KV store handle so handlers can call ctx.kv().

pub fn set_kv(&mut self, kv: Arc<dyn KvHandle>)

Attach a KV store handle (mutable reference version).

pub fn with_default_timeout(self, timeout: Duration) -> Self

Set the default timeout applied to all function calls.

pub fn set_max_jobs_per_request(&mut self, limit: usize)

Set the maximum number of jobs a single mutation may dispatch. A value of 0 disables the limit.

pub fn set_max_result_size_bytes(&mut self, limit: usize)

Set the maximum serialized response size in bytes. A value of 0 disables the limit.

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

Execute a function call with timeout, observability, and signals emission.

pub fn function_info(&self, function_name: &str) -> Option<FunctionInfo>

Look up function metadata by name.

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

Check if a function exists.

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

Get the function kind by name.

pub fn function_infos(&self) -> Vec<FunctionInfo>

Return info for all registered query and mutation functions.

pub fn cache(&self) -> Arc<QueryCacheCoordinator>

Shared handle to the query cache coordinator (used to wire cluster invalidation).

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