{
private RepositoryManagerBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected RepositoryManagerBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new RepositoryManagerBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a Connection.
*
*/
public com.google.longrunning.Operation createConnection(
com.google.cloudbuild.v2.CreateConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single connection.
*
*/
public com.google.cloudbuild.v2.Connection getConnection(
com.google.cloudbuild.v2.GetConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Connections in a given project and location.
*
*/
public com.google.cloudbuild.v2.ListConnectionsResponse listConnections(
com.google.cloudbuild.v2.ListConnectionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListConnectionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a single connection.
*
*/
public com.google.longrunning.Operation updateConnection(
com.google.cloudbuild.v2.UpdateConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single connection.
*
*/
public com.google.longrunning.Operation deleteConnection(
com.google.cloudbuild.v2.DeleteConnectionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteConnectionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a Repository.
*
*/
public com.google.longrunning.Operation createRepository(
com.google.cloudbuild.v2.CreateRepositoryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateRepositoryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates multiple repositories inside a connection.
*
*/
public com.google.longrunning.Operation batchCreateRepositories(
com.google.cloudbuild.v2.BatchCreateRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getBatchCreateRepositoriesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single repository.
*
*/
public com.google.cloudbuild.v2.Repository getRepository(
com.google.cloudbuild.v2.GetRepositoryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetRepositoryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Repositories in a given connection.
*
*/
public com.google.cloudbuild.v2.ListRepositoriesResponse listRepositories(
com.google.cloudbuild.v2.ListRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListRepositoriesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single repository.
*
*/
public com.google.longrunning.Operation deleteRepository(
com.google.cloudbuild.v2.DeleteRepositoryRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteRepositoryMethod(), getCallOptions(), request);
}
/**
*
*
*
* Fetches read/write token of a given repository.
*
*/
public com.google.cloudbuild.v2.FetchReadWriteTokenResponse fetchReadWriteToken(
com.google.cloudbuild.v2.FetchReadWriteTokenRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getFetchReadWriteTokenMethod(), getCallOptions(), request);
}
/**
*
*
*
* Fetches read token of a given repository.
*
*/
public com.google.cloudbuild.v2.FetchReadTokenResponse fetchReadToken(
com.google.cloudbuild.v2.FetchReadTokenRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getFetchReadTokenMethod(), getCallOptions(), request);
}
/**
*
*
*
* FetchLinkableRepositories get repositories from SCM that are
* accessible and could be added to the connection.
*
*/
public com.google.cloudbuild.v2.FetchLinkableRepositoriesResponse fetchLinkableRepositories(
com.google.cloudbuild.v2.FetchLinkableRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getFetchLinkableRepositoriesMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service RepositoryManager.
*
*
* Manages connections to source code repostiories.
*
*/
public static final class RepositoryManagerFutureStub
extends io.grpc.stub.AbstractFutureStub {
private RepositoryManagerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected RepositoryManagerFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new RepositoryManagerFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a Connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createConnection(com.google.cloudbuild.v2.CreateConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getConnection(com.google.cloudbuild.v2.GetConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Connections in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloudbuild.v2.ListConnectionsResponse>
listConnections(com.google.cloudbuild.v2.ListConnectionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListConnectionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a single connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateConnection(com.google.cloudbuild.v2.UpdateConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteConnection(com.google.cloudbuild.v2.DeleteConnectionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteConnectionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a Repository.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createRepository(com.google.cloudbuild.v2.CreateRepositoryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateRepositoryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates multiple repositories inside a connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture
batchCreateRepositories(com.google.cloudbuild.v2.BatchCreateRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getBatchCreateRepositoriesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single repository.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getRepository(com.google.cloudbuild.v2.GetRepositoryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetRepositoryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Repositories in a given connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloudbuild.v2.ListRepositoriesResponse>
listRepositories(com.google.cloudbuild.v2.ListRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListRepositoriesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single repository.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteRepository(com.google.cloudbuild.v2.DeleteRepositoryRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteRepositoryMethod(), getCallOptions()), request);
}
/**
*
*
*
* Fetches read/write token of a given repository.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloudbuild.v2.FetchReadWriteTokenResponse>
fetchReadWriteToken(com.google.cloudbuild.v2.FetchReadWriteTokenRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getFetchReadWriteTokenMethod(), getCallOptions()), request);
}
/**
*
*
*
* Fetches read token of a given repository.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloudbuild.v2.FetchReadTokenResponse>
fetchReadToken(com.google.cloudbuild.v2.FetchReadTokenRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getFetchReadTokenMethod(), getCallOptions()), request);
}
/**
*
*
*
* FetchLinkableRepositories get repositories from SCM that are
* accessible and could be added to the connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloudbuild.v2.FetchLinkableRepositoriesResponse>
fetchLinkableRepositories(
com.google.cloudbuild.v2.FetchLinkableRepositoriesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getFetchLinkableRepositoriesMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_CONNECTION = 0;
private static final int METHODID_GET_CONNECTION = 1;
private static final int METHODID_LIST_CONNECTIONS = 2;
private static final int METHODID_UPDATE_CONNECTION = 3;
private static final int METHODID_DELETE_CONNECTION = 4;
private static final int METHODID_CREATE_REPOSITORY = 5;
private static final int METHODID_BATCH_CREATE_REPOSITORIES = 6;
private static final int METHODID_GET_REPOSITORY = 7;
private static final int METHODID_LIST_REPOSITORIES = 8;
private static final int METHODID_DELETE_REPOSITORY = 9;
private static final int METHODID_FETCH_READ_WRITE_TOKEN = 10;
private static final int METHODID_FETCH_READ_TOKEN = 11;
private static final int METHODID_FETCH_LINKABLE_REPOSITORIES = 12;
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_CREATE_CONNECTION:
serviceImpl.createConnection(
(com.google.cloudbuild.v2.CreateConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_CONNECTION:
serviceImpl.getConnection(
(com.google.cloudbuild.v2.GetConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_CONNECTIONS:
serviceImpl.listConnections(
(com.google.cloudbuild.v2.ListConnectionsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_CONNECTION:
serviceImpl.updateConnection(
(com.google.cloudbuild.v2.UpdateConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_CONNECTION:
serviceImpl.deleteConnection(
(com.google.cloudbuild.v2.DeleteConnectionRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_REPOSITORY:
serviceImpl.createRepository(
(com.google.cloudbuild.v2.CreateRepositoryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_BATCH_CREATE_REPOSITORIES:
serviceImpl.batchCreateRepositories(
(com.google.cloudbuild.v2.BatchCreateRepositoriesRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_REPOSITORY:
serviceImpl.getRepository(
(com.google.cloudbuild.v2.GetRepositoryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_REPOSITORIES:
serviceImpl.listRepositories(
(com.google.cloudbuild.v2.ListRepositoriesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_REPOSITORY:
serviceImpl.deleteRepository(
(com.google.cloudbuild.v2.DeleteRepositoryRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_FETCH_READ_WRITE_TOKEN:
serviceImpl.fetchReadWriteToken(
(com.google.cloudbuild.v2.FetchReadWriteTokenRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_FETCH_READ_TOKEN:
serviceImpl.fetchReadToken(
(com.google.cloudbuild.v2.FetchReadTokenRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_FETCH_LINKABLE_REPOSITORIES:
serviceImpl.fetchLinkableRepositories(
(com.google.cloudbuild.v2.FetchLinkableRepositoriesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloudbuild.v2.FetchLinkableRepositoriesResponse>)
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(
getCreateConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.CreateConnectionRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CONNECTION)))
.addMethod(
getGetConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.GetConnectionRequest,
com.google.cloudbuild.v2.Connection>(service, METHODID_GET_CONNECTION)))
.addMethod(
getListConnectionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.ListConnectionsRequest,
com.google.cloudbuild.v2.ListConnectionsResponse>(
service, METHODID_LIST_CONNECTIONS)))
.addMethod(
getUpdateConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.UpdateConnectionRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_CONNECTION)))
.addMethod(
getDeleteConnectionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.DeleteConnectionRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CONNECTION)))
.addMethod(
getCreateRepositoryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.CreateRepositoryRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_REPOSITORY)))
.addMethod(
getBatchCreateRepositoriesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.BatchCreateRepositoriesRequest,
com.google.longrunning.Operation>(service, METHODID_BATCH_CREATE_REPOSITORIES)))
.addMethod(
getGetRepositoryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.GetRepositoryRequest,
com.google.cloudbuild.v2.Repository>(service, METHODID_GET_REPOSITORY)))
.addMethod(
getListRepositoriesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.ListRepositoriesRequest,
com.google.cloudbuild.v2.ListRepositoriesResponse>(
service, METHODID_LIST_REPOSITORIES)))
.addMethod(
getDeleteRepositoryMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.DeleteRepositoryRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_REPOSITORY)))
.addMethod(
getFetchReadWriteTokenMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.FetchReadWriteTokenRequest,
com.google.cloudbuild.v2.FetchReadWriteTokenResponse>(
service, METHODID_FETCH_READ_WRITE_TOKEN)))
.addMethod(
getFetchReadTokenMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.FetchReadTokenRequest,
com.google.cloudbuild.v2.FetchReadTokenResponse>(
service, METHODID_FETCH_READ_TOKEN)))
.addMethod(
getFetchLinkableRepositoriesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloudbuild.v2.FetchLinkableRepositoriesRequest,
com.google.cloudbuild.v2.FetchLinkableRepositoriesResponse>(
service, METHODID_FETCH_LINKABLE_REPOSITORIES)))
.build();
}
private abstract static class RepositoryManagerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
RepositoryManagerBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloudbuild.v2.RepositoryManagerProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("RepositoryManager");
}
}
private static final class RepositoryManagerFileDescriptorSupplier
extends RepositoryManagerBaseDescriptorSupplier {
RepositoryManagerFileDescriptorSupplier() {}
}
private static final class RepositoryManagerMethodDescriptorSupplier
extends RepositoryManagerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
RepositoryManagerMethodDescriptorSupplier(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 (RepositoryManagerGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new RepositoryManagerFileDescriptorSupplier())
.addMethod(getCreateConnectionMethod())
.addMethod(getGetConnectionMethod())
.addMethod(getListConnectionsMethod())
.addMethod(getUpdateConnectionMethod())
.addMethod(getDeleteConnectionMethod())
.addMethod(getCreateRepositoryMethod())
.addMethod(getBatchCreateRepositoriesMethod())
.addMethod(getGetRepositoryMethod())
.addMethod(getListRepositoriesMethod())
.addMethod(getDeleteRepositoryMethod())
.addMethod(getFetchReadWriteTokenMethod())
.addMethod(getFetchReadTokenMethod())
.addMethod(getFetchLinkableRepositoriesMethod())
.build();
}
}
}
return result;
}
}