Package com.google.cloud.visionai.v1

Class WarehouseGrpc.WarehouseStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<WarehouseGrpc.WarehouseStub>
com.google.cloud.visionai.v1.WarehouseGrpc.WarehouseStub
Enclosing class:
WarehouseGrpc
public static final class WarehouseGrpc.WarehouseStub extends io.grpc.stub.AbstractAsyncStub<WarehouseGrpc.WarehouseStub>
A stub to allow clients to do asynchronous rpc calls to service Warehouse. 
 Service that manages media content + metadata for streaming.

  • Method Details

    • build

      protected WarehouseGrpc.WarehouseStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<WarehouseGrpc.WarehouseStub>

    • createAsset

      public void createAsset(CreateAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)
       Creates an asset inside corpus.

    • updateAsset

      public void updateAsset(UpdateAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)
       Updates an asset inside corpus.

    • getAsset

      public void getAsset(GetAssetRequest request, io.grpc.stub.StreamObserver<Asset> responseObserver)
       Reads an asset inside corpus.

    • listAssets

      public void listAssets(ListAssetsRequest request, io.grpc.stub.StreamObserver<ListAssetsResponse> responseObserver)
       Lists an list of assets inside corpus.

    • deleteAsset

      public void deleteAsset(DeleteAssetRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Deletes asset inside corpus.

    • uploadAsset

      public void uploadAsset(UploadAssetRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Upload asset by specifing the asset Cloud Storage uri.
 For video warehouse, it requires users who call this API have read access
 to the cloud storage file. Once it is uploaded, it can be retrieved by
 GenerateRetrievalUrl API which by default, only can retrieve cloud storage
 files from the same project of the warehouse. To allow retrieval cloud
 storage files that are in a separate project, it requires to find the
 vision ai service account (Go to IAM, check checkbox to show "Include
 Google-provided role grants", search for "Cloud Vision AI Service Agent")
 and grant the read access of the cloud storage files to that service
 account.

    • generateRetrievalUrl

      public void generateRetrievalUrl(GenerateRetrievalUrlRequest request, io.grpc.stub.StreamObserver<GenerateRetrievalUrlResponse> responseObserver)
       Generates a signed url for downloading the asset.
 For video warehouse, please see comment of UploadAsset about how to allow
 retrieval of cloud storage files in a different project.

    • analyzeAsset

      public void analyzeAsset(AnalyzeAssetRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Analyze asset to power search capability.

    • indexAsset

      public void indexAsset(IndexAssetRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Index one asset for search.
 Supported corpus type: Corpus.Type.VIDEO_ON_DEMAND

    • removeIndexAsset

      public void removeIndexAsset(RemoveIndexAssetRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Remove one asset's index data for search.
 Supported corpus type: Corpus.Type.VIDEO_ON_DEMAND

    • viewIndexedAssets

      public void viewIndexedAssets(ViewIndexedAssetsRequest request, io.grpc.stub.StreamObserver<ViewIndexedAssetsResponse> responseObserver)
       Lists assets inside an index.

    • createIndex

      public void createIndex(CreateIndexRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Creates an Index under the corpus.

    • updateIndex

      public void updateIndex(UpdateIndexRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Updates an Index under the corpus.
 Users can perform a metadata-only update or trigger a full index rebuild
 with different update_mask values.

    • getIndex

      public void getIndex(GetIndexRequest request, io.grpc.stub.StreamObserver<Index> responseObserver)
       Gets the details of a single Index under a Corpus.

    • listIndexes

      public void listIndexes(ListIndexesRequest request, io.grpc.stub.StreamObserver<ListIndexesResponse> responseObserver)
       List all Indexes in a given Corpus.

    • deleteIndex

      public void deleteIndex(DeleteIndexRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Delete a single Index. In order to delete an index, the caller must
 make sure that it is not deployed to any index endpoint.

    • createCorpus

      public void createCorpus(CreateCorpusRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Creates a corpus inside a project.

    • getCorpus

      public void getCorpus(GetCorpusRequest request, io.grpc.stub.StreamObserver<Corpus> responseObserver)
       Gets corpus details inside a project.

    • updateCorpus

      public void updateCorpus(UpdateCorpusRequest request, io.grpc.stub.StreamObserver<Corpus> responseObserver)
       Updates a corpus in a project.

    • listCorpora

      public void listCorpora(ListCorporaRequest request, io.grpc.stub.StreamObserver<ListCorporaResponse> responseObserver)
       Lists all corpora in a project.

    • deleteCorpus

      public void deleteCorpus(DeleteCorpusRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a corpus only if its empty.
 Returns empty response.

    • analyzeCorpus

      public void analyzeCorpus(AnalyzeCorpusRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Analyzes a corpus.

    • createDataSchema

      public void createDataSchema(CreateDataSchemaRequest request, io.grpc.stub.StreamObserver<DataSchema> responseObserver)
       Creates data schema inside corpus.

    • updateDataSchema

      public void updateDataSchema(UpdateDataSchemaRequest request, io.grpc.stub.StreamObserver<DataSchema> responseObserver)
       Updates data schema inside corpus.

    • getDataSchema

      public void getDataSchema(GetDataSchemaRequest request, io.grpc.stub.StreamObserver<DataSchema> responseObserver)
       Gets data schema inside corpus.

    • deleteDataSchema

      public void deleteDataSchema(DeleteDataSchemaRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes data schema inside corpus.

    • listDataSchemas

      public void listDataSchemas(ListDataSchemasRequest request, io.grpc.stub.StreamObserver<ListDataSchemasResponse> responseObserver)
       Lists a list of data schemas inside corpus.

    • createAnnotation

      public void createAnnotation(CreateAnnotationRequest request, io.grpc.stub.StreamObserver<Annotation> responseObserver)
       Creates annotation inside asset.

    • getAnnotation

      public void getAnnotation(GetAnnotationRequest request, io.grpc.stub.StreamObserver<Annotation> responseObserver)
       Reads annotation inside asset.

    • listAnnotations

      public void listAnnotations(ListAnnotationsRequest request, io.grpc.stub.StreamObserver<ListAnnotationsResponse> responseObserver)
       Lists a list of annotations inside asset.

    • updateAnnotation

      public void updateAnnotation(UpdateAnnotationRequest request, io.grpc.stub.StreamObserver<Annotation> responseObserver)
       Updates annotation inside asset.

    • deleteAnnotation

      public void deleteAnnotation(DeleteAnnotationRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes annotation inside asset.

    • ingestAsset

      public io.grpc.stub.StreamObserver<IngestAssetRequest> ingestAsset(io.grpc.stub.StreamObserver<IngestAssetResponse> responseObserver)
       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).

    • clipAsset

      public void clipAsset(ClipAssetRequest request, io.grpc.stub.StreamObserver<ClipAssetResponse> responseObserver)
       Supported by STREAM_VIDEO corpus type.
 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.

    • generateHlsUri

      public void generateHlsUri(GenerateHlsUriRequest request, io.grpc.stub.StreamObserver<GenerateHlsUriResponse> responseObserver)
       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.

    • importAssets

      public void importAssets(ImportAssetsRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Imports assets (images plus annotations) from a meta file on cloud storage.
 Each row in the meta file is corresponding to an image (specified by a
 cloud storage uri) and its annotations.

    • createSearchConfig

      public void createSearchConfig(CreateSearchConfigRequest request, io.grpc.stub.StreamObserver<SearchConfig> responseObserver)
       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.

    • updateSearchConfig

      public void updateSearchConfig(UpdateSearchConfigRequest request, io.grpc.stub.StreamObserver<SearchConfig> responseObserver)
       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.

    • getSearchConfig

      public void getSearchConfig(GetSearchConfigRequest request, io.grpc.stub.StreamObserver<SearchConfig> responseObserver)
       Gets a search configuration inside a corpus.

    • deleteSearchConfig

      public void deleteSearchConfig(DeleteSearchConfigRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a search configuration inside a corpus.
 For a DeleteSearchConfigRequest to be valid,
 Request.search_configuration.name must already exist.

    • listSearchConfigs

      public void listSearchConfigs(ListSearchConfigsRequest request, io.grpc.stub.StreamObserver<ListSearchConfigsResponse> responseObserver)
       Lists all search configurations inside a corpus.

    • createSearchHypernym

      public void createSearchHypernym(CreateSearchHypernymRequest request, io.grpc.stub.StreamObserver<SearchHypernym> responseObserver)
       Creates a SearchHypernym inside a corpus.

    • updateSearchHypernym

      public void updateSearchHypernym(UpdateSearchHypernymRequest request, io.grpc.stub.StreamObserver<SearchHypernym> responseObserver)
       Updates a SearchHypernym inside a corpus.

    • getSearchHypernym

      public void getSearchHypernym(GetSearchHypernymRequest request, io.grpc.stub.StreamObserver<SearchHypernym> responseObserver)
       Gets a SearchHypernym inside a corpus.

    • deleteSearchHypernym

      public void deleteSearchHypernym(DeleteSearchHypernymRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a SearchHypernym inside a corpus.

    • listSearchHypernyms

      public void listSearchHypernyms(ListSearchHypernymsRequest request, io.grpc.stub.StreamObserver<ListSearchHypernymsResponse> responseObserver)
       Lists SearchHypernyms inside a corpus.

    • searchAssets

      public void searchAssets(SearchAssetsRequest request, io.grpc.stub.StreamObserver<SearchAssetsResponse> responseObserver)
       Search media asset.

    • searchIndexEndpoint

      public void searchIndexEndpoint(SearchIndexEndpointRequest request, io.grpc.stub.StreamObserver<SearchIndexEndpointResponse> responseObserver)
       Search a deployed index endpoint (IMAGE corpus type only).

    • createIndexEndpoint

      public void createIndexEndpoint(CreateIndexEndpointRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Creates an IndexEndpoint.

    • getIndexEndpoint

      public void getIndexEndpoint(GetIndexEndpointRequest request, io.grpc.stub.StreamObserver<IndexEndpoint> responseObserver)
       Gets an IndexEndpoint.

    • listIndexEndpoints

      public void listIndexEndpoints(ListIndexEndpointsRequest request, io.grpc.stub.StreamObserver<ListIndexEndpointsResponse> responseObserver)
       Lists all IndexEndpoints in a project.

    • updateIndexEndpoint

      public void updateIndexEndpoint(UpdateIndexEndpointRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Updates an IndexEndpoint.

    • deleteIndexEndpoint

      public void deleteIndexEndpoint(DeleteIndexEndpointRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Deletes an IndexEndpoint.

    • deployIndex

      public void deployIndex(DeployIndexRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Deploys an Index to IndexEndpoint.

    • undeployIndex

      public void undeployIndex(UndeployIndexRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Undeploys an Index from IndexEndpoint.

    • createCollection

      public void createCollection(CreateCollectionRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Creates a collection.

    • deleteCollection

      public void deleteCollection(DeleteCollectionRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Deletes a collection.

    • getCollection

      public void getCollection(GetCollectionRequest request, io.grpc.stub.StreamObserver<Collection> responseObserver)
       Gets a collection.

    • updateCollection

      public void updateCollection(UpdateCollectionRequest request, io.grpc.stub.StreamObserver<Collection> responseObserver)
       Updates a collection.

    • listCollections

      public void listCollections(ListCollectionsRequest request, io.grpc.stub.StreamObserver<ListCollectionsResponse> responseObserver)
       Lists collections inside a corpus.

    • addCollectionItem

      public void addCollectionItem(AddCollectionItemRequest request, io.grpc.stub.StreamObserver<AddCollectionItemResponse> responseObserver)
       Adds an item into a Collection.

    • removeCollectionItem

      public void removeCollectionItem(RemoveCollectionItemRequest request, io.grpc.stub.StreamObserver<RemoveCollectionItemResponse> responseObserver)
       Removes an item from a collection.

    • viewCollectionItems

      public void viewCollectionItems(ViewCollectionItemsRequest request, io.grpc.stub.StreamObserver<ViewCollectionItemsResponse> responseObserver)
       View items inside a collection.