udb 0.3.1

// <auto-generated>
// Generated by `udb sdk generate` from the embedded proto descriptor set. Edit the template under sdk-templates/<lang>/, not this file.
//
// UDB C# SDK — generated robustness/forwarding layer.
//   Language:         csharp
//   UDB version:      0.3.1
//   Protocol version: 1.0.0
//   Services:         7
//   RPCs:             153
//
// This file is RENDERED by `udb sdk generate` from
//   sdk-templates/csharp/Udb.Client/GeneratedClient.cs.tmpl
// into
//   sdk/csharp/Udb.Client/GeneratedClient.cs
//
// It is a thin, uniform wrapper OVER the committed buf-generated stub clients in
// sdk/csharp/gen (e.g. Udb.Services.V1.DataBroker.DataBrokerClient,
// udb.core.Authn.Services.V1.AuthnService.AuthnServiceClient). Each per-RPC
// method forwards to the stub's `<Rpc>Async` (or streaming) method, adding the
// shared deadline / retry / backoff / metadata / error-mapping behaviour from
// GeneratedClientRuntime.cs.
//
// The stub is held as `dynamic`, so this renderer never has to resolve the
// PascalCased per-service C# namespace — it dispatches to the stub method by
// name. The buf stubs are strongly typed at runtime, so the forwarded calls and
// their request/response message types remain exactly the generated protobuf
// types.
//
// DO NOT EDIT — re-run `udb sdk generate` instead. This file COMPOSES WITH the
// hand-written UdbClient / UdbAuthClient / UdbMetadata; it never redefines them.
// </auto-generated>
using Grpc.Core;

namespace Udb.Client.Generated;

// ── Per-service robustness wrappers ─────────────────────────────────────────
// One partial wrapper class per gRPC service. The per-service block below
// declares the class skeleton (constructor + stub field); the per-RPC block
// further down declares the typed forwarding methods, which merge into the same
// partial class by name (the service-name placeholder matches across both blocks).

/// <summary>
/// Robustness wrapper for the <c>udb.core.analytics.services.v1.AnalyticsService</c> service
/// (7 RPCs). Forwards to the buf-generated
/// <c>AnalyticsServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedAnalyticsServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new AnalyticsServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedAnalyticsServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.analytics.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.analytics.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.analytics.services.v1.AnalyticsService</c>).</summary>
    public const string ServiceFullName = "udb.core.analytics.services.v1.AnalyticsService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.core.apikey.services.v1.ApiKeyService</c> service
/// (7 RPCs). Forwards to the buf-generated
/// <c>ApiKeyServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedApiKeyServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new ApiKeyServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedApiKeyServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.apikey.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.apikey.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.apikey.services.v1.ApiKeyService</c>).</summary>
    public const string ServiceFullName = "udb.core.apikey.services.v1.ApiKeyService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.core.authn.services.v1.AuthnService</c> service
/// (23 RPCs). Forwards to the buf-generated
/// <c>AuthnServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedAuthnServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new AuthnServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedAuthnServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.authn.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.authn.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.authn.services.v1.AuthnService</c>).</summary>
    public const string ServiceFullName = "udb.core.authn.services.v1.AuthnService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.core.authz.services.v1.AuthzService</c> service
/// (23 RPCs). Forwards to the buf-generated
/// <c>AuthzServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedAuthzServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new AuthzServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedAuthzServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.authz.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.authz.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.authz.services.v1.AuthzService</c>).</summary>
    public const string ServiceFullName = "udb.core.authz.services.v1.AuthzService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.core.notification.services.v1.NotificationService</c> service
/// (11 RPCs). Forwards to the buf-generated
/// <c>NotificationServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedNotificationServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new NotificationServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedNotificationServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.notification.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.notification.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.notification.services.v1.NotificationService</c>).</summary>
    public const string ServiceFullName = "udb.core.notification.services.v1.NotificationService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.core.tenant.services.v1.TenantService</c> service
/// (6 RPCs). Forwards to the buf-generated
/// <c>TenantServiceClient</c> stub.
/// </summary>
public sealed partial class GeneratedTenantServiceClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new TenantServiceClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedTenantServiceClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.core.tenant.services.v1</c>).</summary>
    public const string ServicePackage = "udb.core.tenant.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.core.tenant.services.v1.TenantService</c>).</summary>
    public const string ServiceFullName = "udb.core.tenant.services.v1.TenantService";
}
/// <summary>
/// Robustness wrapper for the <c>udb.services.v1.DataBroker</c> service
/// (76 RPCs). Forwards to the buf-generated
/// <c>DataBrokerClient</c> stub.
/// </summary>
public sealed partial class GeneratedDataBrokerClient : GeneratedServiceBase
{
    private readonly dynamic _stub;

    /// <summary>
    /// Wrap an already-constructed buf stub (e.g.
    /// <c>new DataBrokerClient(channel)</c>) with the shared robustness
    /// layer. <paramref name="headers"/> supplies per-call metadata (reuse
    /// <c>UdbClient.Headers()</c> / <c>UdbMetadata</c>).
    /// </summary>
    public GeneratedDataBrokerClient(object stub, Func<Metadata> headers, UdbCallOptions? options = null)
        : base(headers, options)
    {
        _stub = stub ?? throw new ArgumentNullException(nameof(stub));
    }

    /// <summary>The proto package this service lives in (<c>udb.services.v1</c>).</summary>
    public const string ServicePackage = "udb.services.v1";

    /// <summary>The fully-qualified service name (<c>udb.services.v1.DataBroker</c>).</summary>
    public const string ServiceFullName = "udb.services.v1.DataBroker";
}

