Struct RiffDbClient 

pub struct RiffDbClient { /* private fields */ }

Typed clients for every service in the public riffdb.v1 API.

Clones share one Tonic channel while retaining independent generated client readiness state.

Implementations

impl RiffDbClient

pub async fn execute_idempotent_transport_batch_with_retry( &self, commands: Vec<IdempotentCommand>, attempts: AttemptBudget, metadata: &CallMetadata, ) -> Result<Vec<Result<ExecuteCommandResponse, ClientError>>, IdempotentTransportBatchError>

Executes at most 16 ordinary idempotent commands through one transport batch while preserving independent per-item recovery.

This is transport coalescing only: every item remains a separately authorized command with its own idempotency identity, commit decision, provenance, and typed outcome. Whole-RPC uncertainty and retryable item failures re-enter through RiffDbClient::execute_with_retry with the identical command input and key.

impl RiffDbClient

pub async fn execute_named_application_query( &mut self, query: NamedQuery, metadata: &CallMetadata, ) -> Result<NamedQueryResult, ApplicationClientError>

Executes one named module query through one public application RPC.

pub async fn execute_application_command( &mut self, command: ApplicationCommand, attempts: AttemptBudget, metadata: &CallMetadata, ) -> Result<ApplicationCommandResult, ApplicationClientError>

Executes one symbolic command with bounded retry and no kernel-shaped caller input.

impl RiffDbClient

pub async fn connect(endpoint: Endpoint) -> Result<Self, ClientError>

Connects all typed service clients over one lazily cloned channel.

pub fn from_channel(channel: Channel) -> Self

Constructs all typed service clients over an existing channel.

pub fn set_observed_history_incarnation(&mut self, observed: Option<u64>)

Remembers an observed history incarnation for subsequent commit reads.

Pass None to clear. Explicit per-request values always win.

pub const fn observed_history_incarnation(&self) -> Option<u64>

Returns the client-remembered observed history incarnation, if any.

pub fn apply_observed_history_incarnation_get( &self, request: GetCommitRequest, ) -> GetCommitRequest

Fills observed_history_incarnation on a get-commit request when unset.

pub fn apply_observed_history_incarnation_scan( &self, request: ScanCommitsRequest, ) -> ScanCommitsRequest

Fills observed_history_incarnation on a scan-commits request when unset.

pub fn apply_observed_history_incarnation_subscribe( &self, request: SubscribeCommitsRequest, ) -> SubscribeCommitsRequest

Fills observed_history_incarnation on a subscribe request when unset.

pub fn apply_observed_history_incarnation_replay( &self, request: ReplayEventsRequest, ) -> ReplayEventsRequest

Fills observed_history_incarnation on a replay-events request when unset (0).

pub fn apply_observed_history_incarnation_tail( &self, request: TailEventsRequest, ) -> TailEventsRequest

Fills observed_history_incarnation on a tail-events request when unset (0).

pub fn remember_history_incarnation_from_get( &mut self, response: &GetCommitResponse, )

Remembers the history incarnation reported by a get-commit response.

pub fn remember_history_incarnation_from_scan( &mut self, response: &ScanCommitsResponse, )

Remembers the history incarnation reported by a commit page.

pub fn remember_history_incarnation_from_event_page( &mut self, page: Option<&EventPage>, )

Remembers the history incarnation reported by an event page.

pub async fn describe_contract( &mut self, message: DescribeContractRequest, metadata: &CallMetadata, ) -> Result<DescribeContractResponse, ClientError>

Performs the checked application describe_contract unary RPC.

pub async fn get_application_catalog( &mut self, message: GetApplicationCatalogRequest, metadata: &CallMetadata, ) -> Result<GetApplicationCatalogResponse, ClientError>

Performs the checked application get_application_catalog unary RPC.

pub async fn check_query( &mut self, message: CheckQueryRequest, metadata: &CallMetadata, ) -> Result<CheckQueryResponse, ClientError>

Performs the checked application check_query unary RPC.

pub async fn explain_query( &mut self, message: ExplainQueryRequest, metadata: &CallMetadata, ) -> Result<ExplainQueryResponse, ClientError>

Performs the checked application explain_query unary RPC.

pub async fn execute_query( &mut self, message: ExecuteQueryRequest, metadata: &CallMetadata, ) -> Result<ExecuteQueryResponse, ClientError>

Performs the checked application execute_query unary RPC.

