pub struct Client {
pub raw: RawClient,
pub limiter: Limiter,
}Fields§
§raw: RawClient§limiter: LimiterImplementations§
Source§impl Client
impl Client
pub const BASE_URL: &'static str = RawClient::BASE_URL
pub fn new(baseurl: &str) -> Self
pub fn new_with_client(baseurl: &str, client: Client) -> Self
pub fn new_with_key(api_key: &str) -> Result<Self>
pub async fn list_categories<'a>( &'a self, ) -> Result<ResponseValue<DocCategoryList>, Error<ListCategoriesResponse>>
pub async fn list_docs<'a>( &'a self, folder_id: Option<&'a str>, in_gallery: Option<bool>, is_owner: Option<bool>, is_published: Option<bool>, is_starred: Option<bool>, limit: Option<NonZeroU64>, page_token: Option<&'a str>, query: Option<&'a str>, source_doc: Option<&'a str>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<DocList>, Error<ListDocsResponse>>
pub async fn create_doc<'a>( &'a self, body: &'a DocCreate, ) -> Result<ResponseValue<DocumentCreationResult>, Error<CreateDocResponse>>
pub async fn get_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<Doc>, Error<GetDocResponse>>
pub async fn delete_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<DocDelete>, Error<DeleteDocResponse>>
pub async fn update_doc<'a>( &'a self, doc_id: &'a str, body: &'a DocUpdate, ) -> Result<ResponseValue<DocUpdateResult>, Error<UpdateDocResponse>>
pub async fn get_sharing_metadata<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<AclMetadata>, Error<GetSharingMetadataResponse>>
pub async fn get_permissions<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<Acl>, Error<GetPermissionsResponse>>
pub async fn add_permission<'a>( &'a self, doc_id: &'a str, body: &'a AddPermissionRequest, ) -> Result<ResponseValue<AddPermissionResult>, Error<AddPermissionResponse>>
pub async fn delete_permission<'a>( &'a self, doc_id: &'a str, permission_id: &'a str, ) -> Result<ResponseValue<DeletePermissionResult>, Error<DeletePermissionResponse>>
pub async fn search_principals<'a>( &'a self, doc_id: &'a str, query: Option<&'a str>, ) -> Result<ResponseValue<SearchPrincipalsResponse>, Error<SearchPrincipalsResponse>>
pub async fn get_acl_settings<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<AclSettings>, Error<GetAclSettingsResponse>>
pub async fn update_acl_settings<'a>( &'a self, doc_id: &'a str, body: &'a UpdateAclSettingsRequest, ) -> Result<ResponseValue<AclSettings>, Error<UpdateAclSettingsResponse>>
pub async fn publish_doc<'a>( &'a self, doc_id: &'a str, body: &'a DocPublish, ) -> Result<ResponseValue<PublishResult>, Error<PublishDocResponse>>
pub async fn unpublish_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<UnpublishResult>, Error<UnpublishDocResponse>>
pub async fn list_pages<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PageList>, Error<ListPagesResponse>>
pub async fn create_page<'a>( &'a self, doc_id: &'a str, body: &'a PageCreate, ) -> Result<ResponseValue<PageCreateResult>, Error<CreatePageResponse>>
pub async fn get_page<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, ) -> Result<ResponseValue<Page>, Error<GetPageResponse>>
pub async fn update_page<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, body: &'a PageUpdate, ) -> Result<ResponseValue<PageUpdateResult>, Error<UpdatePageResponse>>
pub async fn delete_page<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, ) -> Result<ResponseValue<PageDeleteResult>, Error<DeletePageResponse>>
pub async fn begin_page_content_export<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, body: &'a BeginPageContentExportRequest, ) -> Result<ResponseValue<BeginPageContentExportResponse>, Error<BeginPageContentExportResponse>>
pub async fn get_page_content_export_status<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, request_id: &'a str, ) -> Result<ResponseValue<PageContentExportStatusResponse>, Error<GetPageContentExportStatusResponse>>
pub async fn list_tables<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, sort_by: Option<SortBy>, table_types: Option<&'a Vec<TableTypeEnum>>, ) -> Result<ResponseValue<TableList>, Error<ListTablesResponse>>
pub async fn get_table<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, use_updated_table_layouts: Option<bool>, ) -> Result<ResponseValue<Table>, Error<GetTableResponse>>
pub async fn list_columns<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, visible_only: Option<bool>, ) -> Result<ResponseValue<ColumnList>, Error<ListColumnsResponse>>
pub async fn list_rows<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, query: Option<&'a str>, sort_by: Option<RowsSortBy>, sync_token: Option<&'a str>, use_column_names: Option<bool>, value_format: Option<ValueFormat>, visible_only: Option<bool>, ) -> Result<ResponseValue<RowList>, Error<ListRowsResponse>>
pub async fn upsert_rows<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, disable_parsing: Option<bool>, body: &'a RowsUpsert, ) -> Result<ResponseValue<RowsUpsertResult>, Error<UpsertRowsResponse>>
👎Deprecated:
use upsert_rows_correct
pub async fn delete_rows<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, body: &'a RowsDelete, ) -> Result<ResponseValue<RowsDeleteResult>, Error<DeleteRowsResponse>>
pub async fn get_row<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, use_column_names: Option<bool>, value_format: Option<ValueFormat>, ) -> Result<ResponseValue<RowDetail>, Error<GetRowResponse>>
👎Deprecated:
use get_row_correct
pub async fn get_row_correct<'a, T: DeserializeOwned + ValueFormatProvider>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, use_column_names: Option<bool>, ) -> Result<ResponseValue<T>, Error<GetRowResponse>>
pub async fn update_row<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, disable_parsing: Option<bool>, body: &'a RowUpdate, ) -> Result<ResponseValue<RowUpdateResult>, Error<UpdateRowResponse>>
pub async fn delete_row<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, ) -> Result<ResponseValue<RowDeleteResult>, Error<DeleteRowResponse>>
pub async fn get_column<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, column_id_or_name: &'a str, ) -> Result<ResponseValue<ColumnDetail>, Error<GetColumnResponse>>
pub async fn list_formulas<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, sort_by: Option<SortBy>, ) -> Result<ResponseValue<FormulaList>, Error<ListFormulasResponse>>
pub async fn get_formula<'a>( &'a self, doc_id: &'a str, formula_id_or_name: &'a str, ) -> Result<ResponseValue<Formula>, Error<GetFormulaResponse>>
pub async fn list_controls<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, sort_by: Option<SortBy>, ) -> Result<ResponseValue<ControlList>, Error<ListControlsResponse>>
pub async fn get_control<'a>( &'a self, doc_id: &'a str, control_id_or_name: &'a str, ) -> Result<ResponseValue<Control>, Error<GetControlResponse>>
pub async fn list_custom_doc_domains<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<CustomDocDomainList>, Error<ListCustomDocDomainsResponse>>
pub async fn add_custom_doc_domain<'a>( &'a self, doc_id: &'a str, body: &'a AddCustomDocDomainRequest, ) -> Result<ResponseValue<AddCustomDocDomainResponse>, Error<AddCustomDocDomainResponse>>
pub async fn delete_custom_doc_domain<'a>( &'a self, doc_id: &'a str, custom_doc_domain: &'a str, ) -> Result<ResponseValue<DeleteCustomDocDomainResponse>, Error<DeleteCustomDocDomainResponse>>
pub async fn update_custom_doc_domain<'a>( &'a self, doc_id: &'a str, custom_doc_domain: &'a str, body: &'a UpdateCustomDocDomainRequest, ) -> Result<ResponseValue<UpdateCustomDocDomainResponse>, Error<UpdateCustomDocDomainResponse>>
pub async fn get_custom_doc_domain_provider<'a>( &'a self, custom_doc_domain: &'a str, ) -> Result<ResponseValue<CustomDocDomainProviderResponse>, Error<GetCustomDocDomainProviderResponse>>
pub async fn get_folder<'a>( &'a self, folder_id: &'a str, ) -> Result<ResponseValue<Folder>, Error<GetFolderResponse>>
pub async fn whoami<'a>( &'a self, ) -> Result<ResponseValue<User>, Error<WhoamiResponse>>
pub async fn resolve_browser_link<'a>( &'a self, degrade_gracefully: Option<bool>, url: &'a str, ) -> Result<ResponseValue<ApiLink>, Error<ResolveBrowserLinkResponse>>
pub async fn get_mutation_status<'a>( &'a self, request_id: &'a str, ) -> Result<ResponseValue<MutationStatus>, Error<GetMutationStatusResponse>>
pub async fn trigger_webhook_automation<'a>( &'a self, doc_id: &'a str, rule_id: &'a str, body: &'a WebhookTriggerPayload, ) -> Result<ResponseValue<WebhookTriggerResult>, Error<TriggerWebhookAutomationResponse>>
pub async fn list_doc_analytics<'a>( &'a self, direction: Option<SortDirection>, doc_ids: Option<&'a Vec<String>>, is_published: Option<bool>, limit: Option<NonZeroU64>, order_by: Option<DocAnalyticsOrderBy>, page_token: Option<&'a str>, query: Option<&'a str>, scale: Option<AnalyticsScale>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<DocAnalyticsCollection>, Error<ListDocAnalyticsResponse>>
pub async fn list_page_analytics<'a>( &'a self, doc_id: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, ) -> Result<ResponseValue<PageAnalyticsCollection>, Error<ListPageAnalyticsResponse>>
pub async fn list_doc_analytics_summary<'a>( &'a self, is_published: Option<bool>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<DocAnalyticsSummary>, Error<ListDocAnalyticsSummaryResponse>>
pub async fn list_pack_analytics<'a>( &'a self, direction: Option<SortDirection>, is_published: Option<bool>, limit: Option<NonZeroU64>, order_by: Option<PackAnalyticsOrderBy>, pack_ids: Option<&'a Vec<i64>>, page_token: Option<&'a str>, query: Option<&'a str>, scale: Option<AnalyticsScale>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<PackAnalyticsCollection>, Error<ListPackAnalyticsResponse>>
pub async fn list_pack_analytics_summary<'a>( &'a self, is_published: Option<bool>, pack_ids: Option<&'a Vec<i64>>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<PackAnalyticsSummary>, Error<ListPackAnalyticsSummaryResponse>>
pub async fn list_pack_formula_analytics<'a>( &'a self, pack_id: NonZeroU64, direction: Option<SortDirection>, limit: Option<NonZeroU64>, order_by: Option<PackFormulaAnalyticsOrderBy>, pack_formula_names: Option<&'a Vec<String>>, pack_formula_types: Option<&'a Vec<PackFormulaType>>, page_token: Option<&'a str>, scale: Option<AnalyticsScale>, since_date: Option<&'a NaiveDate>, until_date: Option<&'a NaiveDate>, ) -> Result<ResponseValue<PackFormulaAnalyticsCollection>, Error<ListPackFormulaAnalyticsResponse>>
pub async fn get_analytics_last_updated<'a>( &'a self, ) -> Result<ResponseValue<AnalyticsLastUpdatedResponse>, Error<GetAnalyticsLastUpdatedResponse>>
pub async fn list_workspace_members<'a>( &'a self, workspace_id: &'a str, included_roles: Option<&'a Vec<WorkspaceUserRole>>, page_token: Option<&'a str>, ) -> Result<ResponseValue<WorkspaceMembersList>, Error<ListWorkspaceMembersResponse>>
pub async fn change_user_role<'a>( &'a self, workspace_id: &'a str, body: &'a ChangeRole, ) -> Result<ResponseValue<ChangeRoleResult>, Error<ChangeUserRoleResponse>>
pub async fn list_workspace_role_activity<'a>( &'a self, workspace_id: &'a str, ) -> Result<ResponseValue<GetWorkspaceRoleActivity>, Error<ListWorkspaceRoleActivityResponse>>
pub async fn list_packs<'a>( &'a self, access_type: Option<PackAccessType>, access_types: Option<&'a Vec<PackAccessType>>, direction: Option<SortDirection>, exclude_individual_acls: Option<bool>, exclude_public_packs: Option<bool>, exclude_workspace_acls: Option<bool>, limit: Option<NonZeroU64>, only_workspace_id: Option<&'a str>, pack_entrypoint: Option<PackEntrypoint>, page_token: Option<&'a str>, parent_workspace_ids: Option<&'a Vec<String>>, sort_by: Option<PacksSortBy>, ) -> Result<ResponseValue<PackSummaryList>, Error<ListPacksResponse>>
pub async fn create_pack<'a>( &'a self, body: &'a CreatePackRequest, ) -> Result<ResponseValue<CreatePackResponse>, Error<CreatePackResponse>>
pub async fn get_pack<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<Pack>, Error<GetPackResponse>>
pub async fn delete_pack<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<DeletePackResponse>, Error<DeletePackResponse>>
pub async fn update_pack<'a>( &'a self, pack_id: NonZeroU64, body: &'a UpdatePackRequest, ) -> Result<ResponseValue<Pack>, Error<UpdatePackResponse>>
pub async fn get_pack_configuration_schema<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<GetPackConfigurationJsonSchemaResponse>, Error<GetPackConfigurationSchemaResponse>>
pub async fn list_pack_versions<'a>( &'a self, pack_id: NonZeroU64, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PackVersionList>, Error<ListPackVersionsResponse>>
pub async fn get_next_pack_version<'a>( &'a self, pack_id: NonZeroU64, body: &'a GetNextPackVersionRequest, ) -> Result<ResponseValue<NextPackVersionInfo>, Error<GetNextPackVersionResponse>>
pub async fn get_pack_version_diffs<'a>( &'a self, pack_id: NonZeroU64, base_pack_version: &'a str, target_pack_version: &'a str, ) -> Result<ResponseValue<PackVersionDiffs>, Error<GetPackVersionDiffsResponse>>
pub async fn register_pack_version<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, body: &'a RegisterPackVersionRequest, ) -> Result<ResponseValue<PackVersionUploadInfo>, Error<RegisterPackVersionResponse>>
pub async fn pack_version_upload_complete<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, body: &'a CreatePackVersionRequest, ) -> Result<ResponseValue<CreatePackVersionResponse>, Error<PackVersionUploadCompleteResponse>>
pub async fn list_pack_releases<'a>( &'a self, pack_id: NonZeroU64, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PackReleaseList>, Error<ListPackReleasesResponse>>
pub async fn create_pack_release<'a>( &'a self, pack_id: NonZeroU64, body: &'a CreatePackReleaseRequest, ) -> Result<ResponseValue<PackRelease>, Error<CreatePackReleaseResponse>>
pub async fn update_pack_release<'a>( &'a self, pack_id: NonZeroU64, pack_release_id: NonZeroU64, body: &'a UpdatePackReleaseRequest, ) -> Result<ResponseValue<PackRelease>, Error<UpdatePackReleaseResponse>>
pub async fn get_pack_oauth_config<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackOauthConfigMetadata>, Error<GetPackOauthConfigResponse>>
pub async fn set_pack_oauth_config<'a>( &'a self, pack_id: NonZeroU64, body: &'a SetPackOauthConfigRequest, ) -> Result<ResponseValue<PackOauthConfigMetadata>, Error<SetPackOauthConfigResponse>>
pub async fn get_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<GetPackSystemConnectionResponse>>
pub async fn set_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, body: &'a SetPackSystemConnectionRequest, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<SetPackSystemConnectionResponse>>
pub async fn patch_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, body: &'a PatchPackSystemConnectionRequest, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<PatchPackSystemConnectionResponse>>
pub async fn get_pack_permissions<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackPermissionList>, Error<GetPackPermissionsResponse>>
pub async fn add_pack_permission<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackPermissionRequest, ) -> Result<ResponseValue<AddPackPermissionResponse>, Error<AddPackPermissionResponse>>
pub async fn delete_pack_permission<'a>( &'a self, pack_id: NonZeroU64, permission_id: &'a str, ) -> Result<ResponseValue<DeletePackPermissionResponse>, Error<DeletePackPermissionResponse>>
pub async fn list_user_pack_invitations<'a>( &'a self, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PackInvitationWithPackList>, Error<ListUserPackInvitationsResponse>>
pub async fn list_pack_invitations<'a>( &'a self, pack_id: NonZeroU64, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PackInvitationList>, Error<ListPackInvitationsResponse>>
pub async fn create_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, body: &'a CreatePackInvitationRequest, ) -> Result<ResponseValue<CreatePackInvitationResponse>, Error<CreatePackInvitationResponse>>
pub async fn update_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, invitation_id: &'a Uuid, body: &'a UpdatePackInvitationRequest, ) -> Result<ResponseValue<UpdatePackInvitationResponse>, Error<UpdatePackInvitationResponse>>
pub async fn delete_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, invitation_id: &'a Uuid, ) -> Result<ResponseValue<DeletePackInvitationResponse>, Error<DeletePackInvitationResponse>>
pub async fn reply_to_pack_invitation<'a>( &'a self, invitation_id: &'a Uuid, body: &'a HandlePackInvitationRequest, ) -> Result<ResponseValue<HandlePackInvitationResponse>, Error<ReplyToPackInvitationResponse>>
pub async fn list_pack_makers<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<ListPackMakersResponse>, Error<ListPackMakersResponse>>
pub async fn add_pack_maker<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackMakerRequest, ) -> Result<ResponseValue<AddPackMakerResponse>, Error<AddPackMakerResponse>>
pub async fn delete_pack_maker<'a>( &'a self, pack_id: NonZeroU64, login_id: &'a str, ) -> Result<ResponseValue<DeletePackMakerResponse>, Error<DeletePackMakerResponse>>
pub async fn list_pack_categories<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<ListPackCategoriesResponse>, Error<ListPackCategoriesResponse>>
pub async fn add_pack_category<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackCategoryRequest, ) -> Result<ResponseValue<AddPackCategoryResponse>, Error<AddPackCategoryResponse>>
pub async fn delete_pack_category<'a>( &'a self, pack_id: NonZeroU64, category_name: &'a str, ) -> Result<ResponseValue<DeletePackCategoryResponse>, Error<DeletePackCategoryResponse>>
pub async fn upload_pack_asset<'a>( &'a self, pack_id: NonZeroU64, body: &'a UploadPackAssetRequest, ) -> Result<ResponseValue<PackAssetUploadInfo>, Error<UploadPackAssetResponse>>
pub async fn upload_pack_source_code<'a>( &'a self, pack_id: NonZeroU64, body: &'a UploadPackSourceCodeRequest, ) -> Result<ResponseValue<PackSourceCodeUploadInfo>, Error<UploadPackSourceCodeResponse>>
pub async fn pack_asset_upload_complete<'a>( &'a self, pack_id: NonZeroU64, pack_asset_id: &'a str, pack_asset_type: PackAssetType, ) -> Result<ResponseValue<PackAssetUploadCompleteResponse>, Error<PackAssetUploadCompleteResponse>>
pub async fn pack_source_code_upload_complete<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, body: &'a PackSourceCodeUploadCompleteRequest, ) -> Result<ResponseValue<PackSourceCodeUploadCompleteResponse>, Error<PackSourceCodeUploadCompleteResponse>>
pub async fn get_pack_source_code<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, ) -> Result<ResponseValue<PackSourceCodeInfo>, Error<GetPackSourceCodeResponse>>
pub async fn list_pack_listings<'a>( &'a self, certified_agents_only: Option<bool>, direction: Option<SortDirection>, exclude_individual_acls: Option<bool>, exclude_public_packs: Option<bool>, exclude_workspace_acls: Option<bool>, install_context: Option<PackListingInstallContextType>, limit: Option<NonZeroU64>, only_workspace_id: Option<&'a str>, order_by: Option<PackListingsSortBy>, pack_access_types: Option<&'a PackAccessTypes>, pack_entrypoint: Option<PackEntrypoint>, pack_ids: Option<&'a Vec<i64>>, page_token: Option<&'a str>, parent_workspace_ids: Option<&'a Vec<String>>, sort_by: Option<PackListingsSortBy>, ) -> Result<ResponseValue<PackListingList>, Error<ListPackListingsResponse>>
pub async fn get_pack_listing<'a>( &'a self, pack_id: NonZeroU64, doc_id: Option<&'a str>, ingestion_id: Option<&'a str>, install_context: Option<PackListingInstallContextType>, release_channel: Option<IngestionPackReleaseChannel>, workspace_id: Option<&'a str>, ) -> Result<ResponseValue<PackListingDetail>, Error<GetPackListingResponse>>
pub async fn list_pack_logs<'a>( &'a self, pack_id: NonZeroU64, doc_id: &'a str, after_timestamp: Option<&'a DateTime<Utc>>, before_timestamp: Option<&'a DateTime<Utc>>, limit: Option<NonZeroU64>, log_types: Option<&'a Vec<PackLogType>>, order: Option<ListPackLogsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, request_ids: Option<&'a Vec<String>>, ) -> Result<ResponseValue<PackLogsList>, Error<ListPackLogsResponse>>
pub async fn list_ingestion_logs<'a>( &'a self, pack_id: NonZeroU64, tenant_id: &'a str, root_ingestion_id: &'a Uuid, after_timestamp: Option<&'a DateTime<Utc>>, before_timestamp: Option<&'a DateTime<Utc>>, ingestion_execution_id: Option<&'a Uuid>, ingestion_status: Option<IngestionStatus>, limit: Option<NonZeroU64>, log_types: Option<&'a Vec<PackLogType>>, only_execution_completions: Option<bool>, order: Option<ListIngestionLogsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, request_ids: Option<&'a Vec<String>>, ) -> Result<ResponseValue<PackLogsList>, Error<ListIngestionLogsResponse>>
pub async fn list_grouped_pack_logs<'a>( &'a self, pack_id: NonZeroU64, doc_id: &'a str, after_timestamp: Option<&'a DateTime<Utc>>, before_timestamp: Option<&'a DateTime<Utc>>, limit: Option<NonZeroU64>, order: Option<ListGroupedPackLogsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, ) -> Result<ResponseValue<GroupedPackLogsList>, Error<ListGroupedPackLogsResponse>>
pub async fn list_grouped_ingestion_logs<'a>( &'a self, pack_id: NonZeroU64, tenant_id: &'a str, root_ingestion_id: &'a Uuid, after_timestamp: Option<&'a DateTime<Utc>>, before_timestamp: Option<&'a DateTime<Utc>>, ingestion_execution_id: Option<&'a Uuid>, limit: Option<NonZeroU64>, order: Option<ListGroupedIngestionLogsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, ) -> Result<ResponseValue<GroupedPackLogsList>, Error<ListGroupedIngestionLogsResponse>>
pub async fn list_ingestion_batch_executions<'a>( &'a self, pack_id: NonZeroU64, tenant_id: &'a str, root_ingestion_id: &'a Uuid, datasource: Option<&'a str>, execution_type: Option<IngestionExecutionType>, include_deleted_ingestions: Option<bool>, ingestion_execution_id: Option<&'a str>, ingestion_id: Option<&'a str>, ingestion_status: Option<IngestionStatus>, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<IngestionBatchExecutionsList>, Error<ListIngestionBatchExecutionsResponse>>
pub async fn list_ingestion_parent_items<'a>( &'a self, pack_id: NonZeroU64, tenant_id: &'a str, root_ingestion_id: &'a Uuid, ingestion_execution_id: &'a Uuid, ingestion_id: &'a Uuid, ingestion_status: Option<IngestionStatus>, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<IngestionParentItemsList>, Error<ListIngestionParentItemsResponse>>
pub async fn get_pack_log_details<'a>( &'a self, pack_id: NonZeroU64, tenant_id: &'a str, root_ingestion_id: &'a Uuid, log_id: &'a str, details_key: &'a str, ) -> Result<ResponseValue<PackLogDetails>, Error<GetPackLogDetailsResponse>>
pub async fn list_pack_featured_docs<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackFeaturedDocsResponse>, Error<ListPackFeaturedDocsResponse>>
pub async fn update_pack_featured_docs<'a>( &'a self, pack_id: NonZeroU64, body: &'a UpdatePackFeaturedDocsRequest, ) -> Result<ResponseValue<UpdatePackFeaturedDocsResponse>, Error<UpdatePackFeaturedDocsResponse>>
pub async fn add_go_link<'a>( &'a self, organization_id: &'a str, body: &'a AddGoLinkRequest, ) -> Result<ResponseValue<AddGoLinkResult>, Error<AddGoLinkResponse>>
pub async fn list_agent_session_ids<'a>( &'a self, tenant_id: &'a str, agent_instance_id: &'a Uuid, after_timestamp: Option<&'a DateTime<Utc>>, agent_session_id: Option<&'a Uuid>, before_timestamp: Option<&'a DateTime<Utc>>, limit: Option<NonZeroU64>, log_types: Option<&'a Vec<PackLogType>>, order: Option<ListAgentSessionIdsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, request_ids: Option<&'a Vec<String>>, ) -> Result<ResponseValue<PackLogsList>, Error<ListAgentSessionIdsResponse>>
pub async fn list_agent_logs<'a>( &'a self, tenant_id: &'a str, agent_instance_id: &'a Uuid, after_timestamp: Option<&'a DateTime<Utc>>, agent_session_id: Option<&'a Uuid>, before_timestamp: Option<&'a DateTime<Utc>>, limit: Option<NonZeroU64>, log_types: Option<&'a Vec<PackLogType>>, order: Option<ListAgentLogsOrder>, page_token: Option<&'a str>, q: Option<&'a str>, request_ids: Option<&'a Vec<String>>, ) -> Result<ResponseValue<PackLogsList>, Error<ListAgentLogsResponse>>
pub async fn get_agent_pack_log_details<'a>( &'a self, tenant_id: &'a str, agent_instance_id: &'a Uuid, log_id: &'a str, details_key: &'a str, ) -> Result<ResponseValue<PackLogDetails>, Error<GetAgentPackLogDetailsResponse>>
pub async fn table_refs( &self, doc_id: &str, ) -> Result<Vec<TableReference>, Error<ListTablesResponse>>
pub async fn tables( &self, doc_id: &str, ) -> Result<Vec<Table>, ClientTablesError>
pub async fn columns_map( &self, doc_id: &str, table_ids: impl IntoIterator<Item = TableId>, ) -> Result<HashMap<TableId, Vec<Column>>, Error<ListColumnsResponse>>
pub async fn rows( &self, doc_id: &str, table_id: &str, query: Option<&str>, sort_by: Option<RowsSortBy>, sync_token: Option<&str>, use_column_names: Option<bool>, value_format: Option<ValueFormat>, ) -> Result<Vec<Row>, Error<ListRowsResponse>>
pub async fn list_rows_correct<'a, T: DeserializeOwned + ValueFormatProvider>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, limit: Option<NonZeroU64>, page_token: Option<&'a str>, query: Option<&'a str>, sort_by: Option<RowsSortBy>, sync_token: Option<&'a str>, use_column_names: Option<bool>, visible_only: Option<bool>, ) -> Result<ResponseValue<ItemsList<T>>, Error<ListRowsResponse>>
pub async fn rows_correct<T: DeserializeOwned + ValueFormatProvider + Clone>( &self, doc_id: &str, table_id: &str, query: Option<&str>, sort_by: Option<RowsSortBy>, sync_token: Option<&str>, use_column_names: Option<bool>, visible_only: Option<bool>, ) -> Result<Vec<T>, Error<ListRowsResponse>>
pub async fn rows_map( &self, doc_id: &str, table_ids: impl IntoIterator<Item = TableId>, query: Option<&str>, sort_by: Option<RowsSortBy>, sync_token: Option<&str>, use_column_names: Option<bool>, value_format: Option<ValueFormat>, ) -> Result<HashMap<TableId, Vec<Row>>, Error<ListRowsResponse>>
pub async fn upsert_rows_correct<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, disable_parsing: Option<bool>, body: &'a RowsUpsert, ) -> Result<ResponseValue<RowsUpsertResultCorrect>, Error<UpsertRowsResponse>>
pub async fn upsert_rows_conclusively<'a, T: DeserializeOwned + ValueFormatProvider>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, disable_parsing: Option<bool>, body: &'a RowsUpsert, max_attempts: usize, delay_secs: u64, ) -> Result<UpsertRowsConclusivelyResult<T>, UpsertRowsConclusivelyError>
Sourcepub async fn wait_for_upserted_rows<T: DeserializeOwned + ValueFormatProvider>(
&self,
doc_id: &str,
table_id: &str,
row_ids: &[String],
max_attempts: usize,
delay_secs: u64,
) -> Result<Vec<T>, WaitForRowsError>
pub async fn wait_for_upserted_rows<T: DeserializeOwned + ValueFormatProvider>( &self, doc_id: &str, table_id: &str, row_ids: &[String], max_attempts: usize, delay_secs: u64, ) -> Result<Vec<T>, WaitForRowsError>
NOTE: This function works only for inserted rows, not for updated rows (it will always return after the first request for them)
pub async fn update_row_correct<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, disable_parsing: Option<bool>, body: &'a RowUpdate, ) -> Result<ResponseValue<RowUpdateResultCorrect>, Error<UpdateRowResponse>>
Auto Trait Implementations§
impl !Freeze for Client
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl UnsafeUnpin for Client
impl !UnwindSafe 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
Mutably borrows from an owned value. Read more