Client

Struct Client 

Source
pub struct Client {
    pub raw: RawClient,
    pub limiter: Limiter,
}

Fields§

§raw: RawClient§limiter: Limiter

Implementations§

Source§

impl Client

Source

pub const BASE_URL: &'static str = RawClient::BASE_URL

Source

pub fn new(baseurl: &str) -> Self

Source

pub fn new_with_client(baseurl: &str, client: Client) -> Self

Source

pub fn new_with_key(api_key: &str) -> Result<Self>

Source

pub async fn list_categories<'a>( &'a self, ) -> Result<ResponseValue<DocCategoryList>, Error<ListCategoriesResponse>>

Source

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

Source

pub async fn create_doc<'a>( &'a self, body: &'a DocCreate, ) -> Result<ResponseValue<DocumentCreationResult>, Error<CreateDocResponse>>

Source

pub async fn get_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<Doc>, Error<GetDocResponse>>

Source

pub async fn delete_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<DocDelete>, Error<DeleteDocResponse>>

Source

pub async fn update_doc<'a>( &'a self, doc_id: &'a str, body: &'a DocUpdate, ) -> Result<ResponseValue<DocUpdateResult>, Error<UpdateDocResponse>>

Source

pub async fn get_sharing_metadata<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<AclMetadata>, Error<GetSharingMetadataResponse>>

Source

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

Source

pub async fn add_permission<'a>( &'a self, doc_id: &'a str, body: &'a AddPermissionRequest, ) -> Result<ResponseValue<AddPermissionResult>, Error<AddPermissionResponse>>

Source

pub async fn delete_permission<'a>( &'a self, doc_id: &'a str, permission_id: &'a str, ) -> Result<ResponseValue<DeletePermissionResult>, Error<DeletePermissionResponse>>

Source

pub async fn search_principals<'a>( &'a self, doc_id: &'a str, query: Option<&'a str>, ) -> Result<ResponseValue<SearchPrincipalsResponse>, Error<SearchPrincipalsResponse>>

Source

pub async fn get_acl_settings<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<AclSettings>, Error<GetAclSettingsResponse>>

Source

pub async fn update_acl_settings<'a>( &'a self, doc_id: &'a str, body: &'a UpdateAclSettingsRequest, ) -> Result<ResponseValue<AclSettings>, Error<UpdateAclSettingsResponse>>

Source

pub async fn publish_doc<'a>( &'a self, doc_id: &'a str, body: &'a DocPublish, ) -> Result<ResponseValue<PublishResult>, Error<PublishDocResponse>>

Source

pub async fn unpublish_doc<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<UnpublishResult>, Error<UnpublishDocResponse>>

Source

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

Source

pub async fn create_page<'a>( &'a self, doc_id: &'a str, body: &'a PageCreate, ) -> Result<ResponseValue<PageCreateResult>, Error<CreatePageResponse>>

Source

pub async fn get_page<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, ) -> Result<ResponseValue<Page>, Error<GetPageResponse>>

Source

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

Source

pub async fn delete_page<'a>( &'a self, doc_id: &'a str, page_id_or_name: &'a str, ) -> Result<ResponseValue<PageDeleteResult>, Error<DeletePageResponse>>

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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
Source

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

Source

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
Source

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

Source

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

Source

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

Source

pub async fn push_button<'a>( &'a self, doc_id: &'a str, table_id_or_name: &'a str, row_id_or_name: &'a str, column_id_or_name: &'a str, ) -> Result<ResponseValue<PushButtonResult>, Error<PushButtonResponse>>

Source

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

Source

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

Source

pub async fn get_formula<'a>( &'a self, doc_id: &'a str, formula_id_or_name: &'a str, ) -> Result<ResponseValue<Formula>, Error<GetFormulaResponse>>

Source

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

Source

pub async fn get_control<'a>( &'a self, doc_id: &'a str, control_id_or_name: &'a str, ) -> Result<ResponseValue<Control>, Error<GetControlResponse>>

Source

pub async fn list_custom_doc_domains<'a>( &'a self, doc_id: &'a str, ) -> Result<ResponseValue<CustomDocDomainList>, Error<ListCustomDocDomainsResponse>>

Source

pub async fn add_custom_doc_domain<'a>( &'a self, doc_id: &'a str, body: &'a AddCustomDocDomainRequest, ) -> Result<ResponseValue<AddCustomDocDomainResponse>, Error<AddCustomDocDomainResponse>>

