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 !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