Struct FnOpsImpl 

pub struct FnOpsImpl {
    pub runner: Arc<FnRunner>,
    pub registry: Arc<FnRegistry>,
    pub runtime: Arc<Runtime>,
    pub fn_rate_limiter: Arc<RateLimiter>,
    pub change_log: Arc<ChangeLog>,
    pub notifier: Arc<dyn ChangeNotifier>,
    pub job_queue: Arc<JobQueue>,
}

Adapter that implements [FnOps] by delegating to a FnRunner.

Holds an Arc<Runtime> so function handlers get a DataStore to operate against.

Fields

runner: Arc<FnRunner>

registry: Arc<FnRegistry>

runtime: Arc<Runtime>

fn_rate_limiter: Arc<RateLimiter>

Per-function rate limiter, keyed on "<fn_name>::<identity>". Limits are uniform; per-fn overrides can be added later via FnDef metadata once the TS define API surfaces them.

change_log: Arc<ChangeLog>

Sync change log for broadcasting ctx.db.insert/update/delete ops that happen inside a function handler. Without this, mutations via functions silently bypass sync — WS subscribers see nothing until they manually refetch. Flushed post-COMMIT so rollbacks don’t emit phantom events.

notifier: Arc<dyn ChangeNotifier>

Where to broadcast change events after a function mutation commits.

job_queue: Arc<JobQueue>

Job queue for flushing schedules buffered during a mutation handler. The schedule hook itself owns its own clone for the non-mutation enqueue path; this clone is what the post-COMMIT flush uses.

Trait Implementations

impl FnOps for FnOpsImpl

fn get_fn(&self, name: &str) -> Option<FnDef>

Look up a registered function.

fn list_fns(&self) -> Vec<FnDef>

List all registered functions.

fn call( &self, fn_name: &str, args: Value, auth: FnAuth, on_stream: Option<Box<dyn FnMut(&str) + Send>>, request: Option<RequestInfo>, ) -> Result<(Value, FnTrace), FnCallError>

Execute a function. For streaming responses, on_stream is called for each chunk as it arrives from the function handler.

fn recent_traces(&self, limit: usize) -> Vec<FnTrace>

Recent traces for observability (newest first).

fn check_rate_limit(&self, fn_name: &str, identity: &str) -> Result<(), u64>

Check whether the caller is allowed to invoke this function right now.