pub async fn deploy_query_module( &mut self, message: DeployQueryModuleRequest, metadata: &CallMetadata, ) -> Result<DeployQueryModuleResponse, ClientError>

Performs the checked application deploy_query_module unary RPC.

pub async fn deploy_reactive_module( &mut self, message: DeployReactiveModuleRequest, metadata: &CallMetadata, ) -> Result<DeployReactiveModuleResponse, ClientError>

Performs the checked application deploy_reactive_module unary RPC.

pub async fn get_query_module( &mut self, message: GetQueryModuleRequest, metadata: &CallMetadata, ) -> Result<GetQueryModuleResponse, ClientError>

Performs the checked application get_query_module unary RPC.

pub async fn execute_projected_query_raw( &mut self, message: ExecuteProjectedQueryRequest, metadata: &CallMetadata, ) -> Result<ExecuteProjectedQueryResponse, ClientError>

Performs the checked application execute_projected_query unary RPC.

pub async fn inspect_vector_state( &mut self, message: InspectVectorStateRequest, metadata: &CallMetadata, ) -> Result<InspectVectorStateResponse, ClientError>

Performs the checked application inspect_vector_state unary RPC.

pub async fn validate_contract( &mut self, message: ValidateContractRequest, metadata: &CallMetadata, ) -> Result<ValidateContractResponse, ClientError>

Performs the checked validate_contract unary RPC.

pub async fn explain_command( &mut self, message: ExplainCommandRequest, metadata: &CallMetadata, ) -> Result<ExplainCommandResponse, ClientError>

Performs the checked explain_command unary RPC.

pub async fn deploy_contract( &mut self, message: DeployContractRequest, metadata: &CallMetadata, ) -> Result<DeployContractResponse, ClientError>

Performs the checked deploy_contract unary RPC.

pub async fn get_active_contract( &mut self, message: GetActiveContractRequest, metadata: &CallMetadata, ) -> Result<GetActiveContractResponse, ClientError>

Performs the checked get_active_contract unary RPC.

pub async fn get_contract_version( &mut self, message: GetContractVersionRequest, metadata: &CallMetadata, ) -> Result<GetContractVersionResponse, ClientError>

Performs the checked get_contract_version unary RPC.

pub async fn discover_command_tools( &mut self, message: DiscoverCommandToolsRequest, metadata: &CallMetadata, ) -> Result<DiscoverCommandToolsResponse, ClientError>

Performs the checked discover_command_tools unary RPC.

pub async fn discover_resources( &mut self, message: DiscoverResourcesRequest, metadata: &CallMetadata, ) -> Result<DiscoverResourcesResponse, ClientError>

Performs the checked discover_resources unary RPC.

pub async fn get_reactive_wakeup( &mut self, message: GetReactiveWakeupRequest, metadata: &CallMetadata, ) -> Result<GetReactiveWakeupResponse, ClientError>

Performs the checked get_reactive_wakeup unary RPC.

pub async fn execute( &mut self, message: ExecuteCommandRequest, metadata: &CallMetadata, ) -> Result<ExecuteCommandResponse, ClientError>

Performs the checked execute unary RPC.

pub async fn execute_batch( &mut self, message: ExecuteCommandBatchRequest, metadata: &CallMetadata, ) -> Result<ExecuteCommandBatchResponse, ClientError>

Performs the checked execute_batch unary RPC.

pub async fn get_outcome( &mut self, message: GetOutcomeRequest, metadata: &CallMetadata, ) -> Result<GetOutcomeResponse, ClientError>

Performs the checked get_outcome unary RPC.

pub async fn get_entity( &mut self, message: GetEntityRequest, metadata: &CallMetadata, ) -> Result<GetEntityResponse, ClientError>

Performs the checked get_entity unary RPC.

pub async fn scan_index( &mut self, message: ScanIndexRequest, metadata: &CallMetadata, ) -> Result<ScanIndexResponse, ClientError>

Performs the checked scan_index unary RPC.

pub async fn query_projection( &mut self, message: QueryProjectionRequest, metadata: &CallMetadata, ) -> Result<QueryProjectionResponse, ClientError>

Performs the checked query_projection unary RPC.

pub async fn get_projection_status( &mut self, message: GetProjectionStatusRequest, metadata: &CallMetadata, ) -> Result<GetProjectionStatusResponse, ClientError>

Performs the checked get_projection_status unary RPC.

