Struct AsyncCatalogServiceClient 

pub struct AsyncCatalogServiceClient<C> { /* private fields */ }

Trait Implementations

impl<I: Stream<Item = Result<Bytes, Error>>, __C> AsyncCatalogService<I> for AsyncCatalogServiceClient<__C>

where __C: AsyncClient<ResponseBody = I> + Sync + Send, __C::ResponseBody: 'static + Send,

async fn get_enriched_dataset( &self, auth_: &BearerToken, dataset_uuid: Uuid, ) -> Result<EnrichedDataset, Error>

async fn get_enriched_datasets( &self, auth_: &BearerToken, get_datasets_request: &GetDatasetsRequest, ) -> Result<BTreeSet<EnrichedDataset>, Error>

async fn get_dataset( &self, auth_: &BearerToken, dataset_uuid: Uuid, ) -> Result<Dataset, Error>

async fn get_datasets( &self, auth_: &BearerToken, get_datasets_request: &GetDatasetsRequest, ) -> Result<BTreeSet<Dataset>, Error>

async fn get_dataset_file( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, file_id: DatasetFileId, ) -> Result<DatasetFile, Error>

async fn batch_get_dataset_files( &self, auth_: &BearerToken, request: &BatchGetDatasetFilesRequest, ) -> Result<BTreeMap<DatasetFileId, DatasetFile>, Error>

Returns dataset files for the given file IDs within a single dataset. Only returns files that exist and belong to the specified dataset. Useful for checking ingestion status of many files at once.

async fn get_dataset_files_for_job( &self, auth_: &BearerToken, ingest_job_rid: &ResourceIdentifier, next_page_token: Option<&Token>, ) -> Result<DatasetFilesPage, Error>

async fn search_datasets( &self, auth_: &BearerToken, request: &SearchDatasetsRequest, ) -> Result<SearchDatasetsResponse, Error>

async fn update_dataset_ingest_status_v2( &self, auth_: &BearerToken, details: &UpdateIngestStatusV2, ) -> Result<IngestStatusV2, Error>

async fn get_ingest_progress_v2( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, ) -> Result<IngestProgressV2, Error>

async fn get_handle_for_dataset( &self, auth_: &BearerToken, dataset: Uuid, ) -> Result<Option<Handle>, Error>

async fn create_dataset( &self, auth_: &BearerToken, details: &CreateDataset, ) -> Result<EnrichedDataset, Error>

async fn create_or_update_dataset( &self, auth_: &BearerToken, details: &CreateDataset, ) -> Result<EnrichedDataset, Error>

Creates a dataset if the s3 path does not exist, otherwise updates the dataset

async fn create_dataset_with_uuid( &self, auth_: &BearerToken, request: &CreateDatasetWithUuidRequest, ) -> Result<EnrichedDataset, Error>

Creates a dataset with a specific UUID. This is useful for migrations and advanced use cases where the dataset UUID must be controlled by the caller. Throws a conflict error if a dataset with the specified UUID already exists. This endpoint is not intended for general use. Use /datasets instead to create a new dataset.

async fn add_file_to_dataset( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, request: &AddFileToDataset, ) -> Result<DatasetFile, Error>

Adds a single file to an existing dataset.

async fn list_dataset_files( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, next_page_token: Option<&Token>, ) -> Result<DatasetFilesPage, Error>

async fn search_dataset_files( &self, auth_: &BearerToken, request: &SearchDatasetFilesRequest, ) -> Result<SearchDatasetFilesResponse, Error>

async fn get_dataset_file_uri( &self, auth_: &BearerToken, dataset_rid: &DatasetRid, file_id: DatasetFileId, ) -> Result<DatasetFileUri, Error>

async fn get_video_file_uri( &self, auth_: &BearerToken, video_file_rid: &VideoFileRid, ) -> Result<VideoFileUri, Error>

async fn get_origin_file_uris( &self, auth_: &BearerToken, dataset_rid: &DatasetRid, file_id: DatasetFileId, ) -> Result<Vec<OriginFileUri>, Error>

async fn mark_file_ingest_successful( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, file_id: DatasetFileId, request: &MarkFileIngestSuccessful, ) -> Result<DatasetFile, Error>

async fn mark_file_ingest_error( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, file_id: DatasetFileId, request: &MarkFileIngestError, ) -> Result<DatasetFile, Error>

async fn update_dataset_file_metadata( &self, auth_: &BearerToken, dataset_rid: &DatasetRid, file_id: DatasetFileId, metadata: &DatasetFileMetadata, ) -> Result<DatasetFile, Error>

Updates file-type-specific metadata for a dataset file. Currently used to update video segment metadata after video segmentation is complete.

async fn update_dataset_metadata( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, request: &UpdateDatasetMetadata, ) -> Result<EnrichedDataset, Error>

async fn update_bounds( &self, auth_: &BearerToken, rid: &ResourceIdentifier, request: &UpdateBoundsRequest, ) -> Result<EnrichedDataset, Error>

async fn update_global_dataset_bounds( &self, auth_: &BearerToken, rid: &ResourceIdentifier, request: &UpdateBoundsRequest, ) -> Result<Dataset, Error>

Update the bounds for a dataset without updating bounds of files within the dataset. If the current bounds of the dataset are not set, then the bounds of the request will be used. Otherwise, the bounds will be min(current start, request start), max(current end, request end).

async fn archive_dataset( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, ) -> Result<(), Error>

Archives a dataset, which will hide it from search results unless the includeArchived flag is set to true. The dataset can still be directly accessed by its UUID/rid.

async fn unarchive_dataset( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, ) -> Result<(), Error>

Undoes the archiving of a dataset.

async fn update_retention_policy( &self, auth_: &BearerToken, dataset_rid: &ResourceIdentifier, request: &UpdateRetentionPolicyRequest, ) -> Result<EnrichedDataset, Error>

Updates the retention policy for a dataset. If the retention policy is set, data that is older than the retention policy will be deleted.

async fn get_all_properties_and_labels( &self, auth_: &BearerToken, workspaces: &BTreeSet<WorkspaceRid>, ) -> Result<AllPropertiesAndLabelsResponse, Error>

async fn get_log_dataset_for_workspace( &self, auth_: &BearerToken, workspace_rid: &WorkspaceRid, ) -> Result<Option<DatasetRid>, Error>

Returns the log dataset RID for the specified workspace if configured and accessible to the caller.

impl<C> AsyncService<C> for AsyncCatalogServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for AsyncCatalogServiceClient<C>

fn clone(&self) -> AsyncCatalogServiceClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for AsyncCatalogServiceClient<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.