Source

pub async fn delete_custom_doc_domain<'a>( &'a self, doc_id: &'a str, custom_doc_domain: &'a str, ) -> Result<ResponseValue<DeleteCustomDocDomainResponse>, Error<DeleteCustomDocDomainResponse>>

Source

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

Source

pub async fn get_custom_doc_domain_provider<'a>( &'a self, custom_doc_domain: &'a str, ) -> Result<ResponseValue<CustomDocDomainProviderResponse>, Error<GetCustomDocDomainProviderResponse>>

Source

pub async fn get_folder<'a>( &'a self, folder_id: &'a str, ) -> Result<ResponseValue<Folder>, Error<GetFolderResponse>>

Source

pub async fn whoami<'a>( &'a self, ) -> Result<ResponseValue<User>, Error<WhoamiResponse>>

Source

pub async fn get_mutation_status<'a>( &'a self, request_id: &'a str, ) -> Result<ResponseValue<MutationStatus>, Error<GetMutationStatusResponse>>

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

pub async fn get_analytics_last_updated<'a>( &'a self, ) -> Result<ResponseValue<AnalyticsLastUpdatedResponse>, Error<GetAnalyticsLastUpdatedResponse>>

Source

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

Source

pub async fn change_user_role<'a>( &'a self, workspace_id: &'a str, body: &'a ChangeRole, ) -> Result<ResponseValue<ChangeRoleResult>, Error<ChangeUserRoleResponse>>

Source

pub async fn list_workspace_role_activity<'a>( &'a self, workspace_id: &'a str, ) -> Result<ResponseValue<GetWorkspaceRoleActivity>, Error<ListWorkspaceRoleActivityResponse>>

Source

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

Source

pub async fn create_pack<'a>( &'a self, body: &'a CreatePackRequest, ) -> Result<ResponseValue<CreatePackResponse>, Error<CreatePackResponse>>

Source

pub async fn get_pack<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<Pack>, Error<GetPackResponse>>

Source

pub async fn delete_pack<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<DeletePackResponse>, Error<DeletePackResponse>>

Source

pub async fn update_pack<'a>( &'a self, pack_id: NonZeroU64, body: &'a UpdatePackRequest, ) -> Result<ResponseValue<Pack>, Error<UpdatePackResponse>>

Source

pub async fn get_pack_configuration_schema<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<GetPackConfigurationJsonSchemaResponse>, Error<GetPackConfigurationSchemaResponse>>

Source

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

Source

pub async fn get_next_pack_version<'a>( &'a self, pack_id: NonZeroU64, body: &'a GetNextPackVersionRequest, ) -> Result<ResponseValue<NextPackVersionInfo>, Error<GetNextPackVersionResponse>>

Source

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

Source

pub async fn register_pack_version<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, body: &'a RegisterPackVersionRequest, ) -> Result<ResponseValue<PackVersionUploadInfo>, Error<RegisterPackVersionResponse>>

Source

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

Source

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

Source

pub async fn create_pack_release<'a>( &'a self, pack_id: NonZeroU64, body: &'a CreatePackReleaseRequest, ) -> Result<ResponseValue<PackRelease>, Error<CreatePackReleaseResponse>>

Source

pub async fn update_pack_release<'a>( &'a self, pack_id: NonZeroU64, pack_release_id: NonZeroU64, body: &'a UpdatePackReleaseRequest, ) -> Result<ResponseValue<PackRelease>, Error<UpdatePackReleaseResponse>>

Source

pub async fn get_pack_oauth_config<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackOauthConfigMetadata>, Error<GetPackOauthConfigResponse>>

Source

pub async fn set_pack_oauth_config<'a>( &'a self, pack_id: NonZeroU64, body: &'a SetPackOauthConfigRequest, ) -> Result<ResponseValue<PackOauthConfigMetadata>, Error<SetPackOauthConfigResponse>>

Source

pub async fn get_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<GetPackSystemConnectionResponse>>

Source

pub async fn set_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, body: &'a SetPackSystemConnectionRequest, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<SetPackSystemConnectionResponse>>

Source

pub async fn patch_pack_system_connection<'a>( &'a self, pack_id: NonZeroU64, body: &'a PatchPackSystemConnectionRequest, ) -> Result<ResponseValue<PackSystemConnectionMetadata>, Error<PatchPackSystemConnectionResponse>>

