{
private AnalyticsHubServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AnalyticsHubServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AnalyticsHubServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists all data exchanges in a given project and location.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesResponse
listDataExchanges(
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDataExchangesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all data exchanges from projects in a given organization and
* location.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesResponse
listOrgDataExchanges(
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListOrgDataExchangesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the details of a data exchange.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange getDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.GetDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetDataExchangeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new data exchange.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange createDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.CreateDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateDataExchangeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing data exchange.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange updateDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.UpdateDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateDataExchangeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes an existing data exchange.
*
*/
public com.google.protobuf.Empty deleteDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.DeleteDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteDataExchangeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all listings in a given project and location.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsResponse listListings(
com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListListingsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the details of a listing.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.Listing getListing(
com.google.cloud.bigquery.dataexchange.v1beta1.GetListingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetListingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new listing.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.Listing createListing(
com.google.cloud.bigquery.dataexchange.v1beta1.CreateListingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateListingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing listing.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.Listing updateListing(
com.google.cloud.bigquery.dataexchange.v1beta1.UpdateListingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateListingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a listing.
*
*/
public com.google.protobuf.Empty deleteListing(
com.google.cloud.bigquery.dataexchange.v1beta1.DeleteListingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteListingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Subscribes to a listing.
* Currently, with Analytics Hub, you can create listings that
* reference only BigQuery datasets.
* Upon subscription to a listing for a BigQuery dataset, Analytics Hub
* creates a linked dataset in the subscriber's project.
*
*/
public com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingResponse subscribeListing(
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSubscribeListingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the IAM policy.
*
*/
public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetIamPolicyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the IAM policy.
*
*/
public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetIamPolicyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the permissions that a caller has.
*
*/
public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(
com.google.iam.v1.TestIamPermissionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service AnalyticsHubService.
*
*
* The `AnalyticsHubService` API facilitates data sharing within and across
* organizations. It allows data providers to publish listings that reference
* shared datasets. With Analytics Hub, users can discover and search for
* listings that they have access to. Subscribers can view and subscribe to
* listings. When you subscribe to a listing, Analytics Hub creates a linked
* dataset in your project.
*
*/
public static final class AnalyticsHubServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private AnalyticsHubServiceFutureStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AnalyticsHubServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AnalyticsHubServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists all data exchanges in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesResponse>
listDataExchanges(
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDataExchangesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all data exchanges from projects in a given organization and
* location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesResponse>
listOrgDataExchanges(
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListOrgDataExchangesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the details of a data exchange.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>
getDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.GetDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetDataExchangeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new data exchange.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>
createDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.CreateDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateDataExchangeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an existing data exchange.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>
updateDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.UpdateDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateDataExchangeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes an existing data exchange.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteDataExchange(
com.google.cloud.bigquery.dataexchange.v1beta1.DeleteDataExchangeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteDataExchangeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all listings in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsResponse>
listListings(com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListListingsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the details of a listing.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>
getListing(com.google.cloud.bigquery.dataexchange.v1beta1.GetListingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetListingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new listing.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>
createListing(com.google.cloud.bigquery.dataexchange.v1beta1.CreateListingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateListingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an existing listing.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>
updateListing(com.google.cloud.bigquery.dataexchange.v1beta1.UpdateListingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateListingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a listing.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteListing(com.google.cloud.bigquery.dataexchange.v1beta1.DeleteListingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteListingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Subscribes to a listing.
* Currently, with Analytics Hub, you can create listings that
* reference only BigQuery datasets.
* Upon subscription to a listing for a BigQuery dataset, Analytics Hub
* creates a linked dataset in the subscriber's project.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingResponse>
subscribeListing(
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSubscribeListingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the IAM policy.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetIamPolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the IAM policy.
*
*/
public com.google.common.util.concurrent.ListenableFuture
setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetIamPolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the permissions that a caller has.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.iam.v1.TestIamPermissionsResponse>
testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTestIamPermissionsMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_DATA_EXCHANGES = 0;
private static final int METHODID_LIST_ORG_DATA_EXCHANGES = 1;
private static final int METHODID_GET_DATA_EXCHANGE = 2;
private static final int METHODID_CREATE_DATA_EXCHANGE = 3;
private static final int METHODID_UPDATE_DATA_EXCHANGE = 4;
private static final int METHODID_DELETE_DATA_EXCHANGE = 5;
private static final int METHODID_LIST_LISTINGS = 6;
private static final int METHODID_GET_LISTING = 7;
private static final int METHODID_CREATE_LISTING = 8;
private static final int METHODID_UPDATE_LISTING = 9;
private static final int METHODID_DELETE_LISTING = 10;
private static final int METHODID_SUBSCRIBE_LISTING = 11;
private static final int METHODID_GET_IAM_POLICY = 12;
private static final int METHODID_SET_IAM_POLICY = 13;
private static final int METHODID_TEST_IAM_PERMISSIONS = 14;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_LIST_DATA_EXCHANGES:
serviceImpl.listDataExchanges(
(com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesResponse>)
responseObserver);
break;
case METHODID_LIST_ORG_DATA_EXCHANGES:
serviceImpl.listOrgDataExchanges(
(com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesResponse>)
responseObserver);
break;
case METHODID_GET_DATA_EXCHANGE:
serviceImpl.getDataExchange(
(com.google.cloud.bigquery.dataexchange.v1beta1.GetDataExchangeRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>)
responseObserver);
break;
case METHODID_CREATE_DATA_EXCHANGE:
serviceImpl.createDataExchange(
(com.google.cloud.bigquery.dataexchange.v1beta1.CreateDataExchangeRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>)
responseObserver);
break;
case METHODID_UPDATE_DATA_EXCHANGE:
serviceImpl.updateDataExchange(
(com.google.cloud.bigquery.dataexchange.v1beta1.UpdateDataExchangeRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>)
responseObserver);
break;
case METHODID_DELETE_DATA_EXCHANGE:
serviceImpl.deleteDataExchange(
(com.google.cloud.bigquery.dataexchange.v1beta1.DeleteDataExchangeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_LISTINGS:
serviceImpl.listListings(
(com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsResponse>)
responseObserver);
break;
case METHODID_GET_LISTING:
serviceImpl.getListing(
(com.google.cloud.bigquery.dataexchange.v1beta1.GetListingRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_LISTING:
serviceImpl.createListing(
(com.google.cloud.bigquery.dataexchange.v1beta1.CreateListingRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_LISTING:
serviceImpl.updateListing(
(com.google.cloud.bigquery.dataexchange.v1beta1.UpdateListingRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_LISTING:
serviceImpl.deleteListing(
(com.google.cloud.bigquery.dataexchange.v1beta1.DeleteListingRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_SUBSCRIBE_LISTING:
serviceImpl.subscribeListing(
(com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingResponse>)
responseObserver);
break;
case METHODID_GET_IAM_POLICY:
serviceImpl.getIamPolicy(
(com.google.iam.v1.GetIamPolicyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_SET_IAM_POLICY:
serviceImpl.setIamPolicy(
(com.google.iam.v1.SetIamPolicyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_TEST_IAM_PERMISSIONS:
serviceImpl.testIamPermissions(
(com.google.iam.v1.TestIamPermissionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListDataExchangesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.ListDataExchangesResponse>(
service, METHODID_LIST_DATA_EXCHANGES)))
.addMethod(
getListOrgDataExchangesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.ListOrgDataExchangesResponse>(
service, METHODID_LIST_ORG_DATA_EXCHANGES)))
.addMethod(
getGetDataExchangeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.GetDataExchangeRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>(
service, METHODID_GET_DATA_EXCHANGE)))
.addMethod(
getCreateDataExchangeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.CreateDataExchangeRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>(
service, METHODID_CREATE_DATA_EXCHANGE)))
.addMethod(
getUpdateDataExchangeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.UpdateDataExchangeRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.DataExchange>(
service, METHODID_UPDATE_DATA_EXCHANGE)))
.addMethod(
getDeleteDataExchangeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.DeleteDataExchangeRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_DATA_EXCHANGE)))
.addMethod(
getListListingsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.ListListingsResponse>(
service, METHODID_LIST_LISTINGS)))
.addMethod(
getGetListingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.GetListingRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>(
service, METHODID_GET_LISTING)))
.addMethod(
getCreateListingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.CreateListingRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>(
service, METHODID_CREATE_LISTING)))
.addMethod(
getUpdateListingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.UpdateListingRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.Listing>(
service, METHODID_UPDATE_LISTING)))
.addMethod(
getDeleteListingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.DeleteListingRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_LISTING)))
.addMethod(
getSubscribeListingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingRequest,
com.google.cloud.bigquery.dataexchange.v1beta1.SubscribeListingResponse>(
service, METHODID_SUBSCRIBE_LISTING)))
.addMethod(
getGetIamPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers(
service, METHODID_GET_IAM_POLICY)))
.addMethod(
getSetIamPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers(
service, METHODID_SET_IAM_POLICY)))
.addMethod(
getTestIamPermissionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v1.TestIamPermissionsRequest,
com.google.iam.v1.TestIamPermissionsResponse>(
service, METHODID_TEST_IAM_PERMISSIONS)))
.build();
}
private abstract static class AnalyticsHubServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
AnalyticsHubServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.bigquery.dataexchange.v1beta1.DataExchangeProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("AnalyticsHubService");
}
}
private static final class AnalyticsHubServiceFileDescriptorSupplier
extends AnalyticsHubServiceBaseDescriptorSupplier {
AnalyticsHubServiceFileDescriptorSupplier() {}
}
private static final class AnalyticsHubServiceMethodDescriptorSupplier
extends AnalyticsHubServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
AnalyticsHubServiceMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (AnalyticsHubServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new AnalyticsHubServiceFileDescriptorSupplier())
.addMethod(getListDataExchangesMethod())
.addMethod(getListOrgDataExchangesMethod())
.addMethod(getGetDataExchangeMethod())
.addMethod(getCreateDataExchangeMethod())
.addMethod(getUpdateDataExchangeMethod())
.addMethod(getDeleteDataExchangeMethod())
.addMethod(getListListingsMethod())
.addMethod(getGetListingMethod())
.addMethod(getCreateListingMethod())
.addMethod(getUpdateListingMethod())
.addMethod(getDeleteListingMethod())
.addMethod(getSubscribeListingMethod())
.addMethod(getGetIamPolicyMethod())
.addMethod(getSetIamPolicyMethod())
.addMethod(getTestIamPermissionsMethod())
.build();
}
}
}
return result;
}
}