pub struct Client { /* private fields */ }Implementations§
Source§impl Client
impl Client
Sourcepub async fn execute_document_bulk(
&self,
batch_id: Digest,
index: Resource,
items: Vec<BulkDocumentItem>,
options: CallOptions,
) -> Result<BulkExecution, BulkRecoveryError>
pub async fn execute_document_bulk( &self, batch_id: Digest, index: Resource, items: Vec<BulkDocumentItem>, options: CallOptions, ) -> Result<BulkExecution, BulkRecoveryError>
Prepares every item, submits the batch at most once, and resolves any ambiguous or partial outcome by the stable per-item locators.
Source§impl Client
impl Client
pub async fn activate_operational_credential<S>(
&self,
plan: CredentialActivationPlan,
store: &S,
options: CallOptions,
) -> Result<ActiveOperationalCredential, CredentialActivationError>where
S: OperationalCredentialMaterialStore,
pub async fn activate_ephemeral_credential<D>(
&self,
plan: CredentialActivationPlan,
delivery: &D,
options: CallOptions,
) -> Result<ActiveOperationalCredential, CredentialActivationError>where
D: EphemeralCredentialDelivery,
Source§impl Client
impl Client
Sourcepub async fn append_exact(
&self,
request: AppendExactRequestV1,
options: ExactWorkflowOptions,
) -> Result<ExactExecutionV1<AppendExactResultV1>, ExactWorkflowError>
pub async fn append_exact( &self, request: AppendExactRequestV1, options: ExactWorkflowOptions, ) -> Result<ExactExecutionV1<AppendExactResultV1>, ExactWorkflowError>
Runs retained append through prepare, submit, and resolver without ever replacing the caller’s batch or item action identities.
Sourcepub async fn mutate_document_exact(
&self,
request: PrepareDocumentMutationRequest,
options: ExactWorkflowOptions,
) -> Result<ExactExecutionV1<DocumentMutationExactResultV1>, ExactWorkflowError>
pub async fn mutate_document_exact( &self, request: PrepareDocumentMutationRequest, options: ExactWorkflowOptions, ) -> Result<ExactExecutionV1<DocumentMutationExactResultV1>, ExactWorkflowError>
Runs one document mutation with a stable prepared locator and resolves any possibly submitted result before returning a terminal claim.
Sourcepub async fn reconcile_index_exact(
&self,
request: PrepareCreateIndexRequest,
options: ExactWorkflowOptions,
) -> Result<ExactExecutionV1<ReconcileIndexExactResultV1>, ExactWorkflowError>
pub async fn reconcile_index_exact( &self, request: PrepareCreateIndexRequest, options: ExactWorkflowOptions, ) -> Result<ExactExecutionV1<ReconcileIndexExactResultV1>, ExactWorkflowError>
Reconciles only an absent index to one exact desired definition. An existing different definition is a conflict; this helper never updates.
Source§impl Client
impl Client
Sourcepub async fn discover(
&self,
request: DiscoverRequest,
options: CallOptions,
) -> Result<DiscoverResult, ClientError>
pub async fn discover( &self, request: DiscoverRequest, options: CallOptions, ) -> Result<DiscoverResult, ClientError>
Calls the generated discover Lodestone API command.
Sourcepub async fn list_indexes(
&self,
request: ListIndexesRequest,
options: CallOptions,
) -> Result<ListIndexesResult, ClientError>
pub async fn list_indexes( &self, request: ListIndexesRequest, options: CallOptions, ) -> Result<ListIndexesResult, ClientError>
Calls the generated list_indexes Lodestone API command.
Sourcepub async fn get_index(
&self,
request: GetIndexRequest,
options: CallOptions,
) -> Result<GetIndexResult, ClientError>
pub async fn get_index( &self, request: GetIndexRequest, options: CallOptions, ) -> Result<GetIndexResult, ClientError>
Calls the generated get_index Lodestone API command.
Sourcepub async fn validate_index_change(
&self,
request: ValidateIndexChangeRequest,
options: CallOptions,
) -> Result<ValidateIndexChangeResult, ClientError>
pub async fn validate_index_change( &self, request: ValidateIndexChangeRequest, options: CallOptions, ) -> Result<ValidateIndexChangeResult, ClientError>
Calls the generated validate_index_change Lodestone API command.
Sourcepub async fn apply_index_change(
&self,
request: ApplyIndexChangeRequest,
options: CallOptions,
) -> Result<ApplyIndexChangeResult, ClientError>
pub async fn apply_index_change( &self, request: ApplyIndexChangeRequest, options: CallOptions, ) -> Result<ApplyIndexChangeResult, ClientError>
Calls the generated apply_index_change Lodestone API command.
Sourcepub async fn apply_administration_mutation(
&self,
request: ApplyAdministrationMutationRequest,
options: CallOptions,
) -> Result<ApplyAdministrationMutationResult, ClientError>
pub async fn apply_administration_mutation( &self, request: ApplyAdministrationMutationRequest, options: CallOptions, ) -> Result<ApplyAdministrationMutationResult, ClientError>
Calls the generated apply_administration_mutation Lodestone API command.
Sourcepub async fn list_aliases(
&self,
request: ListAliasesRequest,
options: CallOptions,
) -> Result<ListAliasesResult, ClientError>
pub async fn list_aliases( &self, request: ListAliasesRequest, options: CallOptions, ) -> Result<ListAliasesResult, ClientError>
Calls the generated list_aliases Lodestone API command.
Sourcepub async fn get_alias(
&self,
request: GetAliasRequest,
options: CallOptions,
) -> Result<GetAliasResult, ClientError>
pub async fn get_alias( &self, request: GetAliasRequest, options: CallOptions, ) -> Result<GetAliasResult, ClientError>
Calls the generated get_alias Lodestone API command.
Sourcepub async fn list_data_streams(
&self,
request: ListDataStreamsRequest,
options: CallOptions,
) -> Result<ListDataStreamsResult, ClientError>
pub async fn list_data_streams( &self, request: ListDataStreamsRequest, options: CallOptions, ) -> Result<ListDataStreamsResult, ClientError>
Calls the generated list_data_streams Lodestone API command.
Sourcepub async fn get_data_stream(
&self,
request: GetDataStreamRequest,
options: CallOptions,
) -> Result<GetDataStreamResult, ClientError>
pub async fn get_data_stream( &self, request: GetDataStreamRequest, options: CallOptions, ) -> Result<GetDataStreamResult, ClientError>
Calls the generated get_data_stream Lodestone API command.
Sourcepub async fn list_component_templates(
&self,
request: ListComponentTemplatesRequest,
options: CallOptions,
) -> Result<ListComponentTemplatesResult, ClientError>
pub async fn list_component_templates( &self, request: ListComponentTemplatesRequest, options: CallOptions, ) -> Result<ListComponentTemplatesResult, ClientError>
Calls the generated list_component_templates Lodestone API command.
Sourcepub async fn get_component_template(
&self,
request: GetComponentTemplateRequest,
options: CallOptions,
) -> Result<GetComponentTemplateResult, ClientError>
pub async fn get_component_template( &self, request: GetComponentTemplateRequest, options: CallOptions, ) -> Result<GetComponentTemplateResult, ClientError>
Calls the generated get_component_template Lodestone API command.
Sourcepub async fn list_index_templates(
&self,
request: ListIndexTemplatesRequest,
options: CallOptions,
) -> Result<ListIndexTemplatesResult, ClientError>
pub async fn list_index_templates( &self, request: ListIndexTemplatesRequest, options: CallOptions, ) -> Result<ListIndexTemplatesResult, ClientError>
Calls the generated list_index_templates Lodestone API command.
Sourcepub async fn get_index_template(
&self,
request: GetIndexTemplateRequest,
options: CallOptions,
) -> Result<GetIndexTemplateResult, ClientError>
pub async fn get_index_template( &self, request: GetIndexTemplateRequest, options: CallOptions, ) -> Result<GetIndexTemplateResult, ClientError>
Calls the generated get_index_template Lodestone API command.
Sourcepub async fn list_ingest_pipelines(
&self,
request: ListIngestPipelinesRequest,
options: CallOptions,
) -> Result<ListIngestPipelinesResult, ClientError>
pub async fn list_ingest_pipelines( &self, request: ListIngestPipelinesRequest, options: CallOptions, ) -> Result<ListIngestPipelinesResult, ClientError>
Calls the generated list_ingest_pipelines Lodestone API command.
Sourcepub async fn get_ingest_pipeline(
&self,
request: GetIngestPipelineRequest,
options: CallOptions,
) -> Result<GetIngestPipelineResult, ClientError>
pub async fn get_ingest_pipeline( &self, request: GetIngestPipelineRequest, options: CallOptions, ) -> Result<GetIngestPipelineResult, ClientError>
Calls the generated get_ingest_pipeline Lodestone API command.
Sourcepub async fn simulate_ingest_pipeline(
&self,
request: SimulateIngestPipelineRequest,
options: CallOptions,
) -> Result<SimulateIngestPipelineResult, ClientError>
pub async fn simulate_ingest_pipeline( &self, request: SimulateIngestPipelineRequest, options: CallOptions, ) -> Result<SimulateIngestPipelineResult, ClientError>
Calls the generated simulate_ingest_pipeline Lodestone API command.
Sourcepub async fn reprocess_by_query(
&self,
request: ReprocessByQueryRequest,
options: CallOptions,
) -> Result<ReprocessByQueryResult, ClientError>
pub async fn reprocess_by_query( &self, request: ReprocessByQueryRequest, options: CallOptions, ) -> Result<ReprocessByQueryResult, ClientError>
Calls the generated reprocess_by_query Lodestone API command.
Sourcepub async fn list_lifecycle_policies(
&self,
request: ListLifecyclePoliciesRequest,
options: CallOptions,
) -> Result<ListLifecyclePoliciesResult, ClientError>
pub async fn list_lifecycle_policies( &self, request: ListLifecyclePoliciesRequest, options: CallOptions, ) -> Result<ListLifecyclePoliciesResult, ClientError>
Calls the generated list_lifecycle_policies Lodestone API command.
Sourcepub async fn get_lifecycle_policy(
&self,
request: GetLifecyclePolicyRequest,
options: CallOptions,
) -> Result<GetLifecyclePolicyResult, ClientError>
pub async fn get_lifecycle_policy( &self, request: GetLifecyclePolicyRequest, options: CallOptions, ) -> Result<GetLifecyclePolicyResult, ClientError>
Calls the generated get_lifecycle_policy Lodestone API command.
Sourcepub async fn prepare_create_index(
&self,
request: PrepareCreateIndexRequest,
options: CallOptions,
) -> Result<PrepareCreateIndexResult, ClientError>
pub async fn prepare_create_index( &self, request: PrepareCreateIndexRequest, options: CallOptions, ) -> Result<PrepareCreateIndexResult, ClientError>
Calls the generated prepare_create_index Lodestone API command.
Sourcepub async fn prepare_delete_index(
&self,
request: PrepareDeleteIndexRequest,
options: CallOptions,
) -> Result<PrepareDeleteIndexResult, ClientError>
pub async fn prepare_delete_index( &self, request: PrepareDeleteIndexRequest, options: CallOptions, ) -> Result<PrepareDeleteIndexResult, ClientError>
Calls the generated prepare_delete_index Lodestone API command.
Sourcepub async fn submit_catalog_action(
&self,
request: SubmitCatalogActionRequest,
options: CallOptions,
) -> Result<SubmitCatalogActionResult, ClientError>
pub async fn submit_catalog_action( &self, request: SubmitCatalogActionRequest, options: CallOptions, ) -> Result<SubmitCatalogActionResult, ClientError>
Calls the generated submit_catalog_action Lodestone API command.
Sourcepub async fn resolve_catalog_action(
&self,
request: ResolveCatalogActionRequest,
options: CallOptions,
) -> Result<ResolveCatalogActionResult, ClientError>
pub async fn resolve_catalog_action( &self, request: ResolveCatalogActionRequest, options: CallOptions, ) -> Result<ResolveCatalogActionResult, ClientError>
Calls the generated resolve_catalog_action Lodestone API command.
Sourcepub async fn prepare_replayable_source_index(
&self,
request: PrepareReplayableSourceIndexRequest,
options: CallOptions,
) -> Result<PrepareReplayableSourceIndexResult, ClientError>
pub async fn prepare_replayable_source_index( &self, request: PrepareReplayableSourceIndexRequest, options: CallOptions, ) -> Result<PrepareReplayableSourceIndexResult, ClientError>
Calls the generated prepare_replayable_source_index Lodestone API command.
Sourcepub async fn submit_replayable_source_index(
&self,
request: SubmitReplayableSourceIndexRequest,
options: CallOptions,
) -> Result<SubmitReplayableSourceIndexResult, ClientError>
pub async fn submit_replayable_source_index( &self, request: SubmitReplayableSourceIndexRequest, options: CallOptions, ) -> Result<SubmitReplayableSourceIndexResult, ClientError>
Calls the generated submit_replayable_source_index Lodestone API command.
Sourcepub async fn get_replayable_source(
&self,
request: GetReplayableSourceRequest,
options: CallOptions,
) -> Result<GetReplayableSourceResult, ClientError>
pub async fn get_replayable_source( &self, request: GetReplayableSourceRequest, options: CallOptions, ) -> Result<GetReplayableSourceResult, ClientError>
Calls the generated get_replayable_source Lodestone API command.
Sourcepub async fn control_replayable_source(
&self,
request: ControlReplayableSourceRequest,
options: CallOptions,
) -> Result<ControlReplayableSourceResult, ClientError>
pub async fn control_replayable_source( &self, request: ControlReplayableSourceRequest, options: CallOptions, ) -> Result<ControlReplayableSourceResult, ClientError>
Calls the generated control_replayable_source Lodestone API command.
Sourcepub async fn clone_index(
&self,
request: CloneIndexRequest,
options: CallOptions,
) -> Result<CloneIndexResult, ClientError>
pub async fn clone_index( &self, request: CloneIndexRequest, options: CallOptions, ) -> Result<CloneIndexResult, ClientError>
Calls the generated clone_index Lodestone API command.
Sourcepub async fn configure_history(
&self,
request: ConfigureHistoryRequest,
options: CallOptions,
) -> Result<ConfigureHistoryResult, ClientError>
pub async fn configure_history( &self, request: ConfigureHistoryRequest, options: CallOptions, ) -> Result<ConfigureHistoryResult, ClientError>
Calls the generated configure_history Lodestone API command.
Sourcepub async fn get_history(
&self,
request: GetHistoryRequest,
options: CallOptions,
) -> Result<GetHistoryResult, ClientError>
pub async fn get_history( &self, request: GetHistoryRequest, options: CallOptions, ) -> Result<GetHistoryResult, ClientError>
Calls the generated get_history Lodestone API command.
Sourcepub async fn resolve_history(
&self,
request: ResolveHistoryRequest,
options: CallOptions,
) -> Result<ResolveHistoryResult, ClientError>
pub async fn resolve_history( &self, request: ResolveHistoryRequest, options: CallOptions, ) -> Result<ResolveHistoryResult, ClientError>
Calls the generated resolve_history Lodestone API command.
Sourcepub async fn place_history_hold(
&self,
request: PlaceHistoryHoldRequest,
options: CallOptions,
) -> Result<PlaceHistoryHoldResult, ClientError>
pub async fn place_history_hold( &self, request: PlaceHistoryHoldRequest, options: CallOptions, ) -> Result<PlaceHistoryHoldResult, ClientError>
Calls the generated place_history_hold Lodestone API command.
Sourcepub async fn release_history_hold(
&self,
request: ReleaseHistoryHoldRequest,
options: CallOptions,
) -> Result<ReleaseHistoryHoldResult, ClientError>
pub async fn release_history_hold( &self, request: ReleaseHistoryHoldRequest, options: CallOptions, ) -> Result<ReleaseHistoryHoldResult, ClientError>
Calls the generated release_history_hold Lodestone API command.
Sourcepub async fn prepare_document_mutation(
&self,
request: PrepareDocumentMutationRequest,
options: CallOptions,
) -> Result<PrepareDocumentMutationResult, ClientError>
pub async fn prepare_document_mutation( &self, request: PrepareDocumentMutationRequest, options: CallOptions, ) -> Result<PrepareDocumentMutationResult, ClientError>
Calls the generated prepare_document_mutation Lodestone API command.
Sourcepub async fn submit_document_mutation(
&self,
request: SubmitDocumentMutationRequest,
options: CallOptions,
) -> Result<SubmitDocumentMutationResult, ClientError>
pub async fn submit_document_mutation( &self, request: SubmitDocumentMutationRequest, options: CallOptions, ) -> Result<SubmitDocumentMutationResult, ClientError>
Calls the generated submit_document_mutation Lodestone API command.
Sourcepub async fn prepare_document_bulk(
&self,
request: PrepareDocumentBulkRequest,
options: CallOptions,
) -> Result<PrepareDocumentBulkResult, ClientError>
pub async fn prepare_document_bulk( &self, request: PrepareDocumentBulkRequest, options: CallOptions, ) -> Result<PrepareDocumentBulkResult, ClientError>
Calls the generated prepare_document_bulk Lodestone API command.
Sourcepub async fn submit_document_bulk(
&self,
request: SubmitDocumentBulkRequest,
options: CallOptions,
) -> Result<SubmitDocumentBulkResult, ClientError>
pub async fn submit_document_bulk( &self, request: SubmitDocumentBulkRequest, options: CallOptions, ) -> Result<SubmitDocumentBulkResult, ClientError>
Calls the generated submit_document_bulk Lodestone API command.
Sourcepub async fn resolve_document_bulk(
&self,
request: ResolveDocumentBulkRequest,
options: CallOptions,
) -> Result<ResolveDocumentBulkResult, ClientError>
pub async fn resolve_document_bulk( &self, request: ResolveDocumentBulkRequest, options: CallOptions, ) -> Result<ResolveDocumentBulkResult, ClientError>
Calls the generated resolve_document_bulk Lodestone API command.
Sourcepub async fn prepare_append_bulk(
&self,
request: PrepareAppendBulkRequest,
options: CallOptions,
) -> Result<PrepareAppendBulkResult, ClientError>
pub async fn prepare_append_bulk( &self, request: PrepareAppendBulkRequest, options: CallOptions, ) -> Result<PrepareAppendBulkResult, ClientError>
Calls the generated prepare_append_bulk Lodestone API command.
Sourcepub async fn submit_append_bulk(
&self,
request: SubmitAppendBulkRequest,
options: CallOptions,
) -> Result<SubmitAppendBulkResult, ClientError>
pub async fn submit_append_bulk( &self, request: SubmitAppendBulkRequest, options: CallOptions, ) -> Result<SubmitAppendBulkResult, ClientError>
Calls the generated submit_append_bulk Lodestone API command.
Sourcepub async fn resolve_append_bulk(
&self,
request: ResolveAppendBulkRequest,
options: CallOptions,
) -> Result<ResolveAppendBulkResult, ClientError>
pub async fn resolve_append_bulk( &self, request: ResolveAppendBulkRequest, options: CallOptions, ) -> Result<ResolveAppendBulkResult, ClientError>
Calls the generated resolve_append_bulk Lodestone API command.
Sourcepub async fn observe_append_committed(
&self,
request: ObserveAppendCommittedRequest,
options: CallOptions,
) -> Result<ObserveAppendCommittedResult, ClientError>
pub async fn observe_append_committed( &self, request: ObserveAppendCommittedRequest, options: CallOptions, ) -> Result<ObserveAppendCommittedResult, ClientError>
Calls the generated observe_append_committed Lodestone API command.
Sourcepub async fn resolve_document_mutation(
&self,
request: ResolveDocumentMutationRequest,
options: CallOptions,
) -> Result<ResolveDocumentMutationResult, ClientError>
pub async fn resolve_document_mutation( &self, request: ResolveDocumentMutationRequest, options: CallOptions, ) -> Result<ResolveDocumentMutationResult, ClientError>
Calls the generated resolve_document_mutation Lodestone API command.
Sourcepub async fn get_document(
&self,
request: GetDocumentRequest,
options: CallOptions,
) -> Result<GetDocumentResult, ClientError>
pub async fn get_document( &self, request: GetDocumentRequest, options: CallOptions, ) -> Result<GetDocumentResult, ClientError>
Calls the generated get_document Lodestone API command.
Sourcepub async fn search(
&self,
request: SearchRequest,
options: CallOptions,
) -> Result<SearchResult, ClientError>
pub async fn search( &self, request: SearchRequest, options: CallOptions, ) -> Result<SearchResult, ClientError>
Calls the generated search Lodestone API command.
Sourcepub async fn open_pit(
&self,
request: OpenPitRequest,
options: CallOptions,
) -> Result<OpenPitResult, ClientError>
pub async fn open_pit( &self, request: OpenPitRequest, options: CallOptions, ) -> Result<OpenPitResult, ClientError>
Calls the generated open_pit Lodestone API command.
Sourcepub async fn renew_pit(
&self,
request: RenewPitRequest,
options: CallOptions,
) -> Result<RenewPitResult, ClientError>
pub async fn renew_pit( &self, request: RenewPitRequest, options: CallOptions, ) -> Result<RenewPitResult, ClientError>
Calls the generated renew_pit Lodestone API command.
Sourcepub async fn close_pit(
&self,
request: ClosePitRequest,
options: CallOptions,
) -> Result<ClosePitResult, ClientError>
pub async fn close_pit( &self, request: ClosePitRequest, options: CallOptions, ) -> Result<ClosePitResult, ClientError>
Calls the generated close_pit Lodestone API command.
Sourcepub async fn list_operations(
&self,
request: ListOperationsRequest,
options: CallOptions,
) -> Result<ListOperationsResult, ClientError>
pub async fn list_operations( &self, request: ListOperationsRequest, options: CallOptions, ) -> Result<ListOperationsResult, ClientError>
Calls the generated list_operations Lodestone API command.
Sourcepub async fn get_operation(
&self,
request: GetOperationRequest,
options: CallOptions,
) -> Result<GetOperationResult, ClientError>
pub async fn get_operation( &self, request: GetOperationRequest, options: CallOptions, ) -> Result<GetOperationResult, ClientError>
Calls the generated get_operation Lodestone API command.
Sourcepub async fn cancel_operation(
&self,
request: CancelOperationRequest,
options: CallOptions,
) -> Result<CancelOperationResult, ClientError>
pub async fn cancel_operation( &self, request: CancelOperationRequest, options: CallOptions, ) -> Result<CancelOperationResult, ClientError>
Calls the generated cancel_operation Lodestone API command.
Sourcepub async fn list_audit_events(
&self,
request: ListAuditEventsRequest,
options: CallOptions,
) -> Result<ListAuditEventsResult, ClientError>
pub async fn list_audit_events( &self, request: ListAuditEventsRequest, options: CallOptions, ) -> Result<ListAuditEventsResult, ClientError>
Calls the generated list_audit_events Lodestone API command.
Sourcepub async fn export_audit_events(
&self,
request: ExportAuditEventsRequest,
options: CallOptions,
) -> Result<ExportAuditEventsResult, ClientError>
pub async fn export_audit_events( &self, request: ExportAuditEventsRequest, options: CallOptions, ) -> Result<ExportAuditEventsResult, ClientError>
Calls the generated export_audit_events Lodestone API command.
Sourcepub async fn reserve_service_credential(
&self,
request: ReserveServiceCredentialRequest,
options: CallOptions,
) -> Result<ReserveServiceCredentialResult, ClientError>
pub async fn reserve_service_credential( &self, request: ReserveServiceCredentialRequest, options: CallOptions, ) -> Result<ReserveServiceCredentialResult, ClientError>
Calls the generated reserve_service_credential Lodestone API command.
Sourcepub async fn reserve_service_credential_rotation(
&self,
request: ReserveServiceCredentialRotationRequest,
options: CallOptions,
) -> Result<ReserveServiceCredentialRotationResult, ClientError>
pub async fn reserve_service_credential_rotation( &self, request: ReserveServiceCredentialRotationRequest, options: CallOptions, ) -> Result<ReserveServiceCredentialRotationResult, ClientError>
Calls the generated reserve_service_credential_rotation Lodestone API command.
Sourcepub async fn activate_service_credential(
&self,
request: ActivateServiceCredentialRequest,
options: CallOptions,
) -> Result<ActivateServiceCredentialResult, ClientError>
pub async fn activate_service_credential( &self, request: ActivateServiceCredentialRequest, options: CallOptions, ) -> Result<ActivateServiceCredentialResult, ClientError>
Calls the generated activate_service_credential Lodestone API command.
Sourcepub async fn resolve_service_credential_reservation(
&self,
request: ResolveServiceCredentialReservationRequest,
options: CallOptions,
) -> Result<ResolveServiceCredentialReservationResult, ClientError>
pub async fn resolve_service_credential_reservation( &self, request: ResolveServiceCredentialReservationRequest, options: CallOptions, ) -> Result<ResolveServiceCredentialReservationResult, ClientError>
Calls the generated resolve_service_credential_reservation Lodestone API command.
Sourcepub async fn prepare_revoke_service_credential(
&self,
request: PrepareRevokeServiceCredentialRequest,
options: CallOptions,
) -> Result<PrepareRevokeServiceCredentialResult, ClientError>
pub async fn prepare_revoke_service_credential( &self, request: PrepareRevokeServiceCredentialRequest, options: CallOptions, ) -> Result<PrepareRevokeServiceCredentialResult, ClientError>
Calls the generated prepare_revoke_service_credential Lodestone API command.
Sourcepub async fn revoke_service_credential(
&self,
request: RevokeServiceCredentialRequest,
options: CallOptions,
) -> Result<RevokeServiceCredentialResult, ClientError>
pub async fn revoke_service_credential( &self, request: RevokeServiceCredentialRequest, options: CallOptions, ) -> Result<RevokeServiceCredentialResult, ClientError>
Calls the generated revoke_service_credential Lodestone API command.
Sourcepub async fn resolve_security_action(
&self,
request: ResolveSecurityActionRequest,
options: CallOptions,
) -> Result<ResolveSecurityActionResult, ClientError>
pub async fn resolve_security_action( &self, request: ResolveSecurityActionRequest, options: CallOptions, ) -> Result<ResolveSecurityActionResult, ClientError>
Calls the generated resolve_security_action Lodestone API command.
Sourcepub async fn get_security_role(
&self,
request: GetSecurityRoleRequest,
options: CallOptions,
) -> Result<GetSecurityRoleResult, ClientError>
pub async fn get_security_role( &self, request: GetSecurityRoleRequest, options: CallOptions, ) -> Result<GetSecurityRoleResult, ClientError>
Calls the generated get_security_role Lodestone API command.
Sourcepub async fn prepare_role_append_access_change(
&self,
request: PrepareRoleAppendAccessChangeRequest,
options: CallOptions,
) -> Result<PrepareRoleAppendAccessChangeResult, ClientError>
pub async fn prepare_role_append_access_change( &self, request: PrepareRoleAppendAccessChangeRequest, options: CallOptions, ) -> Result<PrepareRoleAppendAccessChangeResult, ClientError>
Calls the generated prepare_role_append_access_change Lodestone API command.
Sourcepub async fn submit_role_append_access_change(
&self,
request: SubmitRoleAppendAccessChangeRequest,
options: CallOptions,
) -> Result<SubmitRoleAppendAccessChangeResult, ClientError>
pub async fn submit_role_append_access_change( &self, request: SubmitRoleAppendAccessChangeRequest, options: CallOptions, ) -> Result<SubmitRoleAppendAccessChangeResult, ClientError>
Calls the generated submit_role_append_access_change Lodestone API command.
Sourcepub async fn list_service_credentials(
&self,
request: ListServiceCredentialsRequest,
options: CallOptions,
) -> Result<ListServiceCredentialsResult, ClientError>
pub async fn list_service_credentials( &self, request: ListServiceCredentialsRequest, options: CallOptions, ) -> Result<ListServiceCredentialsResult, ClientError>
Calls the generated list_service_credentials Lodestone API command.
Sourcepub async fn list_backups(
&self,
request: ListBackupsRequest,
options: CallOptions,
) -> Result<ListBackupsResult, ClientError>
pub async fn list_backups( &self, request: ListBackupsRequest, options: CallOptions, ) -> Result<ListBackupsResult, ClientError>
Calls the generated list_backups Lodestone API command.
Sourcepub async fn get_backup(
&self,
request: GetBackupRequest,
options: CallOptions,
) -> Result<GetBackupResult, ClientError>
pub async fn get_backup( &self, request: GetBackupRequest, options: CallOptions, ) -> Result<GetBackupResult, ClientError>
Calls the generated get_backup Lodestone API command.
Sourcepub async fn create_backup(
&self,
request: CreateBackupRequest,
options: CallOptions,
) -> Result<CreateBackupResult, ClientError>
pub async fn create_backup( &self, request: CreateBackupRequest, options: CallOptions, ) -> Result<CreateBackupResult, ClientError>
Calls the generated create_backup Lodestone API command.
Sourcepub async fn resolve_backup_action(
&self,
request: ResolveBackupActionRequest,
options: CallOptions,
) -> Result<ResolveBackupActionResult, ClientError>
pub async fn resolve_backup_action( &self, request: ResolveBackupActionRequest, options: CallOptions, ) -> Result<ResolveBackupActionResult, ClientError>
Calls the generated resolve_backup_action Lodestone API command.
Sourcepub async fn get_runtime_status(
&self,
request: GetRuntimeStatusRequest,
options: CallOptions,
) -> Result<GetRuntimeStatusResult, ClientError>
pub async fn get_runtime_status( &self, request: GetRuntimeStatusRequest, options: CallOptions, ) -> Result<GetRuntimeStatusResult, ClientError>
Calls the generated get_runtime_status Lodestone API command.
Sourcepub async fn get_result_cache_status(
&self,
request: GetResultCacheStatusRequest,
options: CallOptions,
) -> Result<GetResultCacheStatusResult, ClientError>
pub async fn get_result_cache_status( &self, request: GetResultCacheStatusRequest, options: CallOptions, ) -> Result<GetResultCacheStatusResult, ClientError>
Calls the generated get_result_cache_status Lodestone API command.
Sourcepub async fn get_field_promotion_status(
&self,
request: GetFieldPromotionStatusRequest,
options: CallOptions,
) -> Result<GetFieldPromotionStatusResult, ClientError>
pub async fn get_field_promotion_status( &self, request: GetFieldPromotionStatusRequest, options: CallOptions, ) -> Result<GetFieldPromotionStatusResult, ClientError>
Calls the generated get_field_promotion_status Lodestone API command.
Sourcepub async fn get_overload_status(
&self,
request: GetOverloadStatusRequest,
options: CallOptions,
) -> Result<GetOverloadStatusResult, ClientError>
pub async fn get_overload_status( &self, request: GetOverloadStatusRequest, options: CallOptions, ) -> Result<GetOverloadStatusResult, ClientError>
Calls the generated get_overload_status Lodestone API command.
Sourcepub async fn configure_external_key(
&self,
request: ConfigureExternalKeyRequest,
options: CallOptions,
) -> Result<ConfigureExternalKeyResult, ClientError>
pub async fn configure_external_key( &self, request: ConfigureExternalKeyRequest, options: CallOptions, ) -> Result<ConfigureExternalKeyResult, ClientError>
Calls the generated configure_external_key Lodestone API command.
Sourcepub async fn rotate_external_key_binding(
&self,
request: RotateExternalKeyBindingRequest,
options: CallOptions,
) -> Result<RotateExternalKeyBindingResult, ClientError>
pub async fn rotate_external_key_binding( &self, request: RotateExternalKeyBindingRequest, options: CallOptions, ) -> Result<RotateExternalKeyBindingResult, ClientError>
Calls the generated rotate_external_key_binding Lodestone API command.
Sourcepub async fn configure_aggregate_then_delete(
&self,
request: ConfigureAggregateThenDeleteRequest,
options: CallOptions,
) -> Result<ConfigureAggregateThenDeleteResult, ClientError>
pub async fn configure_aggregate_then_delete( &self, request: ConfigureAggregateThenDeleteRequest, options: CallOptions, ) -> Result<ConfigureAggregateThenDeleteResult, ClientError>
Calls the generated configure_aggregate_then_delete Lodestone API command.
Sourcepub async fn get_lifecycle_status(
&self,
request: GetLifecycleStatusRequest,
options: CallOptions,
) -> Result<GetLifecycleStatusResult, ClientError>
pub async fn get_lifecycle_status( &self, request: GetLifecycleStatusRequest, options: CallOptions, ) -> Result<GetLifecycleStatusResult, ClientError>
Calls the generated get_lifecycle_status Lodestone API command.
Sourcepub async fn get_quota(
&self,
request: GetQuotaRequest,
options: CallOptions,
) -> Result<GetQuotaResult, ClientError>
pub async fn get_quota( &self, request: GetQuotaRequest, options: CallOptions, ) -> Result<GetQuotaResult, ClientError>
Calls the generated get_quota Lodestone API command.
Sourcepub async fn update_quota(
&self,
request: UpdateQuotaRequest,
options: CallOptions,
) -> Result<UpdateQuotaResult, ClientError>
pub async fn update_quota( &self, request: UpdateQuotaRequest, options: CallOptions, ) -> Result<UpdateQuotaResult, ClientError>
Calls the generated update_quota Lodestone API command.
Sourcepub async fn get_binding(
&self,
request: GetBindingRequest,
options: CallOptions,
) -> Result<GetBindingResult, ClientError>
pub async fn get_binding( &self, request: GetBindingRequest, options: CallOptions, ) -> Result<GetBindingResult, ClientError>
Calls the generated get_binding Lodestone API command.
Sourcepub async fn get_admission_status(
&self,
request: GetAdmissionStatusRequest,
options: CallOptions,
) -> Result<GetAdmissionStatusResult, ClientError>
pub async fn get_admission_status( &self, request: GetAdmissionStatusRequest, options: CallOptions, ) -> Result<GetAdmissionStatusResult, ClientError>
Calls the generated get_admission_status Lodestone API command.
Sourcepub async fn set_admission(
&self,
request: SetAdmissionRequest,
options: CallOptions,
) -> Result<SetAdmissionResult, ClientError>
pub async fn set_admission( &self, request: SetAdmissionRequest, options: CallOptions, ) -> Result<SetAdmissionResult, ClientError>
Calls the generated set_admission Lodestone API command.
Sourcepub async fn get_quiesce_status(
&self,
request: GetQuiesceStatusRequest,
options: CallOptions,
) -> Result<GetQuiesceStatusResult, ClientError>
pub async fn get_quiesce_status( &self, request: GetQuiesceStatusRequest, options: CallOptions, ) -> Result<GetQuiesceStatusResult, ClientError>
Calls the generated get_quiesce_status Lodestone API command.
Sourcepub async fn get_decommission_readiness(
&self,
request: GetDecommissionReadinessRequest,
options: CallOptions,
) -> Result<GetDecommissionReadinessResult, ClientError>
pub async fn get_decommission_readiness( &self, request: GetDecommissionReadinessRequest, options: CallOptions, ) -> Result<GetDecommissionReadinessResult, ClientError>
Calls the generated get_decommission_readiness Lodestone API command.
Sourcepub async fn get_upgrade_readiness(
&self,
request: GetUpgradeReadinessRequest,
options: CallOptions,
) -> Result<GetUpgradeReadinessResult, ClientError>
pub async fn get_upgrade_readiness( &self, request: GetUpgradeReadinessRequest, options: CallOptions, ) -> Result<GetUpgradeReadinessResult, ClientError>
Calls the generated get_upgrade_readiness Lodestone API command.
Sourcepub async fn get_maintenance_status(
&self,
request: GetMaintenanceStatusRequest,
options: CallOptions,
) -> Result<GetMaintenanceStatusResult, ClientError>
pub async fn get_maintenance_status( &self, request: GetMaintenanceStatusRequest, options: CallOptions, ) -> Result<GetMaintenanceStatusResult, ClientError>
Calls the generated get_maintenance_status Lodestone API command.
Sourcepub async fn get_restore_readiness(
&self,
request: GetRestoreReadinessRequest,
options: CallOptions,
) -> Result<GetRestoreReadinessResult, ClientError>
pub async fn get_restore_readiness( &self, request: GetRestoreReadinessRequest, options: CallOptions, ) -> Result<GetRestoreReadinessResult, ClientError>
Calls the generated get_restore_readiness Lodestone API command.
Sourcepub async fn warm_vector_index(
&self,
request: WarmVectorIndexRequest,
options: CallOptions,
) -> Result<WarmVectorIndexResult, ClientError>
pub async fn warm_vector_index( &self, request: WarmVectorIndexRequest, options: CallOptions, ) -> Result<WarmVectorIndexResult, ClientError>
Calls the generated warm_vector_index Lodestone API command.
Sourcepub async fn evaluate_vector_recall(
&self,
request: EvaluateVectorRecallRequest,
options: CallOptions,
) -> Result<EvaluateVectorRecallResult, ClientError>
pub async fn evaluate_vector_recall( &self, request: EvaluateVectorRecallRequest, options: CallOptions, ) -> Result<EvaluateVectorRecallResult, ClientError>
Calls the generated evaluate_vector_recall Lodestone API command.
Sourcepub async fn calibrate_vector_strategy(
&self,
request: CalibrateVectorStrategyRequest,
options: CallOptions,
) -> Result<CalibrateVectorStrategyResult, ClientError>
pub async fn calibrate_vector_strategy( &self, request: CalibrateVectorStrategyRequest, options: CallOptions, ) -> Result<CalibrateVectorStrategyResult, ClientError>
Calls the generated calibrate_vector_strategy Lodestone API command.
Sourcepub async fn get_vector_diagnostic(
&self,
request: GetVectorDiagnosticRequest,
options: CallOptions,
) -> Result<GetVectorDiagnosticResult, ClientError>
pub async fn get_vector_diagnostic( &self, request: GetVectorDiagnosticRequest, options: CallOptions, ) -> Result<GetVectorDiagnosticResult, ClientError>
Calls the generated get_vector_diagnostic Lodestone API command.
Sourcepub async fn create_diagnostic(
&self,
request: CreateDiagnosticRequest,
options: CallOptions,
) -> Result<CreateDiagnosticResult, ClientError>
pub async fn create_diagnostic( &self, request: CreateDiagnosticRequest, options: CallOptions, ) -> Result<CreateDiagnosticResult, ClientError>
Calls the generated create_diagnostic Lodestone API command.
Sourcepub async fn get_diagnostic(
&self,
request: GetDiagnosticRequest,
options: CallOptions,
) -> Result<GetDiagnosticResult, ClientError>
pub async fn get_diagnostic( &self, request: GetDiagnosticRequest, options: CallOptions, ) -> Result<GetDiagnosticResult, ClientError>
Calls the generated get_diagnostic Lodestone API command.
Sourcepub async fn read_artifact_chunk(
&self,
request: ReadArtifactChunkRequest,
options: CallOptions,
) -> Result<ReadArtifactChunkResult, ClientError>
pub async fn read_artifact_chunk( &self, request: ReadArtifactChunkRequest, options: CallOptions, ) -> Result<ReadArtifactChunkResult, ClientError>
Calls the generated read_artifact_chunk Lodestone API command.
Sourcepub async fn export_usage(
&self,
request: ExportUsageRequest,
options: CallOptions,
) -> Result<ExportUsageResult, ClientError>
pub async fn export_usage( &self, request: ExportUsageRequest, options: CallOptions, ) -> Result<ExportUsageResult, ClientError>
Calls the generated export_usage Lodestone API command.
Sourcepub async fn execute_state_read(
&self,
request: ExecuteStateReadRequest,
options: CallOptions,
) -> Result<ExecuteStateReadResult, ClientError>
pub async fn execute_state_read( &self, request: ExecuteStateReadRequest, options: CallOptions, ) -> Result<ExecuteStateReadResult, ClientError>
Calls the generated execute_state_read Lodestone API command.
Sourcepub async fn prepare_state_write(
&self,
request: PrepareStateWriteRequest,
options: CallOptions,
) -> Result<PrepareStateWriteResult, ClientError>
pub async fn prepare_state_write( &self, request: PrepareStateWriteRequest, options: CallOptions, ) -> Result<PrepareStateWriteResult, ClientError>
Calls the generated prepare_state_write Lodestone API command.
Sourcepub async fn submit_state_write(
&self,
request: SubmitStateWriteRequest,
options: CallOptions,
) -> Result<SubmitStateWriteResult, ClientError>
pub async fn submit_state_write( &self, request: SubmitStateWriteRequest, options: CallOptions, ) -> Result<SubmitStateWriteResult, ClientError>
Calls the generated submit_state_write Lodestone API command.
Sourcepub async fn resolve_state_write(
&self,
request: ResolveStateWriteRequest,
options: CallOptions,
) -> Result<ResolveStateWriteResult, ClientError>
pub async fn resolve_state_write( &self, request: ResolveStateWriteRequest, options: CallOptions, ) -> Result<ResolveStateWriteResult, ClientError>
Calls the generated resolve_state_write Lodestone API command.
Source§impl Client
impl Client
pub fn index_pager( &self, request: ListIndexesRequest, options: CallOptions, ) -> Result<IndexPager, PagerError>
pub fn search_pager( &self, request: SearchRequest, options: CallOptions, ) -> Result<SearchPager, PagerError>
pub fn usage_pager( &self, request: ExportUsageRequest, options: CallOptions, ) -> Result<UsagePager, PagerError>
Source§impl Client
impl Client
Sourcepub async fn get(
&self,
index: &StateIndex,
key: &[u8],
options: CallOptions,
) -> Result<Option<Vec<u8>>, ClientError>
pub async fn get( &self, index: &StateIndex, key: &[u8], options: CallOptions, ) -> Result<Option<Vec<u8>>, ClientError>
Reads one exact key. Missing values return None.
Sourcepub async fn mget(
&self,
index: &StateIndex,
keys: &[Vec<u8>],
options: CallOptions,
) -> Result<Vec<Option<Vec<u8>>>, ClientError>
pub async fn mget( &self, index: &StateIndex, keys: &[Vec<u8>], options: CallOptions, ) -> Result<Vec<Option<Vec<u8>>>, ClientError>
Reads a colocated key set. Core refuses keys that do not share a slot.
Sourcepub async fn set(
&self,
index: &StateIndex,
action_id: &StateActionId,
key: &[u8],
value: &[u8],
expires_at: Option<AbsoluteExpiry>,
options: CallOptions,
) -> Result<StateWriteOutcome<bool>, ClientError>
pub async fn set( &self, index: &StateIndex, action_id: &StateActionId, key: &[u8], value: &[u8], expires_at: Option<AbsoluteExpiry>, options: CallOptions, ) -> Result<StateWriteOutcome<bool>, ClientError>
Sets one value through the stable prepare/submit/resolve workflow.
Sourcepub async fn delete(
&self,
index: &StateIndex,
action_id: &StateActionId,
keys: &[Vec<u8>],
options: CallOptions,
) -> Result<StateWriteOutcome<u32>, ClientError>
pub async fn delete( &self, index: &StateIndex, action_id: &StateActionId, keys: &[Vec<u8>], options: CallOptions, ) -> Result<StateWriteOutcome<u32>, ClientError>
Deletes one or more keys and returns the authoritative number removed.
Source§impl Client
impl Client
pub async fn subscribe( &self, start: SubscriptionStart, options: CallOptions, ) -> Result<Subscription, SubscriptionError>
Source§impl Client
impl Client
Sourcepub async fn connect(
transport: CellTransport,
config: CollectionSessionConfig,
options: CallOptions,
) -> Result<Self, ClientError>
pub async fn connect( transport: CellTransport, config: CollectionSessionConfig, options: CallOptions, ) -> Result<Self, ClientError>
Connects, authenticates, discovers capabilities, and verifies the exact cluster, collection, schema, stream, and binding identities in the profile.
pub fn new( transport: CellTransport, config: CollectionSessionConfig, ) -> Result<Self, ClientError>
pub fn connection_profile(&self) -> &ValidatedConnectionProfile
Sourcepub fn cell_transport(&self) -> CellTransport
pub fn cell_transport(&self) -> CellTransport
Returns a handle to the exact shared cell transport for creating additional isolated Collection sessions.
pub fn profile_verification(&self) -> Option<ProfileVerification>
pub async fn verify_connection_profile( &self, options: CallOptions, ) -> Result<ProfileVerification, ClientError>
Sourcepub fn validate_discovery_observation(
&self,
discovered: &DiscoverResult,
) -> Result<(), ClientError>
pub fn validate_discovery_observation( &self, discovered: &DiscoverResult, ) -> Result<(), ClientError>
Validates one authenticated discovery observation against the selected profile without performing another network call.
Validates and installs one authenticated discovery/binding cut without performing another network call.
Sourcepub async fn call(
&self,
request: RequestBody,
options: CallOptions,
) -> Result<ResultBody, ClientError>
pub async fn call( &self, request: RequestBody, options: CallOptions, ) -> Result<ResultBody, ClientError>
Dispatches one closed Lodestone API request body through the same validated transport and recovery boundary used by every generated typed method.
The caller supplies no envelope, collection, credential, or arbitrary header. Those remain owned by the validated connection profile, credential provider, and call options.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Client
impl !UnwindSafe for Client
impl Freeze for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl UnsafeUnpin for Client
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request