pub async fn wait_for_projection( &mut self, message: QueryProjectionRequest, required_sequence: CommitSequence, maximum_wait: Duration, metadata: &CallMetadata, ) -> Result<QueryProjectionResponse, ClientError>

Queries a projection while asking the server to wait for one sequence.

The server owns waiting and frontier correctness. This helper only maps the exact Duration into the protocol’s total-nanosecond field and retains every caller-selected query, page, and fresh request ID field.

pub async fn get_commit( &mut self, message: GetCommitRequest, metadata: &CallMetadata, ) -> Result<GetCommitResponse, ClientError>

Performs the checked get_commit unary RPC.

pub async fn scan_commits( &mut self, message: ScanCommitsRequest, metadata: &CallMetadata, ) -> Result<ScanCommitsResponse, ClientError>

Performs the checked scan_commits unary RPC.

pub async fn trace_provenance( &mut self, message: TraceProvenanceRequest, metadata: &CallMetadata, ) -> Result<TraceProvenanceResponse, ClientError>

Performs the checked trace_provenance unary RPC.

pub async fn describe_event( &mut self, message: DescribeEventRequest, metadata: &CallMetadata, ) -> Result<DescribeEventResponse, ClientError>

Performs the checked describe_event unary RPC.

pub async fn replay_events( &mut self, message: ReplayEventsRequest, metadata: &CallMetadata, ) -> Result<ReplayEventsResponse, ClientError>

Performs the checked replay_events unary RPC.

pub async fn tail_events( &mut self, message: TailEventsRequest, metadata: &CallMetadata, ) -> Result<TailEventsResponse, ClientError>

Performs the checked tail_events unary RPC.

pub async fn consume_event_stream( &mut self, message: ConsumeEventStreamRequest, metadata: &CallMetadata, ) -> Result<ConsumeEventStreamResponse, ClientError>

Performs the checked consume_event_stream unary RPC.

