Thalweg · API reference ← Main docs

register_all_udfs

Function register_all_udfs 

Source
pub async fn register_all_udfs(
    ctx: &SessionContext,
    salt: Option<&str>,
    manifest_path: Option<impl AsRef<Path>>,
) -> Result<UdfRegistration, UdfError>
Expand description

Register all enabled UDFs with a DataFusion SessionContext.

Always registers the local UDFs. When the remote feature is enabled and manifest_path is Some, it also loads and registers the remote UDFs described by that manifest, opening one connection per service (fail-fast at startup) and sharing a per-service circuit breaker across its functions.

The signature is identical regardless of which features are compiled in, so callers build the same way under feature unification. When the remote feature is not compiled in, supplying a manifest_path is an error (UdfError::RemoteDisabled) rather than a silent no-op.

§Errors

Returns an error if local registration fails, if a manifest_path is supplied without the remote feature, or (with remote) if the manifest is invalid, a name collides with an existing function, or a service is unreachable at startup.