GrpcDataLabelingServiceStub.java
/*
* Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.google.cloud.datalabeling.v1beta1.stub;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListAnnotatedDatasetsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListAnnotationSpecSetsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListDataItemsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListDatasetsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListEvaluationJobsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListExamplesPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.ListInstructionsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.SearchEvaluationsPagedResponse;
import static com.google.cloud.datalabeling.v1beta1.DataLabelingServiceClient.SearchExampleComparisonsPagedResponse;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.core.BackgroundResourceAggregation;
import com.google.api.gax.grpc.GrpcCallSettings;
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.datalabeling.v1beta1.AnnotatedDataset;
import com.google.cloud.datalabeling.v1beta1.AnnotationSpecSet;
import com.google.cloud.datalabeling.v1beta1.CreateAnnotationSpecSetRequest;
import com.google.cloud.datalabeling.v1beta1.CreateDatasetRequest;
import com.google.cloud.datalabeling.v1beta1.CreateEvaluationJobRequest;
import com.google.cloud.datalabeling.v1beta1.CreateInstructionMetadata;
import com.google.cloud.datalabeling.v1beta1.CreateInstructionRequest;
import com.google.cloud.datalabeling.v1beta1.DataItem;
import com.google.cloud.datalabeling.v1beta1.Dataset;
import com.google.cloud.datalabeling.v1beta1.DeleteAnnotatedDatasetRequest;
import com.google.cloud.datalabeling.v1beta1.DeleteAnnotationSpecSetRequest;
import com.google.cloud.datalabeling.v1beta1.DeleteDatasetRequest;
import com.google.cloud.datalabeling.v1beta1.DeleteEvaluationJobRequest;
import com.google.cloud.datalabeling.v1beta1.DeleteInstructionRequest;
import com.google.cloud.datalabeling.v1beta1.Evaluation;
import com.google.cloud.datalabeling.v1beta1.EvaluationJob;
import com.google.cloud.datalabeling.v1beta1.Example;
import com.google.cloud.datalabeling.v1beta1.ExportDataOperationMetadata;
import com.google.cloud.datalabeling.v1beta1.ExportDataOperationResponse;
import com.google.cloud.datalabeling.v1beta1.ExportDataRequest;
import com.google.cloud.datalabeling.v1beta1.GetAnnotatedDatasetRequest;
import com.google.cloud.datalabeling.v1beta1.GetAnnotationSpecSetRequest;
import com.google.cloud.datalabeling.v1beta1.GetDataItemRequest;
import com.google.cloud.datalabeling.v1beta1.GetDatasetRequest;
import com.google.cloud.datalabeling.v1beta1.GetEvaluationJobRequest;
import com.google.cloud.datalabeling.v1beta1.GetEvaluationRequest;
import com.google.cloud.datalabeling.v1beta1.GetExampleRequest;
import com.google.cloud.datalabeling.v1beta1.GetInstructionRequest;
import com.google.cloud.datalabeling.v1beta1.ImportDataOperationMetadata;
import com.google.cloud.datalabeling.v1beta1.ImportDataOperationResponse;
import com.google.cloud.datalabeling.v1beta1.ImportDataRequest;
import com.google.cloud.datalabeling.v1beta1.Instruction;
import com.google.cloud.datalabeling.v1beta1.LabelImageRequest;
import com.google.cloud.datalabeling.v1beta1.LabelOperationMetadata;
import com.google.cloud.datalabeling.v1beta1.LabelTextRequest;
import com.google.cloud.datalabeling.v1beta1.LabelVideoRequest;
import com.google.cloud.datalabeling.v1beta1.ListAnnotatedDatasetsRequest;
import com.google.cloud.datalabeling.v1beta1.ListAnnotatedDatasetsResponse;
import com.google.cloud.datalabeling.v1beta1.ListAnnotationSpecSetsRequest;
import com.google.cloud.datalabeling.v1beta1.ListAnnotationSpecSetsResponse;
import com.google.cloud.datalabeling.v1beta1.ListDataItemsRequest;
import com.google.cloud.datalabeling.v1beta1.ListDataItemsResponse;
import com.google.cloud.datalabeling.v1beta1.ListDatasetsRequest;
import com.google.cloud.datalabeling.v1beta1.ListDatasetsResponse;
import com.google.cloud.datalabeling.v1beta1.ListEvaluationJobsRequest;
import com.google.cloud.datalabeling.v1beta1.ListEvaluationJobsResponse;
import com.google.cloud.datalabeling.v1beta1.ListExamplesRequest;
import com.google.cloud.datalabeling.v1beta1.ListExamplesResponse;
import com.google.cloud.datalabeling.v1beta1.ListInstructionsRequest;
import com.google.cloud.datalabeling.v1beta1.ListInstructionsResponse;
import com.google.cloud.datalabeling.v1beta1.PauseEvaluationJobRequest;
import com.google.cloud.datalabeling.v1beta1.ResumeEvaluationJobRequest;
import com.google.cloud.datalabeling.v1beta1.SearchEvaluationsRequest;
import com.google.cloud.datalabeling.v1beta1.SearchEvaluationsResponse;
import com.google.cloud.datalabeling.v1beta1.SearchExampleComparisonsRequest;
import com.google.cloud.datalabeling.v1beta1.SearchExampleComparisonsResponse;
import com.google.cloud.datalabeling.v1beta1.UpdateEvaluationJobRequest;
import com.google.common.collect.ImmutableMap;
import com.google.longrunning.Operation;
import com.google.longrunning.stub.GrpcOperationsStub;
import com.google.protobuf.Empty;
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
/**
* gRPC stub implementation for the DataLabelingService service API.
*
* <p>This class is for advanced usage and reflects the underlying API directly.
*/
@BetaApi
@Generated("by gapic-generator-java")
public class GrpcDataLabelingServiceStub extends DataLabelingServiceStub {
private static final MethodDescriptor<CreateDatasetRequest, Dataset>
createDatasetMethodDescriptor =
MethodDescriptor.<CreateDatasetRequest, Dataset>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/CreateDataset")
.setRequestMarshaller(
ProtoUtils.marshaller(CreateDatasetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Dataset.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetDatasetRequest, Dataset> getDatasetMethodDescriptor =
MethodDescriptor.<GetDatasetRequest, Dataset>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/GetDataset")
.setRequestMarshaller(ProtoUtils.marshaller(GetDatasetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Dataset.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListDatasetsRequest, ListDatasetsResponse>
listDatasetsMethodDescriptor =
MethodDescriptor.<ListDatasetsRequest, ListDatasetsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListDatasets")
.setRequestMarshaller(ProtoUtils.marshaller(ListDatasetsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListDatasetsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<DeleteDatasetRequest, Empty> deleteDatasetMethodDescriptor =
MethodDescriptor.<DeleteDatasetRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/DeleteDataset")
.setRequestMarshaller(ProtoUtils.marshaller(DeleteDatasetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<ImportDataRequest, Operation> importDataMethodDescriptor =
MethodDescriptor.<ImportDataRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/ImportData")
.setRequestMarshaller(ProtoUtils.marshaller(ImportDataRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<ExportDataRequest, Operation> exportDataMethodDescriptor =
MethodDescriptor.<ExportDataRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/ExportData")
.setRequestMarshaller(ProtoUtils.marshaller(ExportDataRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetDataItemRequest, DataItem> getDataItemMethodDescriptor =
MethodDescriptor.<GetDataItemRequest, DataItem>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/GetDataItem")
.setRequestMarshaller(ProtoUtils.marshaller(GetDataItemRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(DataItem.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListDataItemsRequest, ListDataItemsResponse>
listDataItemsMethodDescriptor =
MethodDescriptor.<ListDataItemsRequest, ListDataItemsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListDataItems")
.setRequestMarshaller(
ProtoUtils.marshaller(ListDataItemsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListDataItemsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetAnnotatedDatasetRequest, AnnotatedDataset>
getAnnotatedDatasetMethodDescriptor =
MethodDescriptor.<GetAnnotatedDatasetRequest, AnnotatedDataset>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/GetAnnotatedDataset")
.setRequestMarshaller(
ProtoUtils.marshaller(GetAnnotatedDatasetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(AnnotatedDataset.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>
listAnnotatedDatasetsMethodDescriptor =
MethodDescriptor.<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListAnnotatedDatasets")
.setRequestMarshaller(
ProtoUtils.marshaller(ListAnnotatedDatasetsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListAnnotatedDatasetsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<DeleteAnnotatedDatasetRequest, Empty>
deleteAnnotatedDatasetMethodDescriptor =
MethodDescriptor.<DeleteAnnotatedDatasetRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/DeleteAnnotatedDataset")
.setRequestMarshaller(
ProtoUtils.marshaller(DeleteAnnotatedDatasetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<LabelImageRequest, Operation> labelImageMethodDescriptor =
MethodDescriptor.<LabelImageRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/LabelImage")
.setRequestMarshaller(ProtoUtils.marshaller(LabelImageRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<LabelVideoRequest, Operation> labelVideoMethodDescriptor =
MethodDescriptor.<LabelVideoRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/LabelVideo")
.setRequestMarshaller(ProtoUtils.marshaller(LabelVideoRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<LabelTextRequest, Operation> labelTextMethodDescriptor =
MethodDescriptor.<LabelTextRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/LabelText")
.setRequestMarshaller(ProtoUtils.marshaller(LabelTextRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetExampleRequest, Example> getExampleMethodDescriptor =
MethodDescriptor.<GetExampleRequest, Example>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.cloud.datalabeling.v1beta1.DataLabelingService/GetExample")
.setRequestMarshaller(ProtoUtils.marshaller(GetExampleRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Example.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListExamplesRequest, ListExamplesResponse>
listExamplesMethodDescriptor =
MethodDescriptor.<ListExamplesRequest, ListExamplesResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListExamples")
.setRequestMarshaller(ProtoUtils.marshaller(ListExamplesRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListExamplesResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<CreateAnnotationSpecSetRequest, AnnotationSpecSet>
createAnnotationSpecSetMethodDescriptor =
MethodDescriptor.<CreateAnnotationSpecSetRequest, AnnotationSpecSet>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/CreateAnnotationSpecSet")
.setRequestMarshaller(
ProtoUtils.marshaller(CreateAnnotationSpecSetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(AnnotationSpecSet.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetAnnotationSpecSetRequest, AnnotationSpecSet>
getAnnotationSpecSetMethodDescriptor =
MethodDescriptor.<GetAnnotationSpecSetRequest, AnnotationSpecSet>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/GetAnnotationSpecSet")
.setRequestMarshaller(
ProtoUtils.marshaller(GetAnnotationSpecSetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(AnnotationSpecSet.getDefaultInstance()))
.build();
private static final MethodDescriptor<
ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>
listAnnotationSpecSetsMethodDescriptor =
MethodDescriptor
.<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListAnnotationSpecSets")
.setRequestMarshaller(
ProtoUtils.marshaller(ListAnnotationSpecSetsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListAnnotationSpecSetsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<DeleteAnnotationSpecSetRequest, Empty>
deleteAnnotationSpecSetMethodDescriptor =
MethodDescriptor.<DeleteAnnotationSpecSetRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/DeleteAnnotationSpecSet")
.setRequestMarshaller(
ProtoUtils.marshaller(DeleteAnnotationSpecSetRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<CreateInstructionRequest, Operation>
createInstructionMethodDescriptor =
MethodDescriptor.<CreateInstructionRequest, Operation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/CreateInstruction")
.setRequestMarshaller(
ProtoUtils.marshaller(CreateInstructionRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetInstructionRequest, Instruction>
getInstructionMethodDescriptor =
MethodDescriptor.<GetInstructionRequest, Instruction>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/GetInstruction")
.setRequestMarshaller(
ProtoUtils.marshaller(GetInstructionRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Instruction.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListInstructionsRequest, ListInstructionsResponse>
listInstructionsMethodDescriptor =
MethodDescriptor.<ListInstructionsRequest, ListInstructionsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListInstructions")
.setRequestMarshaller(
ProtoUtils.marshaller(ListInstructionsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListInstructionsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<DeleteInstructionRequest, Empty>
deleteInstructionMethodDescriptor =
MethodDescriptor.<DeleteInstructionRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/DeleteInstruction")
.setRequestMarshaller(
ProtoUtils.marshaller(DeleteInstructionRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetEvaluationRequest, Evaluation>
getEvaluationMethodDescriptor =
MethodDescriptor.<GetEvaluationRequest, Evaluation>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/GetEvaluation")
.setRequestMarshaller(
ProtoUtils.marshaller(GetEvaluationRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Evaluation.getDefaultInstance()))
.build();
private static final MethodDescriptor<SearchEvaluationsRequest, SearchEvaluationsResponse>
searchEvaluationsMethodDescriptor =
MethodDescriptor.<SearchEvaluationsRequest, SearchEvaluationsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/SearchEvaluations")
.setRequestMarshaller(
ProtoUtils.marshaller(SearchEvaluationsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(SearchEvaluationsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<
SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>
searchExampleComparisonsMethodDescriptor =
MethodDescriptor
.<SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/SearchExampleComparisons")
.setRequestMarshaller(
ProtoUtils.marshaller(SearchExampleComparisonsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(SearchExampleComparisonsResponse.getDefaultInstance()))
.build();
private static final MethodDescriptor<CreateEvaluationJobRequest, EvaluationJob>
createEvaluationJobMethodDescriptor =
MethodDescriptor.<CreateEvaluationJobRequest, EvaluationJob>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/CreateEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(CreateEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(EvaluationJob.getDefaultInstance()))
.build();
private static final MethodDescriptor<UpdateEvaluationJobRequest, EvaluationJob>
updateEvaluationJobMethodDescriptor =
MethodDescriptor.<UpdateEvaluationJobRequest, EvaluationJob>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/UpdateEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(UpdateEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(EvaluationJob.getDefaultInstance()))
.build();
private static final MethodDescriptor<GetEvaluationJobRequest, EvaluationJob>
getEvaluationJobMethodDescriptor =
MethodDescriptor.<GetEvaluationJobRequest, EvaluationJob>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/GetEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(GetEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(EvaluationJob.getDefaultInstance()))
.build();
private static final MethodDescriptor<PauseEvaluationJobRequest, Empty>
pauseEvaluationJobMethodDescriptor =
MethodDescriptor.<PauseEvaluationJobRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/PauseEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(PauseEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<ResumeEvaluationJobRequest, Empty>
resumeEvaluationJobMethodDescriptor =
MethodDescriptor.<ResumeEvaluationJobRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ResumeEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(ResumeEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<DeleteEvaluationJobRequest, Empty>
deleteEvaluationJobMethodDescriptor =
MethodDescriptor.<DeleteEvaluationJobRequest, Empty>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/DeleteEvaluationJob")
.setRequestMarshaller(
ProtoUtils.marshaller(DeleteEvaluationJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
private static final MethodDescriptor<ListEvaluationJobsRequest, ListEvaluationJobsResponse>
listEvaluationJobsMethodDescriptor =
MethodDescriptor.<ListEvaluationJobsRequest, ListEvaluationJobsResponse>newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
"google.cloud.datalabeling.v1beta1.DataLabelingService/ListEvaluationJobs")
.setRequestMarshaller(
ProtoUtils.marshaller(ListEvaluationJobsRequest.getDefaultInstance()))
.setResponseMarshaller(
ProtoUtils.marshaller(ListEvaluationJobsResponse.getDefaultInstance()))
.build();
private final UnaryCallable<CreateDatasetRequest, Dataset> createDatasetCallable;
private final UnaryCallable<GetDatasetRequest, Dataset> getDatasetCallable;
private final UnaryCallable<ListDatasetsRequest, ListDatasetsResponse> listDatasetsCallable;
private final UnaryCallable<ListDatasetsRequest, ListDatasetsPagedResponse>
listDatasetsPagedCallable;
private final UnaryCallable<DeleteDatasetRequest, Empty> deleteDatasetCallable;
private final UnaryCallable<ImportDataRequest, Operation> importDataCallable;
private final OperationCallable<
ImportDataRequest, ImportDataOperationResponse, ImportDataOperationMetadata>
importDataOperationCallable;
private final UnaryCallable<ExportDataRequest, Operation> exportDataCallable;
private final OperationCallable<
ExportDataRequest, ExportDataOperationResponse, ExportDataOperationMetadata>
exportDataOperationCallable;
private final UnaryCallable<GetDataItemRequest, DataItem> getDataItemCallable;
private final UnaryCallable<ListDataItemsRequest, ListDataItemsResponse> listDataItemsCallable;
private final UnaryCallable<ListDataItemsRequest, ListDataItemsPagedResponse>
listDataItemsPagedCallable;
private final UnaryCallable<GetAnnotatedDatasetRequest, AnnotatedDataset>
getAnnotatedDatasetCallable;
private final UnaryCallable<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>
listAnnotatedDatasetsCallable;
private final UnaryCallable<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsPagedResponse>
listAnnotatedDatasetsPagedCallable;
private final UnaryCallable<DeleteAnnotatedDatasetRequest, Empty> deleteAnnotatedDatasetCallable;
private final UnaryCallable<LabelImageRequest, Operation> labelImageCallable;
private final OperationCallable<LabelImageRequest, AnnotatedDataset, LabelOperationMetadata>
labelImageOperationCallable;
private final UnaryCallable<LabelVideoRequest, Operation> labelVideoCallable;
private final OperationCallable<LabelVideoRequest, AnnotatedDataset, LabelOperationMetadata>
labelVideoOperationCallable;
private final UnaryCallable<LabelTextRequest, Operation> labelTextCallable;
private final OperationCallable<LabelTextRequest, AnnotatedDataset, LabelOperationMetadata>
labelTextOperationCallable;
private final UnaryCallable<GetExampleRequest, Example> getExampleCallable;
private final UnaryCallable<ListExamplesRequest, ListExamplesResponse> listExamplesCallable;
private final UnaryCallable<ListExamplesRequest, ListExamplesPagedResponse>
listExamplesPagedCallable;
private final UnaryCallable<CreateAnnotationSpecSetRequest, AnnotationSpecSet>
createAnnotationSpecSetCallable;
private final UnaryCallable<GetAnnotationSpecSetRequest, AnnotationSpecSet>
getAnnotationSpecSetCallable;
private final UnaryCallable<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>
listAnnotationSpecSetsCallable;
private final UnaryCallable<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsPagedResponse>
listAnnotationSpecSetsPagedCallable;
private final UnaryCallable<DeleteAnnotationSpecSetRequest, Empty>
deleteAnnotationSpecSetCallable;
private final UnaryCallable<CreateInstructionRequest, Operation> createInstructionCallable;
private final OperationCallable<CreateInstructionRequest, Instruction, CreateInstructionMetadata>
createInstructionOperationCallable;
private final UnaryCallable<GetInstructionRequest, Instruction> getInstructionCallable;
private final UnaryCallable<ListInstructionsRequest, ListInstructionsResponse>
listInstructionsCallable;
private final UnaryCallable<ListInstructionsRequest, ListInstructionsPagedResponse>
listInstructionsPagedCallable;
private final UnaryCallable<DeleteInstructionRequest, Empty> deleteInstructionCallable;
private final UnaryCallable<GetEvaluationRequest, Evaluation> getEvaluationCallable;
private final UnaryCallable<SearchEvaluationsRequest, SearchEvaluationsResponse>
searchEvaluationsCallable;
private final UnaryCallable<SearchEvaluationsRequest, SearchEvaluationsPagedResponse>
searchEvaluationsPagedCallable;
private final UnaryCallable<SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>
searchExampleComparisonsCallable;
private final UnaryCallable<
SearchExampleComparisonsRequest, SearchExampleComparisonsPagedResponse>
searchExampleComparisonsPagedCallable;
private final UnaryCallable<CreateEvaluationJobRequest, EvaluationJob>
createEvaluationJobCallable;
private final UnaryCallable<UpdateEvaluationJobRequest, EvaluationJob>
updateEvaluationJobCallable;
private final UnaryCallable<GetEvaluationJobRequest, EvaluationJob> getEvaluationJobCallable;
private final UnaryCallable<PauseEvaluationJobRequest, Empty> pauseEvaluationJobCallable;
private final UnaryCallable<ResumeEvaluationJobRequest, Empty> resumeEvaluationJobCallable;
private final UnaryCallable<DeleteEvaluationJobRequest, Empty> deleteEvaluationJobCallable;
private final UnaryCallable<ListEvaluationJobsRequest, ListEvaluationJobsResponse>
listEvaluationJobsCallable;
private final UnaryCallable<ListEvaluationJobsRequest, ListEvaluationJobsPagedResponse>
listEvaluationJobsPagedCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
private final GrpcStubCallableFactory callableFactory;
public static final GrpcDataLabelingServiceStub create(DataLabelingServiceStubSettings settings)
throws IOException {
return new GrpcDataLabelingServiceStub(settings, ClientContext.create(settings));
}
public static final GrpcDataLabelingServiceStub create(ClientContext clientContext)
throws IOException {
return new GrpcDataLabelingServiceStub(
DataLabelingServiceStubSettings.newBuilder().build(), clientContext);
}
public static final GrpcDataLabelingServiceStub create(
ClientContext clientContext, GrpcStubCallableFactory callableFactory) throws IOException {
return new GrpcDataLabelingServiceStub(
DataLabelingServiceStubSettings.newBuilder().build(), clientContext, callableFactory);
}
/**
* Constructs an instance of GrpcDataLabelingServiceStub, using the given settings. This is
* protected so that it is easy to make a subclass, but otherwise, the static factory methods
* should be preferred.
*/
protected GrpcDataLabelingServiceStub(
DataLabelingServiceStubSettings settings, ClientContext clientContext) throws IOException {
this(settings, clientContext, new GrpcDataLabelingServiceCallableFactory());
}
/**
* Constructs an instance of GrpcDataLabelingServiceStub, using the given settings. This is
* protected so that it is easy to make a subclass, but otherwise, the static factory methods
* should be preferred.
*/
protected GrpcDataLabelingServiceStub(
DataLabelingServiceStubSettings settings,
ClientContext clientContext,
GrpcStubCallableFactory callableFactory)
throws IOException {
this.callableFactory = callableFactory;
this.operationsStub = GrpcOperationsStub.create(clientContext, callableFactory);
GrpcCallSettings<CreateDatasetRequest, Dataset> createDatasetTransportSettings =
GrpcCallSettings.<CreateDatasetRequest, Dataset>newBuilder()
.setMethodDescriptor(createDatasetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<GetDatasetRequest, Dataset> getDatasetTransportSettings =
GrpcCallSettings.<GetDatasetRequest, Dataset>newBuilder()
.setMethodDescriptor(getDatasetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListDatasetsRequest, ListDatasetsResponse> listDatasetsTransportSettings =
GrpcCallSettings.<ListDatasetsRequest, ListDatasetsResponse>newBuilder()
.setMethodDescriptor(listDatasetsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<DeleteDatasetRequest, Empty> deleteDatasetTransportSettings =
GrpcCallSettings.<DeleteDatasetRequest, Empty>newBuilder()
.setMethodDescriptor(deleteDatasetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ImportDataRequest, Operation> importDataTransportSettings =
GrpcCallSettings.<ImportDataRequest, Operation>newBuilder()
.setMethodDescriptor(importDataMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ExportDataRequest, Operation> exportDataTransportSettings =
GrpcCallSettings.<ExportDataRequest, Operation>newBuilder()
.setMethodDescriptor(exportDataMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<GetDataItemRequest, DataItem> getDataItemTransportSettings =
GrpcCallSettings.<GetDataItemRequest, DataItem>newBuilder()
.setMethodDescriptor(getDataItemMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListDataItemsRequest, ListDataItemsResponse> listDataItemsTransportSettings =
GrpcCallSettings.<ListDataItemsRequest, ListDataItemsResponse>newBuilder()
.setMethodDescriptor(listDataItemsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<GetAnnotatedDatasetRequest, AnnotatedDataset>
getAnnotatedDatasetTransportSettings =
GrpcCallSettings.<GetAnnotatedDatasetRequest, AnnotatedDataset>newBuilder()
.setMethodDescriptor(getAnnotatedDatasetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>
listAnnotatedDatasetsTransportSettings =
GrpcCallSettings
.<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>newBuilder()
.setMethodDescriptor(listAnnotatedDatasetsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<DeleteAnnotatedDatasetRequest, Empty> deleteAnnotatedDatasetTransportSettings =
GrpcCallSettings.<DeleteAnnotatedDatasetRequest, Empty>newBuilder()
.setMethodDescriptor(deleteAnnotatedDatasetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<LabelImageRequest, Operation> labelImageTransportSettings =
GrpcCallSettings.<LabelImageRequest, Operation>newBuilder()
.setMethodDescriptor(labelImageMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<LabelVideoRequest, Operation> labelVideoTransportSettings =
GrpcCallSettings.<LabelVideoRequest, Operation>newBuilder()
.setMethodDescriptor(labelVideoMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<LabelTextRequest, Operation> labelTextTransportSettings =
GrpcCallSettings.<LabelTextRequest, Operation>newBuilder()
.setMethodDescriptor(labelTextMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<GetExampleRequest, Example> getExampleTransportSettings =
GrpcCallSettings.<GetExampleRequest, Example>newBuilder()
.setMethodDescriptor(getExampleMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListExamplesRequest, ListExamplesResponse> listExamplesTransportSettings =
GrpcCallSettings.<ListExamplesRequest, ListExamplesResponse>newBuilder()
.setMethodDescriptor(listExamplesMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<CreateAnnotationSpecSetRequest, AnnotationSpecSet>
createAnnotationSpecSetTransportSettings =
GrpcCallSettings.<CreateAnnotationSpecSetRequest, AnnotationSpecSet>newBuilder()
.setMethodDescriptor(createAnnotationSpecSetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<GetAnnotationSpecSetRequest, AnnotationSpecSet>
getAnnotationSpecSetTransportSettings =
GrpcCallSettings.<GetAnnotationSpecSetRequest, AnnotationSpecSet>newBuilder()
.setMethodDescriptor(getAnnotationSpecSetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>
listAnnotationSpecSetsTransportSettings =
GrpcCallSettings
.<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>newBuilder()
.setMethodDescriptor(listAnnotationSpecSetsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<DeleteAnnotationSpecSetRequest, Empty>
deleteAnnotationSpecSetTransportSettings =
GrpcCallSettings.<DeleteAnnotationSpecSetRequest, Empty>newBuilder()
.setMethodDescriptor(deleteAnnotationSpecSetMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<CreateInstructionRequest, Operation> createInstructionTransportSettings =
GrpcCallSettings.<CreateInstructionRequest, Operation>newBuilder()
.setMethodDescriptor(createInstructionMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<GetInstructionRequest, Instruction> getInstructionTransportSettings =
GrpcCallSettings.<GetInstructionRequest, Instruction>newBuilder()
.setMethodDescriptor(getInstructionMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListInstructionsRequest, ListInstructionsResponse>
listInstructionsTransportSettings =
GrpcCallSettings.<ListInstructionsRequest, ListInstructionsResponse>newBuilder()
.setMethodDescriptor(listInstructionsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<DeleteInstructionRequest, Empty> deleteInstructionTransportSettings =
GrpcCallSettings.<DeleteInstructionRequest, Empty>newBuilder()
.setMethodDescriptor(deleteInstructionMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<GetEvaluationRequest, Evaluation> getEvaluationTransportSettings =
GrpcCallSettings.<GetEvaluationRequest, Evaluation>newBuilder()
.setMethodDescriptor(getEvaluationMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<SearchEvaluationsRequest, SearchEvaluationsResponse>
searchEvaluationsTransportSettings =
GrpcCallSettings.<SearchEvaluationsRequest, SearchEvaluationsResponse>newBuilder()
.setMethodDescriptor(searchEvaluationsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>
searchExampleComparisonsTransportSettings =
GrpcCallSettings
.<SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>newBuilder()
.setMethodDescriptor(searchExampleComparisonsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<CreateEvaluationJobRequest, EvaluationJob>
createEvaluationJobTransportSettings =
GrpcCallSettings.<CreateEvaluationJobRequest, EvaluationJob>newBuilder()
.setMethodDescriptor(createEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
GrpcCallSettings<UpdateEvaluationJobRequest, EvaluationJob>
updateEvaluationJobTransportSettings =
GrpcCallSettings.<UpdateEvaluationJobRequest, EvaluationJob>newBuilder()
.setMethodDescriptor(updateEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put(
"evaluation_job.name",
String.valueOf(request.getEvaluationJob().getName()));
return params.build();
})
.build();
GrpcCallSettings<GetEvaluationJobRequest, EvaluationJob> getEvaluationJobTransportSettings =
GrpcCallSettings.<GetEvaluationJobRequest, EvaluationJob>newBuilder()
.setMethodDescriptor(getEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<PauseEvaluationJobRequest, Empty> pauseEvaluationJobTransportSettings =
GrpcCallSettings.<PauseEvaluationJobRequest, Empty>newBuilder()
.setMethodDescriptor(pauseEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ResumeEvaluationJobRequest, Empty> resumeEvaluationJobTransportSettings =
GrpcCallSettings.<ResumeEvaluationJobRequest, Empty>newBuilder()
.setMethodDescriptor(resumeEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<DeleteEvaluationJobRequest, Empty> deleteEvaluationJobTransportSettings =
GrpcCallSettings.<DeleteEvaluationJobRequest, Empty>newBuilder()
.setMethodDescriptor(deleteEvaluationJobMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("name", String.valueOf(request.getName()));
return params.build();
})
.build();
GrpcCallSettings<ListEvaluationJobsRequest, ListEvaluationJobsResponse>
listEvaluationJobsTransportSettings =
GrpcCallSettings.<ListEvaluationJobsRequest, ListEvaluationJobsResponse>newBuilder()
.setMethodDescriptor(listEvaluationJobsMethodDescriptor)
.setParamsExtractor(
request -> {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("parent", String.valueOf(request.getParent()));
return params.build();
})
.build();
this.createDatasetCallable =
callableFactory.createUnaryCallable(
createDatasetTransportSettings, settings.createDatasetSettings(), clientContext);
this.getDatasetCallable =
callableFactory.createUnaryCallable(
getDatasetTransportSettings, settings.getDatasetSettings(), clientContext);
this.listDatasetsCallable =
callableFactory.createUnaryCallable(
listDatasetsTransportSettings, settings.listDatasetsSettings(), clientContext);
this.listDatasetsPagedCallable =
callableFactory.createPagedCallable(
listDatasetsTransportSettings, settings.listDatasetsSettings(), clientContext);
this.deleteDatasetCallable =
callableFactory.createUnaryCallable(
deleteDatasetTransportSettings, settings.deleteDatasetSettings(), clientContext);
this.importDataCallable =
callableFactory.createUnaryCallable(
importDataTransportSettings, settings.importDataSettings(), clientContext);
this.importDataOperationCallable =
callableFactory.createOperationCallable(
importDataTransportSettings,
settings.importDataOperationSettings(),
clientContext,
operationsStub);
this.exportDataCallable =
callableFactory.createUnaryCallable(
exportDataTransportSettings, settings.exportDataSettings(), clientContext);
this.exportDataOperationCallable =
callableFactory.createOperationCallable(
exportDataTransportSettings,
settings.exportDataOperationSettings(),
clientContext,
operationsStub);
this.getDataItemCallable =
callableFactory.createUnaryCallable(
getDataItemTransportSettings, settings.getDataItemSettings(), clientContext);
this.listDataItemsCallable =
callableFactory.createUnaryCallable(
listDataItemsTransportSettings, settings.listDataItemsSettings(), clientContext);
this.listDataItemsPagedCallable =
callableFactory.createPagedCallable(
listDataItemsTransportSettings, settings.listDataItemsSettings(), clientContext);
this.getAnnotatedDatasetCallable =
callableFactory.createUnaryCallable(
getAnnotatedDatasetTransportSettings,
settings.getAnnotatedDatasetSettings(),
clientContext);
this.listAnnotatedDatasetsCallable =
callableFactory.createUnaryCallable(
listAnnotatedDatasetsTransportSettings,
settings.listAnnotatedDatasetsSettings(),
clientContext);
this.listAnnotatedDatasetsPagedCallable =
callableFactory.createPagedCallable(
listAnnotatedDatasetsTransportSettings,
settings.listAnnotatedDatasetsSettings(),
clientContext);
this.deleteAnnotatedDatasetCallable =
callableFactory.createUnaryCallable(
deleteAnnotatedDatasetTransportSettings,
settings.deleteAnnotatedDatasetSettings(),
clientContext);
this.labelImageCallable =
callableFactory.createUnaryCallable(
labelImageTransportSettings, settings.labelImageSettings(), clientContext);
this.labelImageOperationCallable =
callableFactory.createOperationCallable(
labelImageTransportSettings,
settings.labelImageOperationSettings(),
clientContext,
operationsStub);
this.labelVideoCallable =
callableFactory.createUnaryCallable(
labelVideoTransportSettings, settings.labelVideoSettings(), clientContext);
this.labelVideoOperationCallable =
callableFactory.createOperationCallable(
labelVideoTransportSettings,
settings.labelVideoOperationSettings(),
clientContext,
operationsStub);
this.labelTextCallable =
callableFactory.createUnaryCallable(
labelTextTransportSettings, settings.labelTextSettings(), clientContext);
this.labelTextOperationCallable =
callableFactory.createOperationCallable(
labelTextTransportSettings,
settings.labelTextOperationSettings(),
clientContext,
operationsStub);
this.getExampleCallable =
callableFactory.createUnaryCallable(
getExampleTransportSettings, settings.getExampleSettings(), clientContext);
this.listExamplesCallable =
callableFactory.createUnaryCallable(
listExamplesTransportSettings, settings.listExamplesSettings(), clientContext);
this.listExamplesPagedCallable =
callableFactory.createPagedCallable(
listExamplesTransportSettings, settings.listExamplesSettings(), clientContext);
this.createAnnotationSpecSetCallable =
callableFactory.createUnaryCallable(
createAnnotationSpecSetTransportSettings,
settings.createAnnotationSpecSetSettings(),
clientContext);
this.getAnnotationSpecSetCallable =
callableFactory.createUnaryCallable(
getAnnotationSpecSetTransportSettings,
settings.getAnnotationSpecSetSettings(),
clientContext);
this.listAnnotationSpecSetsCallable =
callableFactory.createUnaryCallable(
listAnnotationSpecSetsTransportSettings,
settings.listAnnotationSpecSetsSettings(),
clientContext);
this.listAnnotationSpecSetsPagedCallable =
callableFactory.createPagedCallable(
listAnnotationSpecSetsTransportSettings,
settings.listAnnotationSpecSetsSettings(),
clientContext);
this.deleteAnnotationSpecSetCallable =
callableFactory.createUnaryCallable(
deleteAnnotationSpecSetTransportSettings,
settings.deleteAnnotationSpecSetSettings(),
clientContext);
this.createInstructionCallable =
callableFactory.createUnaryCallable(
createInstructionTransportSettings,
settings.createInstructionSettings(),
clientContext);
this.createInstructionOperationCallable =
callableFactory.createOperationCallable(
createInstructionTransportSettings,
settings.createInstructionOperationSettings(),
clientContext,
operationsStub);
this.getInstructionCallable =
callableFactory.createUnaryCallable(
getInstructionTransportSettings, settings.getInstructionSettings(), clientContext);
this.listInstructionsCallable =
callableFactory.createUnaryCallable(
listInstructionsTransportSettings, settings.listInstructionsSettings(), clientContext);
this.listInstructionsPagedCallable =
callableFactory.createPagedCallable(
listInstructionsTransportSettings, settings.listInstructionsSettings(), clientContext);
this.deleteInstructionCallable =
callableFactory.createUnaryCallable(
deleteInstructionTransportSettings,
settings.deleteInstructionSettings(),
clientContext);
this.getEvaluationCallable =
callableFactory.createUnaryCallable(
getEvaluationTransportSettings, settings.getEvaluationSettings(), clientContext);
this.searchEvaluationsCallable =
callableFactory.createUnaryCallable(
searchEvaluationsTransportSettings,
settings.searchEvaluationsSettings(),
clientContext);
this.searchEvaluationsPagedCallable =
callableFactory.createPagedCallable(
searchEvaluationsTransportSettings,
settings.searchEvaluationsSettings(),
clientContext);
this.searchExampleComparisonsCallable =
callableFactory.createUnaryCallable(
searchExampleComparisonsTransportSettings,
settings.searchExampleComparisonsSettings(),
clientContext);
this.searchExampleComparisonsPagedCallable =
callableFactory.createPagedCallable(
searchExampleComparisonsTransportSettings,
settings.searchExampleComparisonsSettings(),
clientContext);
this.createEvaluationJobCallable =
callableFactory.createUnaryCallable(
createEvaluationJobTransportSettings,
settings.createEvaluationJobSettings(),
clientContext);
this.updateEvaluationJobCallable =
callableFactory.createUnaryCallable(
updateEvaluationJobTransportSettings,
settings.updateEvaluationJobSettings(),
clientContext);
this.getEvaluationJobCallable =
callableFactory.createUnaryCallable(
getEvaluationJobTransportSettings, settings.getEvaluationJobSettings(), clientContext);
this.pauseEvaluationJobCallable =
callableFactory.createUnaryCallable(
pauseEvaluationJobTransportSettings,
settings.pauseEvaluationJobSettings(),
clientContext);
this.resumeEvaluationJobCallable =
callableFactory.createUnaryCallable(
resumeEvaluationJobTransportSettings,
settings.resumeEvaluationJobSettings(),
clientContext);
this.deleteEvaluationJobCallable =
callableFactory.createUnaryCallable(
deleteEvaluationJobTransportSettings,
settings.deleteEvaluationJobSettings(),
clientContext);
this.listEvaluationJobsCallable =
callableFactory.createUnaryCallable(
listEvaluationJobsTransportSettings,
settings.listEvaluationJobsSettings(),
clientContext);
this.listEvaluationJobsPagedCallable =
callableFactory.createPagedCallable(
listEvaluationJobsTransportSettings,
settings.listEvaluationJobsSettings(),
clientContext);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
public GrpcOperationsStub getOperationsStub() {
return operationsStub;
}
@Override
public UnaryCallable<CreateDatasetRequest, Dataset> createDatasetCallable() {
return createDatasetCallable;
}
@Override
public UnaryCallable<GetDatasetRequest, Dataset> getDatasetCallable() {
return getDatasetCallable;
}
@Override
public UnaryCallable<ListDatasetsRequest, ListDatasetsResponse> listDatasetsCallable() {
return listDatasetsCallable;
}
@Override
public UnaryCallable<ListDatasetsRequest, ListDatasetsPagedResponse> listDatasetsPagedCallable() {
return listDatasetsPagedCallable;
}
@Override
public UnaryCallable<DeleteDatasetRequest, Empty> deleteDatasetCallable() {
return deleteDatasetCallable;
}
@Override
public UnaryCallable<ImportDataRequest, Operation> importDataCallable() {
return importDataCallable;
}
@Override
public OperationCallable<
ImportDataRequest, ImportDataOperationResponse, ImportDataOperationMetadata>
importDataOperationCallable() {
return importDataOperationCallable;
}
@Override
public UnaryCallable<ExportDataRequest, Operation> exportDataCallable() {
return exportDataCallable;
}
@Override
public OperationCallable<
ExportDataRequest, ExportDataOperationResponse, ExportDataOperationMetadata>
exportDataOperationCallable() {
return exportDataOperationCallable;
}
@Override
public UnaryCallable<GetDataItemRequest, DataItem> getDataItemCallable() {
return getDataItemCallable;
}
@Override
public UnaryCallable<ListDataItemsRequest, ListDataItemsResponse> listDataItemsCallable() {
return listDataItemsCallable;
}
@Override
public UnaryCallable<ListDataItemsRequest, ListDataItemsPagedResponse>
listDataItemsPagedCallable() {
return listDataItemsPagedCallable;
}
@Override
public UnaryCallable<GetAnnotatedDatasetRequest, AnnotatedDataset> getAnnotatedDatasetCallable() {
return getAnnotatedDatasetCallable;
}
@Override
public UnaryCallable<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsResponse>
listAnnotatedDatasetsCallable() {
return listAnnotatedDatasetsCallable;
}
@Override
public UnaryCallable<ListAnnotatedDatasetsRequest, ListAnnotatedDatasetsPagedResponse>
listAnnotatedDatasetsPagedCallable() {
return listAnnotatedDatasetsPagedCallable;
}
@Override
public UnaryCallable<DeleteAnnotatedDatasetRequest, Empty> deleteAnnotatedDatasetCallable() {
return deleteAnnotatedDatasetCallable;
}
@Override
public UnaryCallable<LabelImageRequest, Operation> labelImageCallable() {
return labelImageCallable;
}
@Override
public OperationCallable<LabelImageRequest, AnnotatedDataset, LabelOperationMetadata>
labelImageOperationCallable() {
return labelImageOperationCallable;
}
@Override
public UnaryCallable<LabelVideoRequest, Operation> labelVideoCallable() {
return labelVideoCallable;
}
@Override
public OperationCallable<LabelVideoRequest, AnnotatedDataset, LabelOperationMetadata>
labelVideoOperationCallable() {
return labelVideoOperationCallable;
}
@Override
public UnaryCallable<LabelTextRequest, Operation> labelTextCallable() {
return labelTextCallable;
}
@Override
public OperationCallable<LabelTextRequest, AnnotatedDataset, LabelOperationMetadata>
labelTextOperationCallable() {
return labelTextOperationCallable;
}
@Override
public UnaryCallable<GetExampleRequest, Example> getExampleCallable() {
return getExampleCallable;
}
@Override
public UnaryCallable<ListExamplesRequest, ListExamplesResponse> listExamplesCallable() {
return listExamplesCallable;
}
@Override
public UnaryCallable<ListExamplesRequest, ListExamplesPagedResponse> listExamplesPagedCallable() {
return listExamplesPagedCallable;
}
@Override
public UnaryCallable<CreateAnnotationSpecSetRequest, AnnotationSpecSet>
createAnnotationSpecSetCallable() {
return createAnnotationSpecSetCallable;
}
@Override
public UnaryCallable<GetAnnotationSpecSetRequest, AnnotationSpecSet>
getAnnotationSpecSetCallable() {
return getAnnotationSpecSetCallable;
}
@Override
public UnaryCallable<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsResponse>
listAnnotationSpecSetsCallable() {
return listAnnotationSpecSetsCallable;
}
@Override
public UnaryCallable<ListAnnotationSpecSetsRequest, ListAnnotationSpecSetsPagedResponse>
listAnnotationSpecSetsPagedCallable() {
return listAnnotationSpecSetsPagedCallable;
}
@Override
public UnaryCallable<DeleteAnnotationSpecSetRequest, Empty> deleteAnnotationSpecSetCallable() {
return deleteAnnotationSpecSetCallable;
}
@Override
public UnaryCallable<CreateInstructionRequest, Operation> createInstructionCallable() {
return createInstructionCallable;
}
@Override
public OperationCallable<CreateInstructionRequest, Instruction, CreateInstructionMetadata>
createInstructionOperationCallable() {
return createInstructionOperationCallable;
}
@Override
public UnaryCallable<GetInstructionRequest, Instruction> getInstructionCallable() {
return getInstructionCallable;
}
@Override
public UnaryCallable<ListInstructionsRequest, ListInstructionsResponse>
listInstructionsCallable() {
return listInstructionsCallable;
}
@Override
public UnaryCallable<ListInstructionsRequest, ListInstructionsPagedResponse>
listInstructionsPagedCallable() {
return listInstructionsPagedCallable;
}
@Override
public UnaryCallable<DeleteInstructionRequest, Empty> deleteInstructionCallable() {
return deleteInstructionCallable;
}
@Override
public UnaryCallable<GetEvaluationRequest, Evaluation> getEvaluationCallable() {
return getEvaluationCallable;
}
@Override
public UnaryCallable<SearchEvaluationsRequest, SearchEvaluationsResponse>
searchEvaluationsCallable() {
return searchEvaluationsCallable;
}
@Override
public UnaryCallable<SearchEvaluationsRequest, SearchEvaluationsPagedResponse>
searchEvaluationsPagedCallable() {
return searchEvaluationsPagedCallable;
}
@Override
public UnaryCallable<SearchExampleComparisonsRequest, SearchExampleComparisonsResponse>
searchExampleComparisonsCallable() {
return searchExampleComparisonsCallable;
}
@Override
public UnaryCallable<SearchExampleComparisonsRequest, SearchExampleComparisonsPagedResponse>
searchExampleComparisonsPagedCallable() {
return searchExampleComparisonsPagedCallable;
}
@Override
public UnaryCallable<CreateEvaluationJobRequest, EvaluationJob> createEvaluationJobCallable() {
return createEvaluationJobCallable;
}
@Override
public UnaryCallable<UpdateEvaluationJobRequest, EvaluationJob> updateEvaluationJobCallable() {
return updateEvaluationJobCallable;
}
@Override
public UnaryCallable<GetEvaluationJobRequest, EvaluationJob> getEvaluationJobCallable() {
return getEvaluationJobCallable;
}
@Override
public UnaryCallable<PauseEvaluationJobRequest, Empty> pauseEvaluationJobCallable() {
return pauseEvaluationJobCallable;
}
@Override
public UnaryCallable<ResumeEvaluationJobRequest, Empty> resumeEvaluationJobCallable() {
return resumeEvaluationJobCallable;
}
@Override
public UnaryCallable<DeleteEvaluationJobRequest, Empty> deleteEvaluationJobCallable() {
return deleteEvaluationJobCallable;
}
@Override
public UnaryCallable<ListEvaluationJobsRequest, ListEvaluationJobsResponse>
listEvaluationJobsCallable() {
return listEvaluationJobsCallable;
}
@Override
public UnaryCallable<ListEvaluationJobsRequest, ListEvaluationJobsPagedResponse>
listEvaluationJobsPagedCallable() {
return listEvaluationJobsPagedCallable;
}
@Override
public final void close() {
try {
backgroundResources.close();
} catch (RuntimeException e) {
throw e;
} catch (Exception e) {
throw new IllegalStateException("Failed to close resource", e);
}
}
@Override
public void shutdown() {
backgroundResources.shutdown();
}
@Override
public boolean isShutdown() {
return backgroundResources.isShutdown();
}
@Override
public boolean isTerminated() {
return backgroundResources.isTerminated();
}
@Override
public void shutdownNow() {
backgroundResources.shutdownNow();
}
@Override
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
return backgroundResources.awaitTermination(duration, unit);
}
}