Source

pub async fn get_pack_permissions<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<PackPermissionList>, Error<GetPackPermissionsResponse>>

Source

pub async fn add_pack_permission<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackPermissionRequest, ) -> Result<ResponseValue<AddPackPermissionResponse>, Error<AddPackPermissionResponse>>

Source

pub async fn delete_pack_permission<'a>( &'a self, pack_id: NonZeroU64, permission_id: &'a str, ) -> Result<ResponseValue<DeletePackPermissionResponse>, Error<DeletePackPermissionResponse>>

Source

pub async fn list_user_pack_invitations<'a>( &'a self, limit: Option<NonZeroU64>, page_token: Option<&'a str>, ) -> Result<ResponseValue<PackInvitationWithPackList>, Error<ListUserPackInvitationsResponse>>

Source

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

Source

pub async fn create_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, body: &'a CreatePackInvitationRequest, ) -> Result<ResponseValue<CreatePackInvitationResponse>, Error<CreatePackInvitationResponse>>

Source

pub async fn update_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, invitation_id: &'a Uuid, body: &'a UpdatePackInvitationRequest, ) -> Result<ResponseValue<UpdatePackInvitationResponse>, Error<UpdatePackInvitationResponse>>

Source

pub async fn delete_pack_invitation<'a>( &'a self, pack_id: NonZeroU64, invitation_id: &'a Uuid, ) -> Result<ResponseValue<DeletePackInvitationResponse>, Error<DeletePackInvitationResponse>>

Source

pub async fn reply_to_pack_invitation<'a>( &'a self, invitation_id: &'a Uuid, body: &'a HandlePackInvitationRequest, ) -> Result<ResponseValue<HandlePackInvitationResponse>, Error<ReplyToPackInvitationResponse>>

Source

pub async fn list_pack_makers<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<ListPackMakersResponse>, Error<ListPackMakersResponse>>

Source

pub async fn add_pack_maker<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackMakerRequest, ) -> Result<ResponseValue<AddPackMakerResponse>, Error<AddPackMakerResponse>>

Source

pub async fn delete_pack_maker<'a>( &'a self, pack_id: NonZeroU64, login_id: &'a str, ) -> Result<ResponseValue<DeletePackMakerResponse>, Error<DeletePackMakerResponse>>

Source

pub async fn list_pack_categories<'a>( &'a self, pack_id: NonZeroU64, ) -> Result<ResponseValue<ListPackCategoriesResponse>, Error<ListPackCategoriesResponse>>

Source

pub async fn add_pack_category<'a>( &'a self, pack_id: NonZeroU64, body: &'a AddPackCategoryRequest, ) -> Result<ResponseValue<AddPackCategoryResponse>, Error<AddPackCategoryResponse>>

Source

pub async fn delete_pack_category<'a>( &'a self, pack_id: NonZeroU64, category_name: &'a str, ) -> Result<ResponseValue<DeletePackCategoryResponse>, Error<DeletePackCategoryResponse>>

Source

pub async fn upload_pack_asset<'a>( &'a self, pack_id: NonZeroU64, body: &'a UploadPackAssetRequest, ) -> Result<ResponseValue<PackAssetUploadInfo>, Error<UploadPackAssetResponse>>

Source

pub async fn upload_pack_source_code<'a>( &'a self, pack_id: NonZeroU64, body: &'a UploadPackSourceCodeRequest, ) -> Result<ResponseValue<PackSourceCodeUploadInfo>, Error<UploadPackSourceCodeResponse>>

Source

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

Source

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

Source

pub async fn get_pack_source_code<'a>( &'a self, pack_id: NonZeroU64, pack_version: &'a str, ) -> Result<ResponseValue<PackSourceCodeInfo>, Error<GetPackSourceCodeResponse>>

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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

Source

pub async fn table_refs( &self, doc_id: &str, ) -> Result<Vec<TableReference>, Error<ListTablesResponse>>

Source

pub async fn tables( &self, doc_id: &str, ) -> Result<Vec<Table>, ClientTablesError>

Source

pub async fn columns_map( &self, doc_id: &str, table_ids: impl IntoIterator<Item = TableId>, ) -> Result<HashMap<TableId, Vec<Column>>, Error<ListColumnsResponse>>

Source

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

Source

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

Source

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

Source

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

Source

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

Source

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>

Source

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)

Source

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> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,