pub async fn acknowledge_event_stream( &mut self, message: AcknowledgeEventStreamRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked acknowledge_event_stream unary RPC.

pub async fn negative_acknowledge_event_stream( &mut self, message: NegativeAcknowledgeEventStreamRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked negative_acknowledge_event_stream unary RPC.

pub async fn seek_event_stream_consumer( &mut self, message: SeekEventStreamConsumerRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked seek_event_stream_consumer unary RPC.

pub async fn retire_event_stream_consumer( &mut self, message: RetireEventStreamConsumerRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked retire_event_stream_consumer unary RPC.

pub async fn get_event_stream_consumer_status( &mut self, message: GetEventStreamConsumerStatusRequest, metadata: &CallMetadata, ) -> Result<GetEventStreamConsumerStatusResponse, ClientError>

Performs the checked get_event_stream_consumer_status unary RPC.

pub async fn consume_contextual_subscription( &mut self, message: ConsumeContextualSubscriptionRequest, metadata: &CallMetadata, ) -> Result<ConsumeContextualSubscriptionResponse, ClientError>

Performs the checked consume_contextual_subscription unary RPC.

pub async fn acknowledge_contextual_subscription( &mut self, message: AcknowledgeContextualSubscriptionRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked acknowledge_contextual_subscription unary RPC.

pub async fn negative_acknowledge_contextual_subscription( &mut self, message: NegativeAcknowledgeContextualSubscriptionRequest, metadata: &CallMetadata, ) -> Result<EventConsumerMutationResponse, ClientError>

Performs the checked negative_acknowledge_contextual_subscription unary RPC.

pub async fn get_contextual_subscription_status( &mut self, message: GetContextualSubscriptionStatusRequest, metadata: &CallMetadata, ) -> Result<GetEventStreamConsumerStatusResponse, ClientError>

Performs the checked get_contextual_subscription_status unary RPC.

pub async fn execute_contextual_reaction( &mut self, message: ExecuteContextualReactionRequest, metadata: &CallMetadata, ) -> Result<ExecuteCommandResponse, ClientError>

Performs the checked execute_contextual_reaction unary RPC.

pub async fn register_follower( &mut self, message: RegisterFollowerRequest, metadata: &CallMetadata, ) -> Result<RegisterFollowerResponse, ClientError>

Performs the checked register_follower unary RPC.

pub async fn promote_follower( &mut self, message: PromoteFollowerRequest, metadata: &CallMetadata, ) -> Result<PromoteFollowerResponse, ClientError>

Performs the checked promote_follower unary RPC.

pub async fn retire_follower( &mut self, message: RetireFollowerRequest, metadata: &CallMetadata, ) -> Result<RetireFollowerResponse, ClientError>

Performs the checked retire_follower unary RPC.

pub async fn fence_replication_primary( &mut self, message: FenceReplicationPrimaryRequest, metadata: &CallMetadata, ) -> Result<FenceReplicationPrimaryResponse, ClientError>

Performs the checked fence_replication_primary unary RPC.

pub async fn health( &mut self, message: HealthRequest, metadata: &CallMetadata, ) -> Result<HealthResponse, ClientError>

Performs the checked health unary RPC.

pub async fn stats( &mut self, message: StatsRequest, metadata: &CallMetadata, ) -> Result<StatsResponse, ClientError>

Performs the checked stats unary RPC.

pub async fn revoke_capability( &mut self, message: RevokeCapabilityRequest, metadata: &CallMetadata, ) -> Result<RevokeCapabilityResponse, ClientError>

Performs the checked revoke_capability unary RPC.

pub async fn list_pending_outbox_deliveries( &mut self, message: ListPendingOutboxDeliveriesRequest, metadata: &CallMetadata, ) -> Result<ListPendingOutboxDeliveriesResponse, ClientError>

Performs the checked list_pending_outbox_deliveries unary RPC.

pub async fn create_offline_backup( &mut self, message: CreateOfflineBackupRequest, metadata: &CallMetadata, ) -> Result<CreateOfflineBackupResponse, ClientError>

Performs the checked create_offline_backup unary RPC.

pub async fn restore_offline_backup( &mut self, message: RestoreOfflineBackupRequest, metadata: &CallMetadata, ) -> Result<RestoreOfflineBackupResponse, ClientError>

Performs the checked restore_offline_backup unary RPC.

pub async fn restore_archived_backup( &mut self, message: RestoreArchivedBackupRequest, metadata: &CallMetadata, ) -> Result<RestoreArchivedBackupResponse, ClientError>

Performs the checked restore_archived_backup unary RPC.

pub async fn retire_offline_backup( &mut self, message: RetireOfflineBackupRequest, metadata: &CallMetadata, ) -> Result<RetireOfflineBackupResponse, ClientError>

Performs the checked retire_offline_backup unary RPC.

pub async fn start_offline_storage_scrub( &mut self, message: StartOfflineStorageScrubRequest, metadata: &CallMetadata, ) -> Result<StartOfflineStorageScrubResponse, ClientError>

Performs the checked start_offline_storage_scrub unary RPC.

pub async fn get_offline_maintenance_operation( &mut self, message: GetOfflineMaintenanceOperationRequest, metadata: &CallMetadata, ) -> Result<GetOfflineMaintenanceOperationResponse, ClientError>

Performs the checked get_offline_maintenance_operation unary RPC.

pub async fn check_contract_migration( &mut self, message: CheckContractMigrationRequest, metadata: &CallMetadata, ) -> Result<CheckContractMigrationResponse, ClientError>

Performs the checked check_contract_migration unary RPC.

pub async fn apply_contract_migration( &mut self, message: ApplyContractMigrationRequest, metadata: &CallMetadata, ) -> Result<ApplyContractMigrationResponse, ClientError>

Performs the checked apply_contract_migration unary RPC.

pub async fn get_contract_migration_operation( &mut self, message: GetContractMigrationOperationRequest, metadata: &CallMetadata, ) -> Result<GetContractMigrationOperationResponse, ClientError>

Performs the checked get_contract_migration_operation unary RPC.

pub async fn start_application_installation( &mut self, message: StartApplicationInstallationRequest, metadata: &CallMetadata, ) -> Result<StartApplicationInstallationResponse, ClientError>

Performs the checked start_application_installation unary RPC.

pub async fn get_application_installation( &mut self, message: GetApplicationInstallationRequest, metadata: &CallMetadata, ) -> Result<GetApplicationInstallationResponse, ClientError>

Performs the checked get_application_installation unary RPC.

pub async fn start_application_export( &mut self, message: StartApplicationExportRequest, metadata: &CallMetadata, ) -> Result<StartApplicationExportResponse, ClientError>

Performs the checked start_application_export unary RPC.

pub async fn get_application_export_page( &mut self, message: GetApplicationExportPageRequest, metadata: &CallMetadata, ) -> Result<GetApplicationExportPageResponse, ClientError>

Performs the checked get_application_export_page unary RPC.

pub async fn get_application_export( &mut self, message: GetApplicationExportRequest, metadata: &CallMetadata, ) -> Result<GetApplicationExportResponse, ClientError>

Performs the checked get_application_export unary RPC.

pub async fn cancel_application_export( &mut self, message: CancelApplicationExportRequest, metadata: &CallMetadata, ) -> Result<CancelApplicationExportResponse, ClientError>

Performs the checked cancel_application_export unary RPC.

pub async fn start_application_reimport( &mut self, message: StartApplicationReimportRequest, metadata: &CallMetadata, ) -> Result<StartApplicationReimportResponse, ClientError>

Performs the checked start_application_reimport unary RPC.

pub async fn apply_application_reimport_page( &mut self, message: ApplyApplicationReimportPageRequest, metadata: &CallMetadata, ) -> Result<ApplyApplicationReimportPageResponse, ClientError>

Performs the checked apply_application_reimport_page unary RPC.

pub async fn get_application_reimport( &mut self, message: GetApplicationReimportRequest, metadata: &CallMetadata, ) -> Result<GetApplicationReimportResponse, ClientError>

Performs the checked get_application_reimport unary RPC.

pub async fn cancel_application_reimport( &mut self, message: CancelApplicationReimportRequest, metadata: &CallMetadata, ) -> Result<CancelApplicationReimportResponse, ClientError>

Performs the checked cancel_application_reimport unary RPC.

pub async fn create_capability( &mut self, message: CreateCapabilityRequest, metadata: &CallMetadata, ) -> Result<CreateCapabilityResponse, ClientError>

Performs normal authenticated capability creation.

pub async fn create_bootstrap_capability( &mut self, message: CreateCapabilityRequest, metadata: &BootstrapCallMetadata, ) -> Result<CreateCapabilityResponse, ClientError>

Performs the loopback-only bootstrap capability creation call.

pub async fn subscribe_commits( &mut self, message: SubscribeCommitsRequest, metadata: &CallMetadata, ) -> Result<CommitNotificationStream, ClientError>

Starts a checked commit stream.

Items are decoded by the strict codec (decode_public_message). This stream does not re-walk structure after decode; exchange-style relations do not apply to commit notifications.

pub async fn stream_event_consumer( &mut self, message: ConsumeEventStreamRequest, metadata: &CallMetadata, ) -> Result<EventConsumerResponseStream, ClientError>

Starts a checked durable event-consumer response stream.

Items are decoded by the strict public codec. Consumer identity, authorization, leasing, and checkpoint semantics remain server-owned.

pub async fn watch_named_query( &mut self, message: WatchNamedQueryRequest, metadata: &CallMetadata, ) -> Result<LiveQueryUpdateStream, ClientError>

Starts a checked exact named-query live stream.

The cursor is consistency evidence only; every reconnect is freshly authenticated and authorized by the server.

pub async fn execute_with_retry( &mut self, command: &IdempotentCommand, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<ExecuteCommandResponse, ClientError>

Executes one immutable command with an explicit total submission bound.

Retryable checked failures are resubmitted immediately with a fresh outer request ID. Overloaded retries apply bounded backoff (command module); other retryables resubmit immediately without inventing a generic retry policy. This method never mutates the command name, selected version, or opaque input.

pub async fn create_capability_with_retry( &mut self, create: &NormalCapabilityCreateTemplate, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<CreateCapabilityResponse, ClientError>

Creates one normal capability with immutable identity and bounded retry.

pub async fn create_bootstrap_capability_with_retry( &mut self, create: &BootstrapCapabilityCreateTemplate, attempt_budget: AttemptBudget, metadata: &BootstrapCallMetadata, ) -> Result<CreateCapabilityResponse, ClientError>

Creates one bootstrap capability with immutable identity and bounded retry.

pub async fn create_offline_backup_with_retry( &mut self, create: &CreateOfflineBackup, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<CreateOfflineBackupResponse, ClientError>

Starts or resolves one immutable backup-create operation with bounded retry.

pub async fn restore_offline_backup_with_retry( &mut self, restore: &RestoreOfflineBackup, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<RestoreOfflineBackupResponse, ClientError>

Starts or resolves one immutable restore operation with bounded retry.

pub async fn restore_archived_backup_with_retry( &mut self, restore: &RestoreArchivedBackup, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<RestoreArchivedBackupResponse, ClientError>

Starts or resolves one immutable archive restore operation with bounded retry.

pub async fn retire_offline_backup_with_retry( &mut self, retire: &RetireOfflineBackup, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<RetireOfflineBackupResponse, ClientError>

Starts or resolves one immutable backup-retirement operation with bounded retry.

pub async fn start_offline_storage_scrub_with_retry( &mut self, scrub: &StartOfflineStorageScrub, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<StartOfflineStorageScrubResponse, ClientError>

Starts or resolves the selector-free offline storage scrub with bounded retry.

pub async fn check_contract_migration_with_retry( &mut self, check: &CheckContractMigration, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<CheckContractMigrationResponse, ClientError>

Starts or resolves one immutable migration check with bounded retry.

pub async fn apply_contract_migration_with_retry( &mut self, apply: &ApplyContractMigration, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<ApplyContractMigrationResponse, ClientError>

Starts or resolves one immutable confirmed migration apply with bounded retry.

pub async fn start_application_installation_with_retry( &mut self, start: &StartApplicationInstallation, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<StartApplicationInstallationResponse, ClientError>

Starts or resumes one immutable exact installation campaign with bounded retry.

pub async fn start_application_export_with_retry( &mut self, start: &StartApplicationExport, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<StartApplicationExportResponse, ClientError>

Starts or exactly replays one immutable symbolic export with bounded retry.

pub async fn get_application_export_page_with_retry( &mut self, operation_id: ApplicationExportOperationId, cursor: &[u8], max_rows: u16, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<GetApplicationExportPageResponse, ClientError>

Releases or exactly replays one snapshot-bound export page with bounded retry.

The opaque cursor is reused byte-for-byte across attempts. If the final response remains uncertain, callers may safely invoke this method again with the same cursor while the operation lease remains valid.

pub async fn get_application_export_operation( &mut self, operation_id: ApplicationExportOperationId, metadata: &CallMetadata, ) -> Result<GetApplicationExportResponse, ClientError>

Observes one exact durable export checkpoint with a fresh request identity.

pub async fn cancel_application_export_with_retry( &mut self, operation_id: ApplicationExportOperationId, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<CancelApplicationExportResponse, ClientError>

Cancels or exactly observes one terminal export with bounded retry.

pub async fn start_application_reimport_with_retry( &mut self, start: &StartApplicationReimport, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<StartApplicationReimportResponse, ClientError>

Starts or exactly replays one immutable application reimport campaign.

pub async fn apply_application_reimport_page_with_retry( &mut self, campaign_id: ApplicationInstallationCampaignId, page: &ApplicationExportPage, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<ApplyApplicationReimportPageResponse, ClientError>

Applies or exactly replays one hash-bearing export page.

pub async fn get_application_reimport_operation( &mut self, campaign_id: ApplicationInstallationCampaignId, metadata: &CallMetadata, ) -> Result<GetApplicationReimportResponse, ClientError>

Observes one exact durable reimport checkpoint with a fresh request identity.

pub async fn cancel_application_reimport_with_retry( &mut self, campaign_id: ApplicationInstallationCampaignId, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<CancelApplicationReimportResponse, ClientError>

Cancels or exactly observes one terminal reimport campaign.

pub async fn execute_generated<C: GeneratedCommand>( &mut self, command: &C, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<GeneratedExecution<C::Outcome>, GeneratedExecutionError>

Builds, submits, and decodes one generated command shape.

pub async fn execute_generated_with_recovery<C: GeneratedCommand>( &mut self, command: &C, attempt_budget: AttemptBudget, metadata: &CallMetadata, ) -> Result<GeneratedExecution<C::Outcome>, GeneratedExecutionError>

Executes a generated command and performs one exact same-key outcome lookup when the bounded submission loop ends in uncertainty.

impl RiffDbClient

pub async fn execute_projected_query( &mut self, query: ProjectedQuery, metadata: &CallMetadata, ) -> Result<ProjectedQueryOutcome, ApplicationClientError>

Executes one projected columnar query through the public application RPC.

impl RiffDbClient

pub async fn connect_verified_tls( config: &TlsClientConfig, ) -> Result<Self, ClientError>

Connects through mandatory CA and exact server-name verification.

This path has no trust-all, cleartext fallback, redirect, client-certificate, cipher-suite, or provider selector.

Trait Implementations

impl Clone for RiffDbClient

fn clone(&self) -> RiffDbClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.