{
private EventarcBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected EventarcBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new EventarcBlockingStub(channel, callOptions);
}
/**
*
*
*
* Get a single trigger.
*
*/
public com.google.cloud.eventarc.v1.Trigger getTrigger(
com.google.cloud.eventarc.v1.GetTriggerRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetTriggerMethod(), getCallOptions(), request);
}
/**
*
*
*
* List triggers.
*
*/
public com.google.cloud.eventarc.v1.ListTriggersResponse listTriggers(
com.google.cloud.eventarc.v1.ListTriggersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTriggersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Create a new trigger in a particular project and location.
*
*/
public com.google.longrunning.Operation createTrigger(
com.google.cloud.eventarc.v1.CreateTriggerRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateTriggerMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update a single trigger.
*
*/
public com.google.longrunning.Operation updateTrigger(
com.google.cloud.eventarc.v1.UpdateTriggerRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateTriggerMethod(), getCallOptions(), request);
}
/**
*
*
*
* Delete a single trigger.
*
*/
public com.google.longrunning.Operation deleteTrigger(
com.google.cloud.eventarc.v1.DeleteTriggerRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteTriggerMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get a single Channel.
*
*/
public com.google.cloud.eventarc.v1.Channel getChannel(
com.google.cloud.eventarc.v1.GetChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* List channels.
*
*/
public com.google.cloud.eventarc.v1.ListChannelsResponse listChannels(
com.google.cloud.eventarc.v1.ListChannelsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListChannelsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Create a new channel in a particular project and location.
*
*/
public com.google.longrunning.Operation createChannel(
com.google.cloud.eventarc.v1.CreateChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update a single channel.
*
*/
public com.google.longrunning.Operation updateChannel(
com.google.cloud.eventarc.v1.UpdateChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Delete a single channel.
*
*/
public com.google.longrunning.Operation deleteChannel(
com.google.cloud.eventarc.v1.DeleteChannelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteChannelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get a single Provider.
*
*/
public com.google.cloud.eventarc.v1.Provider getProvider(
com.google.cloud.eventarc.v1.GetProviderRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetProviderMethod(), getCallOptions(), request);
}
/**
*
*
*
* List providers.
*
*/
public com.google.cloud.eventarc.v1.ListProvidersResponse listProviders(
com.google.cloud.eventarc.v1.ListProvidersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListProvidersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get a single ChannelConnection.
*
*/
public com.google.cloud.eventarc.v1.ChannelConnection getChannelConnection(
com.google.cloud.eventarc.v1.GetChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetChannelConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* List channel connections.
*
*/
public com.google.cloud.eventarc.v1.ListChannelConnectionsResponse listChannelConnections(
com.google.cloud.eventarc.v1.ListChannelConnectionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListChannelConnectionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Create a new ChannelConnection in a particular project and location.
*
*/
public com.google.longrunning.Operation createChannelConnection(
com.google.cloud.eventarc.v1.CreateChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateChannelConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Delete a single ChannelConnection.
*
*/
public com.google.longrunning.Operation deleteChannelConnection(
com.google.cloud.eventarc.v1.DeleteChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteChannelConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get a GoogleChannelConfig
*
*/
public com.google.cloud.eventarc.v1.GoogleChannelConfig getGoogleChannelConfig(
com.google.cloud.eventarc.v1.GetGoogleChannelConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetGoogleChannelConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update a single GoogleChannelConfig
*
*/
public com.google.cloud.eventarc.v1.GoogleChannelConfig updateGoogleChannelConfig(
com.google.cloud.eventarc.v1.UpdateGoogleChannelConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateGoogleChannelConfigMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Eventarc.
*
*
* Eventarc allows users to subscribe to various events that are provided by
* Google Cloud services and forward them to supported destinations.
*
*/
public static final class EventarcFutureStub
extends io.grpc.stub.AbstractFutureStub {
private EventarcFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected EventarcFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new EventarcFutureStub(channel, callOptions);
}
/**
*
*
*
* Get a single trigger.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getTrigger(com.google.cloud.eventarc.v1.GetTriggerRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetTriggerMethod(), getCallOptions()), request);
}
/**
*
*
*
* List triggers.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.ListTriggersResponse>
listTriggers(com.google.cloud.eventarc.v1.ListTriggersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTriggersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Create a new trigger in a particular project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createTrigger(com.google.cloud.eventarc.v1.CreateTriggerRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateTriggerMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update a single trigger.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateTrigger(com.google.cloud.eventarc.v1.UpdateTriggerRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateTriggerMethod(), getCallOptions()), request);
}
/**
*
*
*
* Delete a single trigger.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteTrigger(com.google.cloud.eventarc.v1.DeleteTriggerRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTriggerMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get a single Channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getChannel(com.google.cloud.eventarc.v1.GetChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* List channels.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.ListChannelsResponse>
listChannels(com.google.cloud.eventarc.v1.ListChannelsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListChannelsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Create a new channel in a particular project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createChannel(com.google.cloud.eventarc.v1.CreateChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update a single channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateChannel(com.google.cloud.eventarc.v1.UpdateChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Delete a single channel.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteChannel(com.google.cloud.eventarc.v1.DeleteChannelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteChannelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get a single Provider.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getProvider(com.google.cloud.eventarc.v1.GetProviderRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetProviderMethod(), getCallOptions()), request);
}
/**
*
*
*
* List providers.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.ListProvidersResponse>
listProviders(com.google.cloud.eventarc.v1.ListProvidersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListProvidersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get a single ChannelConnection.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.ChannelConnection>
getChannelConnection(com.google.cloud.eventarc.v1.GetChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetChannelConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* List channel connections.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.ListChannelConnectionsResponse>
listChannelConnections(com.google.cloud.eventarc.v1.ListChannelConnectionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListChannelConnectionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Create a new ChannelConnection in a particular project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createChannelConnection(
com.google.cloud.eventarc.v1.CreateChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateChannelConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Delete a single ChannelConnection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteChannelConnection(
com.google.cloud.eventarc.v1.DeleteChannelConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteChannelConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get a GoogleChannelConfig
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.GoogleChannelConfig>
getGoogleChannelConfig(com.google.cloud.eventarc.v1.GetGoogleChannelConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetGoogleChannelConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update a single GoogleChannelConfig
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.eventarc.v1.GoogleChannelConfig>
updateGoogleChannelConfig(
com.google.cloud.eventarc.v1.UpdateGoogleChannelConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateGoogleChannelConfigMethod(), getCallOptions()), request);
}
}
private static final int METHODID_GET_TRIGGER = 0;
private static final int METHODID_LIST_TRIGGERS = 1;
private static final int METHODID_CREATE_TRIGGER = 2;
private static final int METHODID_UPDATE_TRIGGER = 3;
private static final int METHODID_DELETE_TRIGGER = 4;
private static final int METHODID_GET_CHANNEL = 5;
private static final int METHODID_LIST_CHANNELS = 6;
private static final int METHODID_CREATE_CHANNEL = 7;
private static final int METHODID_UPDATE_CHANNEL = 8;
private static final int METHODID_DELETE_CHANNEL = 9;
private static final int METHODID_GET_PROVIDER = 10;
private static final int METHODID_LIST_PROVIDERS = 11;
private static final int METHODID_GET_CHANNEL_CONNECTION = 12;
private static final int METHODID_LIST_CHANNEL_CONNECTIONS = 13;
private static final int METHODID_CREATE_CHANNEL_CONNECTION = 14;
private static final int METHODID_DELETE_CHANNEL_CONNECTION = 15;
private static final int METHODID_GET_GOOGLE_CHANNEL_CONFIG = 16;
private static final int METHODID_UPDATE_GOOGLE_CHANNEL_CONFIG = 17;
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_GET_TRIGGER:
serviceImpl.getTrigger(
(com.google.cloud.eventarc.v1.GetTriggerRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TRIGGERS:
serviceImpl.listTriggers(
(com.google.cloud.eventarc.v1.ListTriggersRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_TRIGGER:
serviceImpl.createTrigger(
(com.google.cloud.eventarc.v1.CreateTriggerRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_TRIGGER:
serviceImpl.updateTrigger(
(com.google.cloud.eventarc.v1.UpdateTriggerRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_TRIGGER:
serviceImpl.deleteTrigger(
(com.google.cloud.eventarc.v1.DeleteTriggerRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_CHANNEL:
serviceImpl.getChannel(
(com.google.cloud.eventarc.v1.GetChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_CHANNELS:
serviceImpl.listChannels(
(com.google.cloud.eventarc.v1.ListChannelsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_CHANNEL:
serviceImpl.createChannel(
(com.google.cloud.eventarc.v1.CreateChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_CHANNEL:
serviceImpl.updateChannel(
(com.google.cloud.eventarc.v1.UpdateChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_CHANNEL:
serviceImpl.deleteChannel(
(com.google.cloud.eventarc.v1.DeleteChannelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_PROVIDER:
serviceImpl.getProvider(
(com.google.cloud.eventarc.v1.GetProviderRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_PROVIDERS:
serviceImpl.listProviders(
(com.google.cloud.eventarc.v1.ListProvidersRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_CHANNEL_CONNECTION:
serviceImpl.getChannelConnection(
(com.google.cloud.eventarc.v1.GetChannelConnectionRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_CHANNEL_CONNECTIONS:
serviceImpl.listChannelConnections(
(com.google.cloud.eventarc.v1.ListChannelConnectionsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.eventarc.v1.ListChannelConnectionsResponse>)
responseObserver);
break;
case METHODID_CREATE_CHANNEL_CONNECTION:
serviceImpl.createChannelConnection(
(com.google.cloud.eventarc.v1.CreateChannelConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_CHANNEL_CONNECTION:
serviceImpl.deleteChannelConnection(
(com.google.cloud.eventarc.v1.DeleteChannelConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_GOOGLE_CHANNEL_CONFIG:
serviceImpl.getGoogleChannelConfig(
(com.google.cloud.eventarc.v1.GetGoogleChannelConfigRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_GOOGLE_CHANNEL_CONFIG:
serviceImpl.updateGoogleChannelConfig(
(com.google.cloud.eventarc.v1.UpdateGoogleChannelConfigRequest) 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(
getGetTriggerMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.GetTriggerRequest,
com.google.cloud.eventarc.v1.Trigger>(service, METHODID_GET_TRIGGER)))
.addMethod(
getListTriggersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.ListTriggersRequest,
com.google.cloud.eventarc.v1.ListTriggersResponse>(
service, METHODID_LIST_TRIGGERS)))
.addMethod(
getCreateTriggerMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.CreateTriggerRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_TRIGGER)))
.addMethod(
getUpdateTriggerMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.UpdateTriggerRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_TRIGGER)))
.addMethod(
getDeleteTriggerMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.DeleteTriggerRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_TRIGGER)))
.addMethod(
getGetChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.GetChannelRequest,
com.google.cloud.eventarc.v1.Channel>(service, METHODID_GET_CHANNEL)))
.addMethod(
getListChannelsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.ListChannelsRequest,
com.google.cloud.eventarc.v1.ListChannelsResponse>(
service, METHODID_LIST_CHANNELS)))
.addMethod(
getCreateChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.CreateChannelRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CHANNEL)))
.addMethod(
getUpdateChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.UpdateChannelRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_CHANNEL)))
.addMethod(
getDeleteChannelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.DeleteChannelRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CHANNEL)))
.addMethod(
getGetProviderMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.GetProviderRequest,
com.google.cloud.eventarc.v1.Provider>(service, METHODID_GET_PROVIDER)))
.addMethod(
getListProvidersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.ListProvidersRequest,
com.google.cloud.eventarc.v1.ListProvidersResponse>(
service, METHODID_LIST_PROVIDERS)))
.addMethod(
getGetChannelConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.GetChannelConnectionRequest,
com.google.cloud.eventarc.v1.ChannelConnection>(
service, METHODID_GET_CHANNEL_CONNECTION)))
.addMethod(
getListChannelConnectionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.ListChannelConnectionsRequest,
com.google.cloud.eventarc.v1.ListChannelConnectionsResponse>(
service, METHODID_LIST_CHANNEL_CONNECTIONS)))
.addMethod(
getCreateChannelConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.CreateChannelConnectionRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CHANNEL_CONNECTION)))
.addMethod(
getDeleteChannelConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.DeleteChannelConnectionRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CHANNEL_CONNECTION)))
.addMethod(
getGetGoogleChannelConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.GetGoogleChannelConfigRequest,
com.google.cloud.eventarc.v1.GoogleChannelConfig>(
service, METHODID_GET_GOOGLE_CHANNEL_CONFIG)))
.addMethod(
getUpdateGoogleChannelConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.eventarc.v1.UpdateGoogleChannelConfigRequest,
com.google.cloud.eventarc.v1.GoogleChannelConfig>(
service, METHODID_UPDATE_GOOGLE_CHANNEL_CONFIG)))
.build();
}
private abstract static class EventarcBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
EventarcBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.eventarc.v1.EventarcProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Eventarc");
}
}
private static final class EventarcFileDescriptorSupplier extends EventarcBaseDescriptorSupplier {
EventarcFileDescriptorSupplier() {}
}
private static final class EventarcMethodDescriptorSupplier extends EventarcBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
EventarcMethodDescriptorSupplier(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 (EventarcGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new EventarcFileDescriptorSupplier())
.addMethod(getGetTriggerMethod())
.addMethod(getListTriggersMethod())
.addMethod(getCreateTriggerMethod())
.addMethod(getUpdateTriggerMethod())
.addMethod(getDeleteTriggerMethod())
.addMethod(getGetChannelMethod())
.addMethod(getListChannelsMethod())
.addMethod(getCreateChannelMethod())
.addMethod(getUpdateChannelMethod())
.addMethod(getDeleteChannelMethod())
.addMethod(getGetProviderMethod())
.addMethod(getListProvidersMethod())
.addMethod(getGetChannelConnectionMethod())
.addMethod(getListChannelConnectionsMethod())
.addMethod(getCreateChannelConnectionMethod())
.addMethod(getDeleteChannelConnectionMethod())
.addMethod(getGetGoogleChannelConfigMethod())
.addMethod(getUpdateGoogleChannelConfigMethod())
.build();
}
}
}
return result;
}
}