Struct google_api_proto::google::cloud::visionai::v1alpha1::warehouse_client::WarehouseClient

pub struct WarehouseClient<T> { /* private fields */ }

Service that manages media content + metadata for streaming.

Implementations

impl<T> WarehouseClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F ) -> WarehouseClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn create_asset( &mut self, request: impl IntoRequest<CreateAssetRequest> ) -> Result<Response<Asset>, Status>

Creates an asset inside corpus.

pub async fn update_asset( &mut self, request: impl IntoRequest<UpdateAssetRequest> ) -> Result<Response<Asset>, Status>

Updates an asset inside corpus.

pub async fn get_asset( &mut self, request: impl IntoRequest<GetAssetRequest> ) -> Result<Response<Asset>, Status>

Reads an asset inside corpus.

pub async fn list_assets( &mut self, request: impl IntoRequest<ListAssetsRequest> ) -> Result<Response<ListAssetsResponse>, Status>

Lists an list of assets inside corpus.

pub async fn delete_asset( &mut self, request: impl IntoRequest<DeleteAssetRequest> ) -> Result<Response<Operation>, Status>

Deletes asset inside corpus.

pub async fn create_corpus( &mut self, request: impl IntoRequest<CreateCorpusRequest> ) -> Result<Response<Operation>, Status>

Creates a corpus inside a project.

pub async fn get_corpus( &mut self, request: impl IntoRequest<GetCorpusRequest> ) -> Result<Response<Corpus>, Status>

Gets corpus details inside a project.

pub async fn update_corpus( &mut self, request: impl IntoRequest<UpdateCorpusRequest> ) -> Result<Response<Corpus>, Status>

Updates a corpus in a project.

pub async fn list_corpora( &mut self, request: impl IntoRequest<ListCorporaRequest> ) -> Result<Response<ListCorporaResponse>, Status>

Lists all corpora in a project.

pub async fn delete_corpus( &mut self, request: impl IntoRequest<DeleteCorpusRequest> ) -> Result<Response<()>, Status>

Deletes a corpus only if its empty. Returns empty response.

pub async fn create_data_schema( &mut self, request: impl IntoRequest<CreateDataSchemaRequest> ) -> Result<Response<DataSchema>, Status>

Creates data schema inside corpus.

pub async fn update_data_schema( &mut self, request: impl IntoRequest<UpdateDataSchemaRequest> ) -> Result<Response<DataSchema>, Status>

Updates data schema inside corpus.

pub async fn get_data_schema( &mut self, request: impl IntoRequest<GetDataSchemaRequest> ) -> Result<Response<DataSchema>, Status>

Gets data schema inside corpus.

pub async fn delete_data_schema( &mut self, request: impl IntoRequest<DeleteDataSchemaRequest> ) -> Result<Response<()>, Status>

Deletes data schema inside corpus.

pub async fn list_data_schemas( &mut self, request: impl IntoRequest<ListDataSchemasRequest> ) -> Result<Response<ListDataSchemasResponse>, Status>

Lists a list of data schemas inside corpus.

pub async fn create_annotation( &mut self, request: impl IntoRequest<CreateAnnotationRequest> ) -> Result<Response<Annotation>, Status>

Creates annotation inside asset.

pub async fn get_annotation( &mut self, request: impl IntoRequest<GetAnnotationRequest> ) -> Result<Response<Annotation>, Status>

Reads annotation inside asset.

pub async fn list_annotations( &mut self, request: impl IntoRequest<ListAnnotationsRequest> ) -> Result<Response<ListAnnotationsResponse>, Status>

Lists a list of annotations inside asset.

pub async fn update_annotation( &mut self, request: impl IntoRequest<UpdateAnnotationRequest> ) -> Result<Response<Annotation>, Status>

Updates annotation inside asset.

pub async fn delete_annotation( &mut self, request: impl IntoRequest<DeleteAnnotationRequest> ) -> Result<Response<()>, Status>

Deletes annotation inside asset.

pub async fn ingest_asset( &mut self, request: impl IntoStreamingRequest<Message = IngestAssetRequest> ) -> Result<Response<Streaming<IngestAssetResponse>>, Status>

Ingests data for the asset. It is not allowed to ingest a data chunk which is already expired according to TTL. This method is only available via the gRPC API (not HTTP since bi-directional streaming is not supported via HTTP).

pub async fn clip_asset( &mut self, request: impl IntoRequest<ClipAssetRequest> ) -> Result<Response<ClipAssetResponse>, Status>

Generates clips for downloading. The api takes in a time range, and generates a clip of the first content available after start_time and before end_time, which may overflow beyond these bounds. Returned clips are truncated if the total size of the clips are larger than 100MB.

pub async fn generate_hls_uri( &mut self, request: impl IntoRequest<GenerateHlsUriRequest> ) -> Result<Response<GenerateHlsUriResponse>, Status>

Generates a uri for an HLS manifest. The api takes in a collection of time ranges, and generates a URI for an HLS manifest that covers all the requested time ranges.

pub async fn create_search_config( &mut self, request: impl IntoRequest<CreateSearchConfigRequest> ) -> Result<Response<SearchConfig>, Status>

Creates a search configuration inside a corpus.

Please follow the rules below to create a valid CreateSearchConfigRequest. — General Rules —

1. Request.search_config_id must not be associated with an existing SearchConfig.
2. Request must contain at least one non-empty search_criteria_property or facet_property.
3. mapped_fields must not be empty, and must map to existing UGA keys.
4. All mapped_fields must be of the same type.
5. All mapped_fields must share the same granularity.
6. All mapped_fields must share the same semantic SearchConfig match options. For property-specific rules, please reference the comments for FacetProperty and SearchCriteriaProperty.

pub async fn update_search_config( &mut self, request: impl IntoRequest<UpdateSearchConfigRequest> ) -> Result<Response<SearchConfig>, Status>

Updates a search configuration inside a corpus.

Please follow the rules below to create a valid UpdateSearchConfigRequest. — General Rules —

1. Request.search_configuration.name must already exist.
2. Request must contain at least one non-empty search_criteria_property or facet_property.
3. mapped_fields must not be empty, and must map to existing UGA keys.
4. All mapped_fields must be of the same type.
5. All mapped_fields must share the same granularity.
6. All mapped_fields must share the same semantic SearchConfig match options. For property-specific rules, please reference the comments for FacetProperty and SearchCriteriaProperty.

pub async fn get_search_config( &mut self, request: impl IntoRequest<GetSearchConfigRequest> ) -> Result<Response<SearchConfig>, Status>

Gets a search configuration inside a corpus.

pub async fn delete_search_config( &mut self, request: impl IntoRequest<DeleteSearchConfigRequest> ) -> Result<Response<()>, Status>

Deletes a search configuration inside a corpus.

For a DeleteSearchConfigRequest to be valid, Request.search_configuration.name must already exist.

pub async fn list_search_configs( &mut self, request: impl IntoRequest<ListSearchConfigsRequest> ) -> Result<Response<ListSearchConfigsResponse>, Status>

Lists all search configurations inside a corpus.

pub async fn search_assets( &mut self, request: impl IntoRequest<SearchAssetsRequest> ) -> Result<Response<SearchAssetsResponse>, Status>

Search media asset.

Trait Implementations

impl<T: Clone> Clone for WarehouseClient<T>

fn clone(&self) -> WarehouseClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for WarehouseClient<T>

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

Formats the value using the given formatter.