use conjure_http::endpoint;
#[conjure_http::conjure_client(name = "CatalogService")]
pub trait CatalogService<
#[response_body]
I: Iterator<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetUuid}",
name = "getEnrichedDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_enriched_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/multiple",
name = "getEnrichedDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_enriched_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets-simple/{datasetUuid}",
name = "getDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/multiple",
name = "getDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::Dataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/external-config",
name = "getDatasetsWithExternalConnectionConfig",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_datasets_with_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::api::rids::DatasetRid,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/external-config",
name = "registerExternalConnectionConfig",
accept = conjure_http::client::StdResponseDeserializer
)]
fn register_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::RegisterExternalConnectionConfigRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/dataset/{datasetRid}/file/{fileId}",
name = "getDatasetFile",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_dataset_file(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/dataset-files/batchGet",
name = "batchGetDatasetFiles",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn batch_get_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::BatchGetDatasetFilesRequest,
) -> Result<
std::collections::BTreeMap<
super::super::super::super::objects::datasource::DatasetFileId,
super::super::super::super::objects::scout::catalog::DatasetFile,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/ingest-job/{ingestJobRid}/files",
name = "getDatasetFilesForJob",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_dataset_files_for_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-datasets-v2",
name = "searchDatasets",
accept = conjure_http::client::StdResponseDeserializer
)]
fn search_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/ingest-status-v2",
name = "updateDatasetIngestStatusV2",
accept = conjure_http::client::StdResponseDeserializer
)]
fn update_dataset_ingest_status_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::UpdateIngestStatusV2,
) -> Result<
super::super::super::super::objects::api::IngestStatusV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/ingest-progress-v2",
name = "getIngestProgressV2",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_ingest_progress_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<
super::super::super::super::objects::scout::catalog::IngestProgressV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{dataset}/handle",
name = "getHandleForDataset",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_handle_for_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "dataset", encoder = conjure_http::client::conjure::PlainEncoder)]
dataset: conjure_object::Uuid,
) -> Result<
Option<super::super::super::super::objects::scout::catalog::Handle>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets",
name = "createDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
fn create_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/create-or-update",
name = "createOrUpdateDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
fn create_or_update_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/with-uuid",
name = "createDatasetWithUuid",
accept = conjure_http::client::StdResponseDeserializer
)]
fn create_dataset_with_uuid(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::CreateDatasetWithUuidRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/add-file",
name = "addFileToDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
fn add_file_to_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::AddFileToDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/files",
name = "listDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
fn list_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-dataset-files",
name = "searchDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
fn search_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetFilesRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetFilesResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/uri",
name = "getDatasetFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_dataset_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/videos/{videoFileRid}/uri",
name = "getVideoFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_video_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "videoFileRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
video_file_rid: &super::super::super::super::objects::api::rids::VideoFileRid,
) -> Result<
super::super::super::super::objects::scout::catalog::VideoFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/origin-uris",
name = "getOriginFileUris",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_origin_file_uris(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
Vec<super::super::super::super::objects::scout::catalog::OriginFileUri>,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/success",
name = "markFileIngestSuccessful",
accept = conjure_http::client::StdResponseDeserializer
)]
fn mark_file_ingest_successful(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestSuccessful,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/error",
name = "markFileIngestError",
accept = conjure_http::client::StdResponseDeserializer
)]
fn mark_file_ingest_error(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestError,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/metadata",
name = "updateDatasetFileMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
fn update_dataset_file_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
metadata: &super::super::super::super::objects::scout::catalog::DatasetFileMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}",
name = "updateDatasetMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
fn update_dataset_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateDatasetMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{rid}/bounds-from-streaming",
name = "updateGlobalDatasetBounds",
accept = conjure_http::client::StdResponseDeserializer
)]
fn update_global_dataset_bounds(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "rid", encoder = conjure_http::client::conjure::PlainEncoder)]
rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateBoundsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/archive",
name = "archiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
fn archive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/unarchive",
name = "unarchiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
fn unarchive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/all-properties-labels",
name = "getAllPropertiesAndLabels",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_all_properties_and_labels(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[query(
name = "workspaces",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
workspaces: &std::collections::BTreeSet<
super::super::super::super::objects::api::rids::WorkspaceRid,
>,
) -> Result<
super::super::super::super::objects::scout::catalog::AllPropertiesAndLabelsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/workspaces/{workspaceRid}/log-dataset",
name = "getLogDatasetForWorkspace",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
fn get_log_dataset_for_workspace(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "workspaceRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
workspace_rid: &super::super::super::super::objects::api::rids::WorkspaceRid,
) -> Result<
Option<super::super::super::super::objects::api::rids::DatasetRid>,
conjure_http::private::Error,
>;
}
#[conjure_http::conjure_client(name = "CatalogService")]
pub trait AsyncCatalogService<
#[response_body]
I: conjure_http::private::Stream<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetUuid}",
name = "getEnrichedDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_enriched_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/multiple",
name = "getEnrichedDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_enriched_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets-simple/{datasetUuid}",
name = "getDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/multiple",
name = "getDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::Dataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/external-config",
name = "getDatasetsWithExternalConnectionConfig",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_datasets_with_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::api::rids::DatasetRid,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/external-config",
name = "registerExternalConnectionConfig",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn register_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::RegisterExternalConnectionConfigRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/dataset/{datasetRid}/file/{fileId}",
name = "getDatasetFile",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_file(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/dataset-files/batchGet",
name = "batchGetDatasetFiles",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn batch_get_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::BatchGetDatasetFilesRequest,
) -> Result<
std::collections::BTreeMap<
super::super::super::super::objects::datasource::DatasetFileId,
super::super::super::super::objects::scout::catalog::DatasetFile,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/ingest-job/{ingestJobRid}/files",
name = "getDatasetFilesForJob",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_files_for_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-datasets-v2",
name = "searchDatasets",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/ingest-status-v2",
name = "updateDatasetIngestStatusV2",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_ingest_status_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::UpdateIngestStatusV2,
) -> Result<
super::super::super::super::objects::api::IngestStatusV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/ingest-progress-v2",
name = "getIngestProgressV2",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_ingest_progress_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<
super::super::super::super::objects::scout::catalog::IngestProgressV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{dataset}/handle",
name = "getHandleForDataset",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_handle_for_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "dataset", encoder = conjure_http::client::conjure::PlainEncoder)]
dataset: conjure_object::Uuid,
) -> Result<
Option<super::super::super::super::objects::scout::catalog::Handle>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets",
name = "createDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/create-or-update",
name = "createOrUpdateDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_or_update_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/with-uuid",
name = "createDatasetWithUuid",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_dataset_with_uuid(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::CreateDatasetWithUuidRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/add-file",
name = "addFileToDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn add_file_to_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::AddFileToDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/files",
name = "listDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn list_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-dataset-files",
name = "searchDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetFilesRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetFilesResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/uri",
name = "getDatasetFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/videos/{videoFileRid}/uri",
name = "getVideoFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_video_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "videoFileRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
video_file_rid: &super::super::super::super::objects::api::rids::VideoFileRid,
) -> Result<
super::super::super::super::objects::scout::catalog::VideoFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/origin-uris",
name = "getOriginFileUris",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_origin_file_uris(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
Vec<super::super::super::super::objects::scout::catalog::OriginFileUri>,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/success",
name = "markFileIngestSuccessful",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn mark_file_ingest_successful(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestSuccessful,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/error",
name = "markFileIngestError",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn mark_file_ingest_error(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestError,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/metadata",
name = "updateDatasetFileMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_file_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
metadata: &super::super::super::super::objects::scout::catalog::DatasetFileMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}",
name = "updateDatasetMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateDatasetMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{rid}/bounds-from-streaming",
name = "updateGlobalDatasetBounds",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_global_dataset_bounds(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "rid", encoder = conjure_http::client::conjure::PlainEncoder)]
rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateBoundsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/archive",
name = "archiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
async fn archive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/unarchive",
name = "unarchiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
async fn unarchive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/all-properties-labels",
name = "getAllPropertiesAndLabels",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_all_properties_and_labels(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[query(
name = "workspaces",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
workspaces: &std::collections::BTreeSet<
super::super::super::super::objects::api::rids::WorkspaceRid,
>,
) -> Result<
super::super::super::super::objects::scout::catalog::AllPropertiesAndLabelsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/workspaces/{workspaceRid}/log-dataset",
name = "getLogDatasetForWorkspace",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_log_dataset_for_workspace(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "workspaceRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
workspace_rid: &super::super::super::super::objects::api::rids::WorkspaceRid,
) -> Result<
Option<super::super::super::super::objects::api::rids::DatasetRid>,
conjure_http::private::Error,
>;
}
#[conjure_http::conjure_client(name = "CatalogService", local)]
pub trait LocalAsyncCatalogService<
#[response_body]
I: conjure_http::private::Stream<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetUuid}",
name = "getEnrichedDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_enriched_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/multiple",
name = "getEnrichedDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_enriched_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets-simple/{datasetUuid}",
name = "getDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetUuid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_uuid: conjure_object::Uuid,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/multiple",
name = "getDatasets",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::scout::catalog::Dataset,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets-simple/external-config",
name = "getDatasetsWithExternalConnectionConfig",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_datasets_with_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
get_datasets_request: &super::super::super::super::objects::scout::catalog::GetDatasetsRequest,
) -> Result<
std::collections::BTreeSet<
super::super::super::super::objects::api::rids::DatasetRid,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/external-config",
name = "registerExternalConnectionConfig",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn register_external_connection_config(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::RegisterExternalConnectionConfigRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/dataset/{datasetRid}/file/{fileId}",
name = "getDatasetFile",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_file(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/dataset-files/batchGet",
name = "batchGetDatasetFiles",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn batch_get_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::BatchGetDatasetFilesRequest,
) -> Result<
std::collections::BTreeMap<
super::super::super::super::objects::datasource::DatasetFileId,
super::super::super::super::objects::scout::catalog::DatasetFile,
>,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/ingest-job/{ingestJobRid}/files",
name = "getDatasetFilesForJob",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_files_for_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-datasets-v2",
name = "searchDatasets",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_datasets(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/ingest-status-v2",
name = "updateDatasetIngestStatusV2",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_ingest_status_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::UpdateIngestStatusV2,
) -> Result<
super::super::super::super::objects::api::IngestStatusV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/ingest-progress-v2",
name = "getIngestProgressV2",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_ingest_progress_v2(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<
super::super::super::super::objects::scout::catalog::IngestProgressV2,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{dataset}/handle",
name = "getHandleForDataset",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_handle_for_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "dataset", encoder = conjure_http::client::conjure::PlainEncoder)]
dataset: conjure_object::Uuid,
) -> Result<
Option<super::super::super::super::objects::scout::catalog::Handle>,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets",
name = "createDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/create-or-update",
name = "createOrUpdateDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_or_update_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
details: &super::super::super::super::objects::scout::catalog::CreateDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/with-uuid",
name = "createDatasetWithUuid",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn create_dataset_with_uuid(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::CreateDatasetWithUuidRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/add-file",
name = "addFileToDataset",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn add_file_to_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::AddFileToDataset,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/files",
name = "listDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn list_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[query(
name = "nextPageToken",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
next_page_token: Option<&super::super::super::super::objects::api::Token>,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFilesPage,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/search-dataset-files",
name = "searchDatasetFiles",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_dataset_files(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::SearchDatasetFilesRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::SearchDatasetFilesResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/uri",
name = "getDatasetFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_dataset_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/videos/{videoFileRid}/uri",
name = "getVideoFileUri",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_video_file_uri(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "videoFileRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
video_file_rid: &super::super::super::super::objects::api::rids::VideoFileRid,
) -> Result<
super::super::super::super::objects::scout::catalog::VideoFileUri,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/{datasetRid}/{fileId}/origin-uris",
name = "getOriginFileUris",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_origin_file_uris(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
) -> Result<
Vec<super::super::super::super::objects::scout::catalog::OriginFileUri>,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/success",
name = "markFileIngestSuccessful",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn mark_file_ingest_successful(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestSuccessful,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/error",
name = "markFileIngestError",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn mark_file_ingest_error(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::MarkFileIngestError,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}/file/{fileId}/metadata",
name = "updateDatasetFileMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_file_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &super::super::super::super::objects::api::rids::DatasetRid,
#[path(name = "fileId", encoder = conjure_http::client::conjure::PlainEncoder)]
file_id: super::super::super::super::objects::datasource::DatasetFileId,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
metadata: &super::super::super::super::objects::scout::catalog::DatasetFileMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::DatasetFile,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{datasetRid}",
name = "updateDatasetMetadata",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_dataset_metadata(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateDatasetMetadata,
) -> Result<
super::super::super::super::objects::scout::catalog::EnrichedDataset,
conjure_http::private::Error,
>;
#[endpoint(
method = PUT,
path = "/catalog/v1/datasets/{rid}/bounds-from-streaming",
name = "updateGlobalDatasetBounds",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn update_global_dataset_bounds(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(name = "rid", encoder = conjure_http::client::conjure::PlainEncoder)]
rid: &conjure_object::ResourceIdentifier,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::scout::catalog::UpdateBoundsRequest,
) -> Result<
super::super::super::super::objects::scout::catalog::Dataset,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/archive",
name = "archiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
async fn archive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = POST,
path = "/catalog/v1/datasets/{datasetRid}/unarchive",
name = "unarchiveDataset",
accept = conjure_http::client::conjure::EmptyResponseDeserializer
)]
async fn unarchive_dataset(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "datasetRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
dataset_rid: &conjure_object::ResourceIdentifier,
) -> Result<(), conjure_http::private::Error>;
#[endpoint(
method = GET,
path = "/catalog/v1/datasets/all-properties-labels",
name = "getAllPropertiesAndLabels",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_all_properties_and_labels(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[query(
name = "workspaces",
encoder = conjure_http::client::conjure::PlainSeqEncoder
)]
workspaces: &std::collections::BTreeSet<
super::super::super::super::objects::api::rids::WorkspaceRid,
>,
) -> Result<
super::super::super::super::objects::scout::catalog::AllPropertiesAndLabelsResponse,
conjure_http::private::Error,
>;
#[endpoint(
method = GET,
path = "/catalog/v1/workspaces/{workspaceRid}/log-dataset",
name = "getLogDatasetForWorkspace",
accept = conjure_http::client::conjure::CollectionResponseDeserializer
)]
async fn get_log_dataset_for_workspace(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "workspaceRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
workspace_rid: &super::super::super::super::objects::api::rids::WorkspaceRid,
) -> Result<
Option<super::super::super::super::objects::api::rids::DatasetRid>,
conjure_http::private::Error,
>;
}