{
private CloudDeployBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudDeployBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudDeployBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists DeliveryPipelines in a given project and location.
*
*/
public com.google.cloud.deploy.v1.ListDeliveryPipelinesResponse listDeliveryPipelines(
com.google.cloud.deploy.v1.ListDeliveryPipelinesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListDeliveryPipelinesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single DeliveryPipeline.
*
*/
public com.google.cloud.deploy.v1.DeliveryPipeline getDeliveryPipeline(
com.google.cloud.deploy.v1.GetDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetDeliveryPipelineMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new DeliveryPipeline in a given project and location.
*
*/
public com.google.longrunning.Operation createDeliveryPipeline(
com.google.cloud.deploy.v1.CreateDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateDeliveryPipelineMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single DeliveryPipeline.
*
*/
public com.google.longrunning.Operation updateDeliveryPipeline(
com.google.cloud.deploy.v1.UpdateDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateDeliveryPipelineMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single DeliveryPipeline.
*
*/
public com.google.longrunning.Operation deleteDeliveryPipeline(
com.google.cloud.deploy.v1.DeleteDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteDeliveryPipelineMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Targets in a given project and location.
*
*/
public com.google.cloud.deploy.v1.ListTargetsResponse listTargets(
com.google.cloud.deploy.v1.ListTargetsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTargetsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Target.
*
*/
public com.google.cloud.deploy.v1.Target getTarget(
com.google.cloud.deploy.v1.GetTargetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetTargetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Target in a given project and location.
*
*/
public com.google.longrunning.Operation createTarget(
com.google.cloud.deploy.v1.CreateTargetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateTargetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single Target.
*
*/
public com.google.longrunning.Operation updateTarget(
com.google.cloud.deploy.v1.UpdateTargetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateTargetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Target.
*
*/
public com.google.longrunning.Operation deleteTarget(
com.google.cloud.deploy.v1.DeleteTargetRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteTargetMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Releases in a given project and location.
*
*/
public com.google.cloud.deploy.v1.ListReleasesResponse listReleases(
com.google.cloud.deploy.v1.ListReleasesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListReleasesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Release.
*
*/
public com.google.cloud.deploy.v1.Release getRelease(
com.google.cloud.deploy.v1.GetReleaseRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetReleaseMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Release in a given project and location.
*
*/
public com.google.longrunning.Operation createRelease(
com.google.cloud.deploy.v1.CreateReleaseRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateReleaseMethod(), getCallOptions(), request);
}
/**
*
*
*
* Abandons a Release in the Delivery Pipeline.
*
*/
public com.google.cloud.deploy.v1.AbandonReleaseResponse abandonRelease(
com.google.cloud.deploy.v1.AbandonReleaseRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAbandonReleaseMethod(), getCallOptions(), request);
}
/**
*
*
*
* Approves a Rollout.
*
*/
public com.google.cloud.deploy.v1.ApproveRolloutResponse approveRollout(
com.google.cloud.deploy.v1.ApproveRolloutRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getApproveRolloutMethod(), getCallOptions(), request);
}
/**
*
*
*
* Advances a Rollout in a given project and location.
*
*/
public com.google.cloud.deploy.v1.AdvanceRolloutResponse advanceRollout(
com.google.cloud.deploy.v1.AdvanceRolloutRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAdvanceRolloutMethod(), getCallOptions(), request);
}
/**
*
*
*
* Cancels a Rollout in a given project and location.
*
*/
public com.google.cloud.deploy.v1.CancelRolloutResponse cancelRollout(
com.google.cloud.deploy.v1.CancelRolloutRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCancelRolloutMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Rollouts in a given project and location.
*
*/
public com.google.cloud.deploy.v1.ListRolloutsResponse listRollouts(
com.google.cloud.deploy.v1.ListRolloutsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListRolloutsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Rollout.
*
*/
public com.google.cloud.deploy.v1.Rollout getRollout(
com.google.cloud.deploy.v1.GetRolloutRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetRolloutMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Rollout in a given project and location.
*
*/
public com.google.longrunning.Operation createRollout(
com.google.cloud.deploy.v1.CreateRolloutRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateRolloutMethod(), getCallOptions(), request);
}
/**
*
*
*
* Ignores the specified Job in a Rollout.
*
*/
public com.google.cloud.deploy.v1.IgnoreJobResponse ignoreJob(
com.google.cloud.deploy.v1.IgnoreJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getIgnoreJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retries the specified Job in a Rollout.
*
*/
public com.google.cloud.deploy.v1.RetryJobResponse retryJob(
com.google.cloud.deploy.v1.RetryJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRetryJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists JobRuns in a given project and location.
*
*/
public com.google.cloud.deploy.v1.ListJobRunsResponse listJobRuns(
com.google.cloud.deploy.v1.ListJobRunsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListJobRunsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single JobRun.
*
*/
public com.google.cloud.deploy.v1.JobRun getJobRun(
com.google.cloud.deploy.v1.GetJobRunRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetJobRunMethod(), getCallOptions(), request);
}
/**
*
*
*
* Terminates a Job Run in a given project and location.
*
*/
public com.google.cloud.deploy.v1.TerminateJobRunResponse terminateJobRun(
com.google.cloud.deploy.v1.TerminateJobRunRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTerminateJobRunMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the configuration for a location.
*
*/
public com.google.cloud.deploy.v1.Config getConfig(
com.google.cloud.deploy.v1.GetConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetConfigMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service CloudDeploy.
*
*
* CloudDeploy service creates and manages Continuous Delivery operations
* on Google Cloud Platform via Skaffold (https://skaffold.dev).
*
*/
public static final class CloudDeployFutureStub
extends io.grpc.stub.AbstractFutureStub {
private CloudDeployFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudDeployFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudDeployFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists DeliveryPipelines in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ListDeliveryPipelinesResponse>
listDeliveryPipelines(com.google.cloud.deploy.v1.ListDeliveryPipelinesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListDeliveryPipelinesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single DeliveryPipeline.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.DeliveryPipeline>
getDeliveryPipeline(com.google.cloud.deploy.v1.GetDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetDeliveryPipelineMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new DeliveryPipeline in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createDeliveryPipeline(com.google.cloud.deploy.v1.CreateDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateDeliveryPipelineMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single DeliveryPipeline.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateDeliveryPipeline(com.google.cloud.deploy.v1.UpdateDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateDeliveryPipelineMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single DeliveryPipeline.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteDeliveryPipeline(com.google.cloud.deploy.v1.DeleteDeliveryPipelineRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteDeliveryPipelineMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Targets in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ListTargetsResponse>
listTargets(com.google.cloud.deploy.v1.ListTargetsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTargetsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Target.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getTarget(com.google.cloud.deploy.v1.GetTargetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetTargetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Target in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createTarget(com.google.cloud.deploy.v1.CreateTargetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateTargetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single Target.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateTarget(com.google.cloud.deploy.v1.UpdateTargetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateTargetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Target.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteTarget(com.google.cloud.deploy.v1.DeleteTargetRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTargetMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Releases in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ListReleasesResponse>
listReleases(com.google.cloud.deploy.v1.ListReleasesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListReleasesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Release.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getRelease(com.google.cloud.deploy.v1.GetReleaseRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetReleaseMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Release in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createRelease(com.google.cloud.deploy.v1.CreateReleaseRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateReleaseMethod(), getCallOptions()), request);
}
/**
*
*
*
* Abandons a Release in the Delivery Pipeline.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.AbandonReleaseResponse>
abandonRelease(com.google.cloud.deploy.v1.AbandonReleaseRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAbandonReleaseMethod(), getCallOptions()), request);
}
/**
*
*
*
* Approves a Rollout.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ApproveRolloutResponse>
approveRollout(com.google.cloud.deploy.v1.ApproveRolloutRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getApproveRolloutMethod(), getCallOptions()), request);
}
/**
*
*
*
* Advances a Rollout in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.AdvanceRolloutResponse>
advanceRollout(com.google.cloud.deploy.v1.AdvanceRolloutRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAdvanceRolloutMethod(), getCallOptions()), request);
}
/**
*
*
*
* Cancels a Rollout in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.CancelRolloutResponse>
cancelRollout(com.google.cloud.deploy.v1.CancelRolloutRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCancelRolloutMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Rollouts in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ListRolloutsResponse>
listRollouts(com.google.cloud.deploy.v1.ListRolloutsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListRolloutsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Rollout.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getRollout(com.google.cloud.deploy.v1.GetRolloutRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetRolloutMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Rollout in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createRollout(com.google.cloud.deploy.v1.CreateRolloutRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateRolloutMethod(), getCallOptions()), request);
}
/**
*
*
*
* Ignores the specified Job in a Rollout.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.IgnoreJobResponse>
ignoreJob(com.google.cloud.deploy.v1.IgnoreJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getIgnoreJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retries the specified Job in a Rollout.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.RetryJobResponse>
retryJob(com.google.cloud.deploy.v1.RetryJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRetryJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists JobRuns in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.ListJobRunsResponse>
listJobRuns(com.google.cloud.deploy.v1.ListJobRunsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListJobRunsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single JobRun.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getJobRun(com.google.cloud.deploy.v1.GetJobRunRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetJobRunMethod(), getCallOptions()), request);
}
/**
*
*
*
* Terminates a Job Run in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.deploy.v1.TerminateJobRunResponse>
terminateJobRun(com.google.cloud.deploy.v1.TerminateJobRunRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTerminateJobRunMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the configuration for a location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getConfig(com.google.cloud.deploy.v1.GetConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetConfigMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_DELIVERY_PIPELINES = 0;
private static final int METHODID_GET_DELIVERY_PIPELINE = 1;
private static final int METHODID_CREATE_DELIVERY_PIPELINE = 2;
private static final int METHODID_UPDATE_DELIVERY_PIPELINE = 3;
private static final int METHODID_DELETE_DELIVERY_PIPELINE = 4;
private static final int METHODID_LIST_TARGETS = 5;
private static final int METHODID_GET_TARGET = 6;
private static final int METHODID_CREATE_TARGET = 7;
private static final int METHODID_UPDATE_TARGET = 8;
private static final int METHODID_DELETE_TARGET = 9;
private static final int METHODID_LIST_RELEASES = 10;
private static final int METHODID_GET_RELEASE = 11;
private static final int METHODID_CREATE_RELEASE = 12;
private static final int METHODID_ABANDON_RELEASE = 13;
private static final int METHODID_APPROVE_ROLLOUT = 14;
private static final int METHODID_ADVANCE_ROLLOUT = 15;
private static final int METHODID_CANCEL_ROLLOUT = 16;
private static final int METHODID_LIST_ROLLOUTS = 17;
private static final int METHODID_GET_ROLLOUT = 18;
private static final int METHODID_CREATE_ROLLOUT = 19;
private static final int METHODID_IGNORE_JOB = 20;
private static final int METHODID_RETRY_JOB = 21;
private static final int METHODID_LIST_JOB_RUNS = 22;
private static final int METHODID_GET_JOB_RUN = 23;
private static final int METHODID_TERMINATE_JOB_RUN = 24;
private static final int METHODID_GET_CONFIG = 25;
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_DELIVERY_PIPELINES:
serviceImpl.listDeliveryPipelines(
(com.google.cloud.deploy.v1.ListDeliveryPipelinesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.deploy.v1.ListDeliveryPipelinesResponse>)
responseObserver);
break;
case METHODID_GET_DELIVERY_PIPELINE:
serviceImpl.getDeliveryPipeline(
(com.google.cloud.deploy.v1.GetDeliveryPipelineRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_DELIVERY_PIPELINE:
serviceImpl.createDeliveryPipeline(
(com.google.cloud.deploy.v1.CreateDeliveryPipelineRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_DELIVERY_PIPELINE:
serviceImpl.updateDeliveryPipeline(
(com.google.cloud.deploy.v1.UpdateDeliveryPipelineRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_DELIVERY_PIPELINE:
serviceImpl.deleteDeliveryPipeline(
(com.google.cloud.deploy.v1.DeleteDeliveryPipelineRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TARGETS:
serviceImpl.listTargets(
(com.google.cloud.deploy.v1.ListTargetsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_TARGET:
serviceImpl.getTarget(
(com.google.cloud.deploy.v1.GetTargetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_TARGET:
serviceImpl.createTarget(
(com.google.cloud.deploy.v1.CreateTargetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_TARGET:
serviceImpl.updateTarget(
(com.google.cloud.deploy.v1.UpdateTargetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_TARGET:
serviceImpl.deleteTarget(
(com.google.cloud.deploy.v1.DeleteTargetRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_RELEASES:
serviceImpl.listReleases(
(com.google.cloud.deploy.v1.ListReleasesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_RELEASE:
serviceImpl.getRelease(
(com.google.cloud.deploy.v1.GetReleaseRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_RELEASE:
serviceImpl.createRelease(
(com.google.cloud.deploy.v1.CreateReleaseRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_ABANDON_RELEASE:
serviceImpl.abandonRelease(
(com.google.cloud.deploy.v1.AbandonReleaseRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_APPROVE_ROLLOUT:
serviceImpl.approveRollout(
(com.google.cloud.deploy.v1.ApproveRolloutRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_ADVANCE_ROLLOUT:
serviceImpl.advanceRollout(
(com.google.cloud.deploy.v1.AdvanceRolloutRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CANCEL_ROLLOUT:
serviceImpl.cancelRollout(
(com.google.cloud.deploy.v1.CancelRolloutRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_ROLLOUTS:
serviceImpl.listRollouts(
(com.google.cloud.deploy.v1.ListRolloutsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_ROLLOUT:
serviceImpl.getRollout(
(com.google.cloud.deploy.v1.GetRolloutRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_ROLLOUT:
serviceImpl.createRollout(
(com.google.cloud.deploy.v1.CreateRolloutRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_IGNORE_JOB:
serviceImpl.ignoreJob(
(com.google.cloud.deploy.v1.IgnoreJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_RETRY_JOB:
serviceImpl.retryJob(
(com.google.cloud.deploy.v1.RetryJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_JOB_RUNS:
serviceImpl.listJobRuns(
(com.google.cloud.deploy.v1.ListJobRunsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_JOB_RUN:
serviceImpl.getJobRun(
(com.google.cloud.deploy.v1.GetJobRunRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_TERMINATE_JOB_RUN:
serviceImpl.terminateJobRun(
(com.google.cloud.deploy.v1.TerminateJobRunRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_CONFIG:
serviceImpl.getConfig(
(com.google.cloud.deploy.v1.GetConfigRequest) 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(
getListDeliveryPipelinesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ListDeliveryPipelinesRequest,
com.google.cloud.deploy.v1.ListDeliveryPipelinesResponse>(
service, METHODID_LIST_DELIVERY_PIPELINES)))
.addMethod(
getGetDeliveryPipelineMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetDeliveryPipelineRequest,
com.google.cloud.deploy.v1.DeliveryPipeline>(
service, METHODID_GET_DELIVERY_PIPELINE)))
.addMethod(
getCreateDeliveryPipelineMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.CreateDeliveryPipelineRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_DELIVERY_PIPELINE)))
.addMethod(
getUpdateDeliveryPipelineMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.UpdateDeliveryPipelineRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_DELIVERY_PIPELINE)))
.addMethod(
getDeleteDeliveryPipelineMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.DeleteDeliveryPipelineRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_DELIVERY_PIPELINE)))
.addMethod(
getListTargetsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ListTargetsRequest,
com.google.cloud.deploy.v1.ListTargetsResponse>(
service, METHODID_LIST_TARGETS)))
.addMethod(
getGetTargetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetTargetRequest, com.google.cloud.deploy.v1.Target>(
service, METHODID_GET_TARGET)))
.addMethod(
getCreateTargetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.CreateTargetRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_TARGET)))
.addMethod(
getUpdateTargetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.UpdateTargetRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_TARGET)))
.addMethod(
getDeleteTargetMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.DeleteTargetRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_TARGET)))
.addMethod(
getListReleasesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ListReleasesRequest,
com.google.cloud.deploy.v1.ListReleasesResponse>(
service, METHODID_LIST_RELEASES)))
.addMethod(
getGetReleaseMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetReleaseRequest,
com.google.cloud.deploy.v1.Release>(service, METHODID_GET_RELEASE)))
.addMethod(
getCreateReleaseMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.CreateReleaseRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_RELEASE)))
.addMethod(
getAbandonReleaseMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.AbandonReleaseRequest,
com.google.cloud.deploy.v1.AbandonReleaseResponse>(
service, METHODID_ABANDON_RELEASE)))
.addMethod(
getApproveRolloutMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ApproveRolloutRequest,
com.google.cloud.deploy.v1.ApproveRolloutResponse>(
service, METHODID_APPROVE_ROLLOUT)))
.addMethod(
getAdvanceRolloutMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.AdvanceRolloutRequest,
com.google.cloud.deploy.v1.AdvanceRolloutResponse>(
service, METHODID_ADVANCE_ROLLOUT)))
.addMethod(
getCancelRolloutMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.CancelRolloutRequest,
com.google.cloud.deploy.v1.CancelRolloutResponse>(
service, METHODID_CANCEL_ROLLOUT)))
.addMethod(
getListRolloutsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ListRolloutsRequest,
com.google.cloud.deploy.v1.ListRolloutsResponse>(
service, METHODID_LIST_ROLLOUTS)))
.addMethod(
getGetRolloutMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetRolloutRequest,
com.google.cloud.deploy.v1.Rollout>(service, METHODID_GET_ROLLOUT)))
.addMethod(
getCreateRolloutMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.CreateRolloutRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_ROLLOUT)))
.addMethod(
getIgnoreJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.IgnoreJobRequest,
com.google.cloud.deploy.v1.IgnoreJobResponse>(service, METHODID_IGNORE_JOB)))
.addMethod(
getRetryJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.RetryJobRequest,
com.google.cloud.deploy.v1.RetryJobResponse>(service, METHODID_RETRY_JOB)))
.addMethod(
getListJobRunsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.ListJobRunsRequest,
com.google.cloud.deploy.v1.ListJobRunsResponse>(
service, METHODID_LIST_JOB_RUNS)))
.addMethod(
getGetJobRunMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetJobRunRequest, com.google.cloud.deploy.v1.JobRun>(
service, METHODID_GET_JOB_RUN)))
.addMethod(
getTerminateJobRunMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.TerminateJobRunRequest,
com.google.cloud.deploy.v1.TerminateJobRunResponse>(
service, METHODID_TERMINATE_JOB_RUN)))
.addMethod(
getGetConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.deploy.v1.GetConfigRequest, com.google.cloud.deploy.v1.Config>(
service, METHODID_GET_CONFIG)))
.build();
}
private abstract static class CloudDeployBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
CloudDeployBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.deploy.v1.CloudDeployProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("CloudDeploy");
}
}
private static final class CloudDeployFileDescriptorSupplier
extends CloudDeployBaseDescriptorSupplier {
CloudDeployFileDescriptorSupplier() {}
}
private static final class CloudDeployMethodDescriptorSupplier
extends CloudDeployBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
CloudDeployMethodDescriptorSupplier(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 (CloudDeployGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new CloudDeployFileDescriptorSupplier())
.addMethod(getListDeliveryPipelinesMethod())
.addMethod(getGetDeliveryPipelineMethod())
.addMethod(getCreateDeliveryPipelineMethod())
.addMethod(getUpdateDeliveryPipelineMethod())
.addMethod(getDeleteDeliveryPipelineMethod())
.addMethod(getListTargetsMethod())
.addMethod(getGetTargetMethod())
.addMethod(getCreateTargetMethod())
.addMethod(getUpdateTargetMethod())
.addMethod(getDeleteTargetMethod())
.addMethod(getListReleasesMethod())
.addMethod(getGetReleaseMethod())
.addMethod(getCreateReleaseMethod())
.addMethod(getAbandonReleaseMethod())
.addMethod(getApproveRolloutMethod())
.addMethod(getAdvanceRolloutMethod())
.addMethod(getCancelRolloutMethod())
.addMethod(getListRolloutsMethod())
.addMethod(getGetRolloutMethod())
.addMethod(getCreateRolloutMethod())
.addMethod(getIgnoreJobMethod())
.addMethod(getRetryJobMethod())
.addMethod(getListJobRunsMethod())
.addMethod(getGetJobRunMethod())
.addMethod(getTerminateJobRunMethod())
.addMethod(getGetConfigMethod())
.build();
}
}
}
return result;
}
}