Thalweg · API reference ← Main docs

register_remote_udfs

Function register_remote_udfs 

Source
pub async fn register_remote_udfs(
    ctx: &SessionContext,
    manifest_path: impl AsRef<Path>,
    metrics: &MetricsRegistry,
) -> Result<(), UdfError>
Expand description

Register remote UDFs from a manifest file, recording metrics into metrics.

For each service this opens a connection (fail-fast: a handshake or connection failure aborts registration), then registers one async udf_impl::RemoteUdf per declared function, sharing a per-service circuit breaker and honouring the service’s manifest-driven limits (response ceiling, per-call timeout, connect timeout). Name collisions with already-registered functions are rejected before any connection is opened.

§Errors

Returns an error if the manifest is invalid, a name collides, a service is unreachable, or a return type cannot be parsed.