// ── Unary RPC wrappers (retry + backoff + jitter) ───────────────────────────
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>GetExecutorPerformance</c> (unary) — forwards to <c>AnalyticsServiceClient.GetExecutorPerformanceAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/GetExecutorPerformance</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetExecutorPerformanceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetExecutorPerformanceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/GetExecutorPerformance",
            co => (object)_stub.GetExecutorPerformanceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>GetPipelineSummary</c> (unary) — forwards to <c>AnalyticsServiceClient.GetPipelineSummaryAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/GetPipelineSummary</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetPipelineSummaryAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetPipelineSummaryAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/GetPipelineSummary",
            co => (object)_stub.GetPipelineSummaryAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>GetReconciliationAnalytics</c> (unary) — forwards to <c>AnalyticsServiceClient.GetReconciliationAnalyticsAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/GetReconciliationAnalytics</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetReconciliationAnalyticsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetReconciliationAnalyticsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/GetReconciliationAnalytics",
            co => (object)_stub.GetReconciliationAnalyticsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>GetSlaCompliance</c> (unary) — forwards to <c>AnalyticsServiceClient.GetSlaComplianceAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/GetSlaCompliance</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetSlaComplianceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetSlaComplianceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/GetSlaCompliance",
            co => (object)_stub.GetSlaComplianceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>GetThroughput</c> (unary) — forwards to <c>AnalyticsServiceClient.GetThroughputAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/GetThroughput</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetThroughputAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetThroughputAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/GetThroughput",
            co => (object)_stub.GetThroughputAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>RecordPipelineMetric</c> (unary) — forwards to <c>AnalyticsServiceClient.RecordPipelineMetricAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/RecordPipelineMetric</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RecordPipelineMetricAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RecordPipelineMetricAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/RecordPipelineMetric",
            co => (object)_stub.RecordPipelineMetricAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAnalyticsServiceClient
{
    /// <summary>
    /// <c>TriggerSnapshot</c> (unary) — forwards to <c>AnalyticsServiceClient.TriggerSnapshotAsync</c>.
    /// gRPC path: <c>/udb.core.analytics.services.v1.AnalyticsService/TriggerSnapshot</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> TriggerSnapshotAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.TriggerSnapshotAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.analytics.services.v1.AnalyticsService/TriggerSnapshot",
            co => (object)_stub.TriggerSnapshotAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>CreateApiKey</c> (unary) — forwards to <c>ApiKeyServiceClient.CreateApiKeyAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/CreateApiKey</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateApiKeyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateApiKeyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/CreateApiKey",
            co => (object)_stub.CreateApiKeyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>GetApiKey</c> (unary) — forwards to <c>ApiKeyServiceClient.GetApiKeyAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/GetApiKey</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetApiKeyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetApiKeyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/GetApiKey",
            co => (object)_stub.GetApiKeyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>GetApiKeyUsageStats</c> (unary) — forwards to <c>ApiKeyServiceClient.GetApiKeyUsageStatsAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/GetApiKeyUsageStats</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetApiKeyUsageStatsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetApiKeyUsageStatsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/GetApiKeyUsageStats",
            co => (object)_stub.GetApiKeyUsageStatsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>ListApiKeys</c> (unary) — forwards to <c>ApiKeyServiceClient.ListApiKeysAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/ListApiKeys</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListApiKeysAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListApiKeysAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/ListApiKeys",
            co => (object)_stub.ListApiKeysAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>RevokeApiKey</c> (unary) — forwards to <c>ApiKeyServiceClient.RevokeApiKeyAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/RevokeApiKey</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RevokeApiKeyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RevokeApiKeyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/RevokeApiKey",
            co => (object)_stub.RevokeApiKeyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>UpdateApiKey</c> (unary) — forwards to <c>ApiKeyServiceClient.UpdateApiKeyAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/UpdateApiKey</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpdateApiKeyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpdateApiKeyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/UpdateApiKey",
            co => (object)_stub.UpdateApiKeyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedApiKeyServiceClient
{
    /// <summary>
    /// <c>ValidateApiKey</c> (unary) — forwards to <c>ApiKeyServiceClient.ValidateApiKeyAsync</c>.
    /// gRPC path: <c>/udb.core.apikey.services.v1.ApiKeyService/ValidateApiKey</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ValidateApiKeyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ValidateApiKeyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.apikey.services.v1.ApiKeyService/ValidateApiKey",
            co => (object)_stub.ValidateApiKeyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>AdminResetPassword</c> (unary) — forwards to <c>AuthnServiceClient.AdminResetPasswordAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/AdminResetPassword</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> AdminResetPasswordAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.AdminResetPasswordAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/AdminResetPassword",
            co => (object)_stub.AdminResetPasswordAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>Authenticate</c> (unary) — forwards to <c>AuthnServiceClient.AuthenticateAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/Authenticate</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> AuthenticateAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.AuthenticateAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/Authenticate",
            co => (object)_stub.AuthenticateAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ChangePassword</c> (unary) — forwards to <c>AuthnServiceClient.ChangePasswordAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ChangePassword</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ChangePasswordAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ChangePasswordAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ChangePassword",
            co => (object)_stub.ChangePasswordAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ChangeUserStatus</c> (unary) — forwards to <c>AuthnServiceClient.ChangeUserStatusAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ChangeUserStatus</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ChangeUserStatusAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ChangeUserStatusAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ChangeUserStatus",
            co => (object)_stub.ChangeUserStatusAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ConfirmMFAEnrollment</c> (unary) — forwards to <c>AuthnServiceClient.ConfirmMFAEnrollmentAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ConfirmMFAEnrollment</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ConfirmMFAEnrollmentAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ConfirmMFAEnrollmentAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ConfirmMFAEnrollment",
            co => (object)_stub.ConfirmMFAEnrollmentAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>CreateSession</c> (unary) — forwards to <c>AuthnServiceClient.CreateSessionAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/CreateSession</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateSessionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateSessionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/CreateSession",
            co => (object)_stub.CreateSessionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>CreateUser</c> (unary) — forwards to <c>AuthnServiceClient.CreateUserAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/CreateUser</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateUserAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateUserAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/CreateUser",
            co => (object)_stub.CreateUserAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>EnrollMFA</c> (unary) — forwards to <c>AuthnServiceClient.EnrollMFAAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/EnrollMFA</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> EnrollMFAAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.EnrollMFAAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/EnrollMFA",
            co => (object)_stub.EnrollMFAAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>GetSession</c> (unary) — forwards to <c>AuthnServiceClient.GetSessionAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/GetSession</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetSessionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetSessionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/GetSession",
            co => (object)_stub.GetSessionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>GetUser</c> (unary) — forwards to <c>AuthnServiceClient.GetUserAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/GetUser</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetUserAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetUserAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/GetUser",
            co => (object)_stub.GetUserAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ListSessions</c> (unary) — forwards to <c>AuthnServiceClient.ListSessionsAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ListSessions</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListSessionsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListSessionsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ListSessions",
            co => (object)_stub.ListSessionsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ListUsers</c> (unary) — forwards to <c>AuthnServiceClient.ListUsersAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ListUsers</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListUsersAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListUsersAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ListUsers",
            co => (object)_stub.ListUsersAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>Login</c> (unary) — forwards to <c>AuthnServiceClient.LoginAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/Login</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> LoginAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.LoginAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/Login",
            co => (object)_stub.LoginAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>Logout</c> (unary) — forwards to <c>AuthnServiceClient.LogoutAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/Logout</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> LogoutAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.LogoutAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/Logout",
            co => (object)_stub.LogoutAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>RefreshSession</c> (unary) — forwards to <c>AuthnServiceClient.RefreshSessionAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/RefreshSession</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RefreshSessionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RefreshSessionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/RefreshSession",
            co => (object)_stub.RefreshSessionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>RefreshToken</c> (unary) — forwards to <c>AuthnServiceClient.RefreshTokenAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/RefreshToken</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RefreshTokenAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RefreshTokenAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/RefreshToken",
            co => (object)_stub.RefreshTokenAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ResendOTP</c> (unary) — forwards to <c>AuthnServiceClient.ResendOTPAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ResendOTP</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ResendOTPAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ResendOTPAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ResendOTP",
            co => (object)_stub.ResendOTPAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>RevokeSession</c> (unary) — forwards to <c>AuthnServiceClient.RevokeSessionAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/RevokeSession</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RevokeSessionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RevokeSessionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/RevokeSession",
            co => (object)_stub.RevokeSessionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>SendOTP</c> (unary) — forwards to <c>AuthnServiceClient.SendOTPAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/SendOTP</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> SendOTPAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.SendOTPAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/SendOTP",
            co => (object)_stub.SendOTPAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>UpdateUser</c> (unary) — forwards to <c>AuthnServiceClient.UpdateUserAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/UpdateUser</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpdateUserAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpdateUserAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/UpdateUser",
            co => (object)_stub.UpdateUserAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ValidateCSRF</c> (unary) — forwards to <c>AuthnServiceClient.ValidateCSRFAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ValidateCSRF</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ValidateCSRFAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ValidateCSRFAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ValidateCSRF",
            co => (object)_stub.ValidateCSRFAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>ValidateToken</c> (unary) — forwards to <c>AuthnServiceClient.ValidateTokenAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/ValidateToken</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ValidateTokenAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ValidateTokenAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/ValidateToken",
            co => (object)_stub.ValidateTokenAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthnServiceClient
{
    /// <summary>
    /// <c>VerifyOTP</c> (unary) — forwards to <c>AuthnServiceClient.VerifyOTPAsync</c>.
    /// gRPC path: <c>/udb.core.authn.services.v1.AuthnService/VerifyOTP</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> VerifyOTPAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.VerifyOTPAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authn.services.v1.AuthnService/VerifyOTP",
            co => (object)_stub.VerifyOTPAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>AssignRole</c> (unary) — forwards to <c>AuthzServiceClient.AssignRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/AssignRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> AssignRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.AssignRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/AssignRole",
            co => (object)_stub.AssignRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>Authorize</c> (unary) — forwards to <c>AuthzServiceClient.AuthorizeAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/Authorize</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> AuthorizeAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.AuthorizeAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/Authorize",
            co => (object)_stub.AuthorizeAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>BatchCheckPermissions</c> (unary) — forwards to <c>AuthzServiceClient.BatchCheckPermissionsAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/BatchCheckPermissions</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> BatchCheckPermissionsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.BatchCheckPermissionsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/BatchCheckPermissions",
            co => (object)_stub.BatchCheckPermissionsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>CheckAccess</c> (unary) — forwards to <c>AuthzServiceClient.CheckAccessAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/CheckAccess</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CheckAccessAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CheckAccessAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/CheckAccess",
            co => (object)_stub.CheckAccessAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>CreatePolicyRule</c> (unary) — forwards to <c>AuthzServiceClient.CreatePolicyRuleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/CreatePolicyRule</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreatePolicyRuleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreatePolicyRuleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/CreatePolicyRule",
            co => (object)_stub.CreatePolicyRuleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>CreateRole</c> (unary) — forwards to <c>AuthzServiceClient.CreateRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/CreateRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/CreateRole",
            co => (object)_stub.CreateRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>DeletePolicyRule</c> (unary) — forwards to <c>AuthzServiceClient.DeletePolicyRuleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/DeletePolicyRule</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DeletePolicyRuleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DeletePolicyRuleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/DeletePolicyRule",
            co => (object)_stub.DeletePolicyRuleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>DeleteRole</c> (unary) — forwards to <c>AuthzServiceClient.DeleteRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/DeleteRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DeleteRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DeleteRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/DeleteRole",
            co => (object)_stub.DeleteRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>GetNativeAccess</c> (unary) — forwards to <c>AuthzServiceClient.GetNativeAccessAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/GetNativeAccess</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetNativeAccessAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetNativeAccessAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/GetNativeAccess",
            co => (object)_stub.GetNativeAccessAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>GetPolicyBundle</c> (unary) — forwards to <c>AuthzServiceClient.GetPolicyBundleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/GetPolicyBundle</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetPolicyBundleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetPolicyBundleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/GetPolicyBundle",
            co => (object)_stub.GetPolicyBundleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>GetPolicyRule</c> (unary) — forwards to <c>AuthzServiceClient.GetPolicyRuleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/GetPolicyRule</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetPolicyRuleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetPolicyRuleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/GetPolicyRule",
            co => (object)_stub.GetPolicyRuleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>GetRole</c> (unary) — forwards to <c>AuthzServiceClient.GetRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/GetRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/GetRole",
            co => (object)_stub.GetRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>LintAuthzPolicies</c> (unary) — forwards to <c>AuthzServiceClient.LintAuthzPoliciesAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/LintAuthzPolicies</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> LintAuthzPoliciesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.LintAuthzPoliciesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/LintAuthzPolicies",
            co => (object)_stub.LintAuthzPoliciesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>ListAccessDecisionAudits</c> (unary) — forwards to <c>AuthzServiceClient.ListAccessDecisionAuditsAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/ListAccessDecisionAudits</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListAccessDecisionAuditsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListAccessDecisionAuditsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/ListAccessDecisionAudits",
            co => (object)_stub.ListAccessDecisionAuditsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>ListPolicyRules</c> (unary) — forwards to <c>AuthzServiceClient.ListPolicyRulesAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/ListPolicyRules</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListPolicyRulesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListPolicyRulesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/ListPolicyRules",
            co => (object)_stub.ListPolicyRulesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>ListRoles</c> (unary) — forwards to <c>AuthzServiceClient.ListRolesAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/ListRoles</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListRolesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListRolesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/ListRoles",
            co => (object)_stub.ListRolesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>ListUserPermissions</c> (unary) — forwards to <c>AuthzServiceClient.ListUserPermissionsAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/ListUserPermissions</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListUserPermissionsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListUserPermissionsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/ListUserPermissions",
            co => (object)_stub.ListUserPermissionsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>ListUserRoles</c> (unary) — forwards to <c>AuthzServiceClient.ListUserRolesAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/ListUserRoles</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListUserRolesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListUserRolesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/ListUserRoles",
            co => (object)_stub.ListUserRolesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>PutAuthzPolicy</c> (unary) — forwards to <c>AuthzServiceClient.PutAuthzPolicyAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/PutAuthzPolicy</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PutAuthzPolicyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PutAuthzPolicyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/PutAuthzPolicy",
            co => (object)_stub.PutAuthzPolicyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>PutRelationship</c> (unary) — forwards to <c>AuthzServiceClient.PutRelationshipAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/PutRelationship</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PutRelationshipAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PutRelationshipAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/PutRelationship",
            co => (object)_stub.PutRelationshipAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>PutRoleBinding</c> (unary) — forwards to <c>AuthzServiceClient.PutRoleBindingAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/PutRoleBinding</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PutRoleBindingAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PutRoleBindingAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/PutRoleBinding",
            co => (object)_stub.PutRoleBindingAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>RevokeRole</c> (unary) — forwards to <c>AuthzServiceClient.RevokeRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/RevokeRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RevokeRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RevokeRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/RevokeRole",
            co => (object)_stub.RevokeRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedAuthzServiceClient
{
    /// <summary>
    /// <c>UpdateRole</c> (unary) — forwards to <c>AuthzServiceClient.UpdateRoleAsync</c>.
    /// gRPC path: <c>/udb.core.authz.services.v1.AuthzService/UpdateRole</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpdateRoleAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpdateRoleAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.authz.services.v1.AuthzService/UpdateRole",
            co => (object)_stub.UpdateRoleAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>GetDeliveryStats</c> (unary) — forwards to <c>NotificationServiceClient.GetDeliveryStatsAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/GetDeliveryStats</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetDeliveryStatsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetDeliveryStatsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/GetDeliveryStats",
            co => (object)_stub.GetDeliveryStatsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>GetNotification</c> (unary) — forwards to <c>NotificationServiceClient.GetNotificationAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/GetNotification</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetNotificationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetNotificationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/GetNotification",
            co => (object)_stub.GetNotificationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>GetPreference</c> (unary) — forwards to <c>NotificationServiceClient.GetPreferenceAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/GetPreference</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetPreferenceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetPreferenceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/GetPreference",
            co => (object)_stub.GetPreferenceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>GetTemplate</c> (unary) — forwards to <c>NotificationServiceClient.GetTemplateAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/GetTemplate</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetTemplateAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetTemplateAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/GetTemplate",
            co => (object)_stub.GetTemplateAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>ListNotifications</c> (unary) — forwards to <c>NotificationServiceClient.ListNotificationsAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/ListNotifications</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListNotificationsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListNotificationsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/ListNotifications",
            co => (object)_stub.ListNotificationsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>ListPreferences</c> (unary) — forwards to <c>NotificationServiceClient.ListPreferencesAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/ListPreferences</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListPreferencesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListPreferencesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/ListPreferences",
            co => (object)_stub.ListPreferencesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>ListTemplates</c> (unary) — forwards to <c>NotificationServiceClient.ListTemplatesAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/ListTemplates</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListTemplatesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListTemplatesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/ListTemplates",
            co => (object)_stub.ListTemplatesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>RetryNotification</c> (unary) — forwards to <c>NotificationServiceClient.RetryNotificationAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/RetryNotification</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RetryNotificationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RetryNotificationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/RetryNotification",
            co => (object)_stub.RetryNotificationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>SendNotification</c> (unary) — forwards to <c>NotificationServiceClient.SendNotificationAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/SendNotification</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> SendNotificationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.SendNotificationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/SendNotification",
            co => (object)_stub.SendNotificationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>SetPreference</c> (unary) — forwards to <c>NotificationServiceClient.SetPreferenceAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/SetPreference</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> SetPreferenceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.SetPreferenceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/SetPreference",
            co => (object)_stub.SetPreferenceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedNotificationServiceClient
{
    /// <summary>
    /// <c>UpsertTemplate</c> (unary) — forwards to <c>NotificationServiceClient.UpsertTemplateAsync</c>.
    /// gRPC path: <c>/udb.core.notification.services.v1.NotificationService/UpsertTemplate</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpsertTemplateAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpsertTemplateAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.notification.services.v1.NotificationService/UpsertTemplate",
            co => (object)_stub.UpsertTemplateAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>CreateTenant</c> (unary) — forwards to <c>TenantServiceClient.CreateTenantAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/CreateTenant</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateTenantAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateTenantAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/CreateTenant",
            co => (object)_stub.CreateTenantAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>GetTenant</c> (unary) — forwards to <c>TenantServiceClient.GetTenantAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/GetTenant</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetTenantAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetTenantAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/GetTenant",
            co => (object)_stub.GetTenantAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>GetTenantConfig</c> (unary) — forwards to <c>TenantServiceClient.GetTenantConfigAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/GetTenantConfig</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetTenantConfigAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetTenantConfigAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/GetTenantConfig",
            co => (object)_stub.GetTenantConfigAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>ListTenants</c> (unary) — forwards to <c>TenantServiceClient.ListTenantsAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/ListTenants</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListTenantsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListTenantsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/ListTenants",
            co => (object)_stub.ListTenantsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>UpdateTenant</c> (unary) — forwards to <c>TenantServiceClient.UpdateTenantAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/UpdateTenant</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpdateTenantAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpdateTenantAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/UpdateTenant",
            co => (object)_stub.UpdateTenantAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedTenantServiceClient
{
    /// <summary>
    /// <c>UpdateTenantConfig</c> (unary) — forwards to <c>TenantServiceClient.UpdateTenantConfigAsync</c>.
    /// gRPC path: <c>/udb.core.tenant.services.v1.TenantService/UpdateTenantConfig</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpdateTenantConfigAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpdateTenantConfigAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.core.tenant.services.v1.TenantService/UpdateTenantConfig",
            co => (object)_stub.UpdateTenantConfigAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ActivateCatalog</c> (unary) — forwards to <c>DataBrokerClient.ActivateCatalogAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ActivateCatalog</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ActivateCatalogAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ActivateCatalogAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ActivateCatalog",
            co => (object)_stub.ActivateCatalogAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>AnalyticalQuery</c> (unary) — forwards to <c>DataBrokerClient.AnalyticalQueryAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/AnalyticalQuery</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> AnalyticalQueryAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.AnalyticalQueryAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/AnalyticalQuery",
            co => (object)_stub.AnalyticalQueryAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ApplyMigration</c> (unary) — forwards to <c>DataBrokerClient.ApplyMigrationAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ApplyMigration</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ApplyMigrationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ApplyMigrationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ApplyMigration",
            co => (object)_stub.ApplyMigrationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ApproveMigrationPlan</c> (unary) — forwards to <c>DataBrokerClient.ApproveMigrationPlanAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ApproveMigrationPlan</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ApproveMigrationPlanAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ApproveMigrationPlanAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ApproveMigrationPlan",
            co => (object)_stub.ApproveMigrationPlanAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>CacheDelete</c> (unary) — forwards to <c>DataBrokerClient.CacheDeleteAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/CacheDelete</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CacheDeleteAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CacheDeleteAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/CacheDelete",
            co => (object)_stub.CacheDeleteAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>CacheGet</c> (unary) — forwards to <c>DataBrokerClient.CacheGetAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/CacheGet</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CacheGetAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CacheGetAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/CacheGet",
            co => (object)_stub.CacheGetAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>CacheScan</c> (unary) — forwards to <c>DataBrokerClient.CacheScanAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/CacheScan</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CacheScanAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CacheScanAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/CacheScan",
            co => (object)_stub.CacheScanAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>CacheSet</c> (unary) — forwards to <c>DataBrokerClient.CacheSetAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/CacheSet</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CacheSetAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CacheSetAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/CacheSet",
            co => (object)_stub.CacheSetAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>CreateMaterializedView</c> (unary) — forwards to <c>DataBrokerClient.CreateMaterializedViewAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/CreateMaterializedView</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> CreateMaterializedViewAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.CreateMaterializedViewAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/CreateMaterializedView",
            co => (object)_stub.CreateMaterializedViewAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>Delete</c> (unary) — forwards to <c>DataBrokerClient.DeleteAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/Delete</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DeleteAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DeleteAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/Delete",
            co => (object)_stub.DeleteAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DeletePolicy</c> (unary) — forwards to <c>DataBrokerClient.DeletePolicyAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DeletePolicy</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DeletePolicyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DeletePolicyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DeletePolicy",
            co => (object)_stub.DeletePolicyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DismissDlqEvent</c> (unary) — forwards to <c>DataBrokerClient.DismissDlqEventAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DismissDlqEvent</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DismissDlqEventAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DismissDlqEventAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DismissDlqEvent",
            co => (object)_stub.DismissDlqEventAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DocumentDelete</c> (unary) — forwards to <c>DataBrokerClient.DocumentDeleteAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DocumentDelete</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DocumentDeleteAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DocumentDeleteAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DocumentDelete",
            co => (object)_stub.DocumentDeleteAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DocumentFind</c> (unary) — forwards to <c>DataBrokerClient.DocumentFindAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DocumentFind</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DocumentFindAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DocumentFindAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DocumentFind",
            co => (object)_stub.DocumentFindAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DocumentGet</c> (unary) — forwards to <c>DataBrokerClient.DocumentGetAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DocumentGet</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DocumentGetAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DocumentGetAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DocumentGet",
            co => (object)_stub.DocumentGetAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DocumentUpsert</c> (unary) — forwards to <c>DataBrokerClient.DocumentUpsertAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DocumentUpsert</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DocumentUpsertAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DocumentUpsertAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DocumentUpsert",
            co => (object)_stub.DocumentUpsertAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>DropResource</c> (unary) — forwards to <c>DataBrokerClient.DropResourceAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/DropResource</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> DropResourceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.DropResourceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/DropResource",
            co => (object)_stub.DropResourceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>EnqueueOutboxEvent</c> (unary) — forwards to <c>DataBrokerClient.EnqueueOutboxEventAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/EnqueueOutboxEvent</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> EnqueueOutboxEventAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.EnqueueOutboxEventAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/EnqueueOutboxEvent",
            co => (object)_stub.EnqueueOutboxEventAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>EnsureProject</c> (unary) — forwards to <c>DataBrokerClient.EnsureProjectAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/EnsureProject</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> EnsureProjectAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.EnsureProjectAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/EnsureProject",
            co => (object)_stub.EnsureProjectAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>EnsureResource</c> (unary) — forwards to <c>DataBrokerClient.EnsureResourceAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/EnsureResource</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> EnsureResourceAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.EnsureResourceAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/EnsureResource",
            co => (object)_stub.EnsureResourceAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GeneratePresignedUrl</c> (unary) — forwards to <c>DataBrokerClient.GeneratePresignedUrlAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GeneratePresignedUrl</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GeneratePresignedUrlAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GeneratePresignedUrlAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GeneratePresignedUrl",
            co => (object)_stub.GeneratePresignedUrlAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GenericDispatch</c> (unary) — forwards to <c>DataBrokerClient.GenericDispatchAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GenericDispatch</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GenericDispatchAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GenericDispatchAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GenericDispatch",
            co => (object)_stub.GenericDispatchAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetAdminSummary</c> (unary) — forwards to <c>DataBrokerClient.GetAdminSummaryAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetAdminSummary</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetAdminSummaryAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetAdminSummaryAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetAdminSummary",
            co => (object)_stub.GetAdminSummaryAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetCapabilities</c> (unary) — forwards to <c>DataBrokerClient.GetCapabilitiesAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetCapabilities</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetCapabilitiesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetCapabilitiesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetCapabilities",
            co => (object)_stub.GetCapabilitiesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetCatalogManifest</c> (unary) — forwards to <c>DataBrokerClient.GetCatalogManifestAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetCatalogManifest</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetCatalogManifestAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetCatalogManifestAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetCatalogManifest",
            co => (object)_stub.GetCatalogManifestAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetCatalogVersion</c> (unary) — forwards to <c>DataBrokerClient.GetCatalogVersionAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetCatalogVersion</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetCatalogVersionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetCatalogVersionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetCatalogVersion",
            co => (object)_stub.GetCatalogVersionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetCatalogVersions</c> (unary) — forwards to <c>DataBrokerClient.GetCatalogVersionsAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetCatalogVersions</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetCatalogVersionsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetCatalogVersionsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetCatalogVersions",
            co => (object)_stub.GetCatalogVersionsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetCdcStatus</c> (unary) — forwards to <c>DataBrokerClient.GetCdcStatusAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetCdcStatus</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetCdcStatusAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetCdcStatusAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetCdcStatus",
            co => (object)_stub.GetCdcStatusAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetDlqEvent</c> (unary) — forwards to <c>DataBrokerClient.GetDlqEventAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetDlqEvent</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetDlqEventAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetDlqEventAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetDlqEvent",
            co => (object)_stub.GetDlqEventAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetHealthReport</c> (unary) — forwards to <c>DataBrokerClient.GetHealthReportAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetHealthReport</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetHealthReportAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetHealthReportAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetHealthReport",
            co => (object)_stub.GetHealthReportAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetMigrationStatus</c> (unary) — forwards to <c>DataBrokerClient.GetMigrationStatusAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetMigrationStatus</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetMigrationStatusAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetMigrationStatusAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetMigrationStatus",
            co => (object)_stub.GetMigrationStatusAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetSaga</c> (unary) — forwards to <c>DataBrokerClient.GetSagaAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GetSaga</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GetSagaAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GetSagaAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GetSaga",
            co => (object)_stub.GetSagaAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GraphMutate</c> (unary) — forwards to <c>DataBrokerClient.GraphMutateAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GraphMutate</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GraphMutateAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GraphMutateAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GraphMutate",
            co => (object)_stub.GraphMutateAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GraphQuery</c> (unary) — forwards to <c>DataBrokerClient.GraphQueryAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/GraphQuery</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> GraphQueryAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.GraphQueryAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/GraphQuery",
            co => (object)_stub.GraphQueryAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>InitiateMultipartUpload</c> (unary) — forwards to <c>DataBrokerClient.InitiateMultipartUploadAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/InitiateMultipartUpload</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> InitiateMultipartUploadAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.InitiateMultipartUploadAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/InitiateMultipartUpload",
            co => (object)_stub.InitiateMultipartUploadAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>LintPolicies</c> (unary) — forwards to <c>DataBrokerClient.LintPoliciesAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/LintPolicies</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> LintPoliciesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.LintPoliciesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/LintPolicies",
            co => (object)_stub.LintPoliciesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListAdminAuditLogs</c> (unary) — forwards to <c>DataBrokerClient.ListAdminAuditLogsAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListAdminAuditLogs</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListAdminAuditLogsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListAdminAuditLogsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListAdminAuditLogs",
            co => (object)_stub.ListAdminAuditLogsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListDlqEvents</c> (unary) — forwards to <c>DataBrokerClient.ListDlqEventsAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListDlqEvents</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListDlqEventsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListDlqEventsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListDlqEvents",
            co => (object)_stub.ListDlqEventsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListMessageSchemas</c> (unary) — forwards to <c>DataBrokerClient.ListMessageSchemasAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListMessageSchemas</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListMessageSchemasAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListMessageSchemasAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListMessageSchemas",
            co => (object)_stub.ListMessageSchemasAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListMigrationRuns</c> (unary) — forwards to <c>DataBrokerClient.ListMigrationRunsAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListMigrationRuns</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListMigrationRunsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListMigrationRunsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListMigrationRuns",
            co => (object)_stub.ListMigrationRunsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListPolicies</c> (unary) — forwards to <c>DataBrokerClient.ListPoliciesAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListPolicies</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListPoliciesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListPoliciesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListPolicies",
            co => (object)_stub.ListPoliciesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListProjects</c> (unary) — forwards to <c>DataBrokerClient.ListProjectsAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListProjects</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListProjectsAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListProjectsAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListProjects",
            co => (object)_stub.ListProjectsAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListResources</c> (unary) — forwards to <c>DataBrokerClient.ListResourcesAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListResources</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListResourcesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListResourcesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListResources",
            co => (object)_stub.ListResourcesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ListSagas</c> (unary) — forwards to <c>DataBrokerClient.ListSagasAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ListSagas</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ListSagasAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ListSagasAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ListSagas",
            co => (object)_stub.ListSagasAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>LookupMessageSchema</c> (unary) — forwards to <c>DataBrokerClient.LookupMessageSchemaAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/LookupMessageSchema</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> LookupMessageSchemaAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.LookupMessageSchemaAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/LookupMessageSchema",
            co => (object)_stub.LookupMessageSchemaAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>MarkSagaReviewed</c> (unary) — forwards to <c>DataBrokerClient.MarkSagaReviewedAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/MarkSagaReviewed</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> MarkSagaReviewedAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.MarkSagaReviewedAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/MarkSagaReviewed",
            co => (object)_stub.MarkSagaReviewedAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PauseCdc</c> (unary) — forwards to <c>DataBrokerClient.PauseCdcAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/PauseCdc</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PauseCdcAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PauseCdcAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/PauseCdc",
            co => (object)_stub.PauseCdcAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PlanMigration</c> (unary) — forwards to <c>DataBrokerClient.PlanMigrationAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/PlanMigration</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PlanMigrationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PlanMigrationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/PlanMigration",
            co => (object)_stub.PlanMigrationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PreviewCdcRedaction</c> (unary) — forwards to <c>DataBrokerClient.PreviewCdcRedactionAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/PreviewCdcRedaction</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PreviewCdcRedactionAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PreviewCdcRedactionAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/PreviewCdcRedaction",
            co => (object)_stub.PreviewCdcRedactionAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PutPolicy</c> (unary) — forwards to <c>DataBrokerClient.PutPolicyAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/PutPolicy</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> PutPolicyAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.PutPolicyAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/PutPolicy",
            co => (object)_stub.PutPolicyAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>QuarantineDlqEvent</c> (unary) — forwards to <c>DataBrokerClient.QuarantineDlqEventAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/QuarantineDlqEvent</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> QuarantineDlqEventAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.QuarantineDlqEventAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/QuarantineDlqEvent",
            co => (object)_stub.QuarantineDlqEventAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ReloadPolicies</c> (unary) — forwards to <c>DataBrokerClient.ReloadPoliciesAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ReloadPolicies</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ReloadPoliciesAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ReloadPoliciesAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ReloadPolicies",
            co => (object)_stub.ReloadPoliciesAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ReplayDlqEvent</c> (unary) — forwards to <c>DataBrokerClient.ReplayDlqEventAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ReplayDlqEvent</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ReplayDlqEventAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ReplayDlqEventAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ReplayDlqEvent",
            co => (object)_stub.ReplayDlqEventAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ResumeCdc</c> (unary) — forwards to <c>DataBrokerClient.ResumeCdcAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ResumeCdc</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ResumeCdcAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ResumeCdcAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ResumeCdc",
            co => (object)_stub.ResumeCdcAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>RetrySagaCompensation</c> (unary) — forwards to <c>DataBrokerClient.RetrySagaCompensationAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/RetrySagaCompensation</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RetrySagaCompensationAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RetrySagaCompensationAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/RetrySagaCompensation",
            co => (object)_stub.RetrySagaCompensationAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>RollbackCatalog</c> (unary) — forwards to <c>DataBrokerClient.RollbackCatalogAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/RollbackCatalog</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> RollbackCatalogAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.RollbackCatalogAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/RollbackCatalog",
            co => (object)_stub.RollbackCatalogAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ScanProjectionDrift</c> (unary) — forwards to <c>DataBrokerClient.ScanProjectionDriftAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ScanProjectionDrift</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ScanProjectionDriftAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ScanProjectionDriftAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ScanProjectionDrift",
            co => (object)_stub.ScanProjectionDriftAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>Select</c> (unary) — forwards to <c>DataBrokerClient.SelectAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/Select</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> SelectAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.SelectAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/Select",
            co => (object)_stub.SelectAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>StageCatalog</c> (unary) — forwards to <c>DataBrokerClient.StageCatalogAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/StageCatalog</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> StageCatalogAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.StageCatalogAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/StageCatalog",
            co => (object)_stub.StageCatalogAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>StepDownCdcLeader</c> (unary) — forwards to <c>DataBrokerClient.StepDownCdcLeaderAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/StepDownCdcLeader</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> StepDownCdcLeaderAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.StepDownCdcLeaderAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/StepDownCdcLeader",
            co => (object)_stub.StepDownCdcLeaderAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>TimeSeriesQuery</c> (unary) — forwards to <c>DataBrokerClient.TimeSeriesQueryAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/TimeSeriesQuery</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> TimeSeriesQueryAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.TimeSeriesQueryAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/TimeSeriesQuery",
            co => (object)_stub.TimeSeriesQueryAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>TimeSeriesWrite</c> (unary) — forwards to <c>DataBrokerClient.TimeSeriesWriteAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/TimeSeriesWrite</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> TimeSeriesWriteAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.TimeSeriesWriteAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/TimeSeriesWrite",
            co => (object)_stub.TimeSeriesWriteAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>Upsert</c> (unary) — forwards to <c>DataBrokerClient.UpsertAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/Upsert</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> UpsertAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.UpsertAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/Upsert",
            co => (object)_stub.UpsertAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>ValidateCatalog</c> (unary) — forwards to <c>DataBrokerClient.ValidateCatalogAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/ValidateCatalog</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> ValidateCatalogAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.ValidateCatalogAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/ValidateCatalog",
            co => (object)_stub.ValidateCatalogAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>VectorHybridSearch</c> (unary) — forwards to <c>DataBrokerClient.VectorHybridSearchAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/VectorHybridSearch</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> VectorHybridSearchAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.VectorHybridSearchAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/VectorHybridSearch",
            co => (object)_stub.VectorHybridSearchAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>VectorSearch</c> (unary) — forwards to <c>DataBrokerClient.VectorSearchAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/VectorSearch</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> VectorSearchAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.VectorSearchAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/VectorSearch",
            co => (object)_stub.VectorSearchAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>VectorUpsert</c> (unary) — forwards to <c>DataBrokerClient.VectorUpsertAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/VectorUpsert</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> VectorUpsertAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.VectorUpsertAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/VectorUpsert",
            co => (object)_stub.VectorUpsertAsync(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>VerifyAdminAuditLog</c> (unary) — forwards to <c>DataBrokerClient.VerifyAdminAuditLogAsync</c>.
    /// gRPC path: <c>/udb.services.v1.DataBroker/VerifyAdminAuditLog</c>. Retries transient failures.
    /// </summary>
    public Task<dynamic> VerifyAdminAuditLogAsync(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // _stub.VerifyAdminAuditLogAsync returns a concrete AsyncUnaryCall<TResp>; box it
        // as object so no dynamic-to-closed-generic cast is ever attempted.
        return InvokeUnaryAsync(
            "/udb.services.v1.DataBroker/VerifyAdminAuditLog",
            co => (object)_stub.VerifyAdminAuditLogAsync(request, co),
            deadline,
            cancellationToken);
    }
}

// ── Server-streaming RPC wrappers (single attempt) ──────────────────────────
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>GetObject</c> (server-streaming) — forwards to
    /// <c>DataBrokerClient.GetObject</c>. gRPC path: <c>/udb.services.v1.DataBroker/GetObject</c>.
    /// Not retried mid-stream; drain the returned stream and map errors with
    /// <see cref="GeneratedServiceBase.MapStreamError"/>.
    /// </summary>
    public dynamic GetObject(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncServerStreamingCall<TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/GetObject",
            co => (object)_stub.GetObject(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PublishCDC</c> (server-streaming) — forwards to
    /// <c>DataBrokerClient.PublishCDC</c>. gRPC path: <c>/udb.services.v1.DataBroker/PublishCDC</c>.
    /// Not retried mid-stream; drain the returned stream and map errors with
    /// <see cref="GeneratedServiceBase.MapStreamError"/>.
    /// </summary>
    public dynamic PublishCDC(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncServerStreamingCall<TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/PublishCDC",
            co => (object)_stub.PublishCDC(request, co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>SelectV2</c> (server-streaming) — forwards to
    /// <c>DataBrokerClient.SelectV2</c>. gRPC path: <c>/udb.services.v1.DataBroker/SelectV2</c>.
    /// Not retried mid-stream; drain the returned stream and map errors with
    /// <see cref="GeneratedServiceBase.MapStreamError"/>.
    /// </summary>
    public dynamic SelectV2(
        dynamic request,
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncServerStreamingCall<TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/SelectV2",
            co => (object)_stub.SelectV2(request, co),
            deadline,
            cancellationToken);
    }
}

// ── Client-streaming RPC wrappers (never retried) ───────────────────────────
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>PutObject</c> (client-streaming) — forwards to
    /// <c>DataBrokerClient.PutObject</c>. gRPC path: <c>/udb.services.v1.DataBroker/PutObject</c>.
    /// Never retried (request stream cannot be safely replayed).
    /// </summary>
    public dynamic PutObject(
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncClientStreamingCall<TReq,TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/PutObject",
            co => (object)_stub.PutObject(co),
            deadline,
            cancellationToken);
    }
}

// ── Bidirectional-streaming RPC wrappers (never retried) ────────────────────
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>BatchSelect</c> (bidi-streaming) — forwards to
    /// <c>DataBrokerClient.BatchSelect</c>. gRPC path: <c>/udb.services.v1.DataBroker/BatchSelect</c>.
    /// Never retried.
    /// </summary>
    public dynamic BatchSelect(
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncDuplexStreamingCall<TReq,TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/BatchSelect",
            co => (object)_stub.BatchSelect(co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>BatchUpsert</c> (bidi-streaming) — forwards to
    /// <c>DataBrokerClient.BatchUpsert</c>. gRPC path: <c>/udb.services.v1.DataBroker/BatchUpsert</c>.
    /// Never retried.
    /// </summary>
    public dynamic BatchUpsert(
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncDuplexStreamingCall<TReq,TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/BatchUpsert",
            co => (object)_stub.BatchUpsert(co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>BeginTx</c> (bidi-streaming) — forwards to
    /// <c>DataBrokerClient.BeginTx</c>. gRPC path: <c>/udb.services.v1.DataBroker/BeginTx</c>.
    /// Never retried.
    /// </summary>
    public dynamic BeginTx(
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncDuplexStreamingCall<TReq,TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/BeginTx",
            co => (object)_stub.BeginTx(co),
            deadline,
            cancellationToken);
    }
}
public sealed partial class GeneratedDataBrokerClient
{
    /// <summary>
    /// <c>VectorBatchUpsert</c> (bidi-streaming) — forwards to
    /// <c>DataBrokerClient.VectorBatchUpsert</c>. gRPC path: <c>/udb.services.v1.DataBroker/VectorBatchUpsert</c>.
    /// Never retried.
    /// </summary>
    public dynamic VectorBatchUpsert(
        TimeSpan? deadline = null,
        CancellationToken cancellationToken = default)
    {
        // Returns the concrete AsyncDuplexStreamingCall<TReq,TResp> as dynamic.
        return InvokeStreaming(
            "/udb.services.v1.DataBroker/VectorBatchUpsert",
            co => (object)_stub.VectorBatchUpsert(co),
            deadline,
            cancellationToken);
    }
}