Struct CatalogServiceClient 

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

Trait Implementations

impl<I: Iterator<Item = Result<Bytes, Error>>, __C> CatalogService<I> for CatalogServiceClient<__C>

where __C: Client<ResponseBody = I>,

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

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

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

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

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

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.

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

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

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

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

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

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

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

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.

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

Adds a single file to an existing dataset.

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

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

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

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

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

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

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

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.

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

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

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

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.

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

Undoes the archiving of a dataset.

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.

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

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: Clone> Clone for CatalogServiceClient<C>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for CatalogServiceClient<C>

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

Formats the value using the given formatter.

impl<C> Service<C> for CatalogServiceClient<C>

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

Creates a new service wrapping an HTTP client.