{
private CloudSchedulerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudSchedulerBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudSchedulerBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists jobs.
*
*/
public com.google.cloud.scheduler.v1beta1.ListJobsResponse listJobs(
com.google.cloud.scheduler.v1beta1.ListJobsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListJobsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets a job.
*
*/
public com.google.cloud.scheduler.v1beta1.Job getJob(
com.google.cloud.scheduler.v1beta1.GetJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a job.
*
*/
public com.google.cloud.scheduler.v1beta1.Job createJob(
com.google.cloud.scheduler.v1beta1.CreateJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a job.
* If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is
* returned. If the job does not exist, `NOT_FOUND` is returned.
* If UpdateJob does not successfully return, it is possible for the
* job to be in an
* [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED]
* state. A job in this state may not be executed. If this happens, retry the
* UpdateJob request until a successful response is received.
*
*/
public com.google.cloud.scheduler.v1beta1.Job updateJob(
com.google.cloud.scheduler.v1beta1.UpdateJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a job.
*
*/
public com.google.protobuf.Empty deleteJob(
com.google.cloud.scheduler.v1beta1.DeleteJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Pauses a job.
* If a job is paused then the system will stop executing the job
* until it is re-enabled via
* [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The
* state of the job is stored in
* [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set
* to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A
* job must be in
* [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be
* paused.
*
*/
public com.google.cloud.scheduler.v1beta1.Job pauseJob(
com.google.cloud.scheduler.v1beta1.PauseJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPauseJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Resume a job.
* This method reenables a job after it has been
* [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The
* state of a job is stored in
* [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this
* method it will be set to
* [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A
* job must be in
* [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be
* resumed.
*
*/
public com.google.cloud.scheduler.v1beta1.Job resumeJob(
com.google.cloud.scheduler.v1beta1.ResumeJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getResumeJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Forces a job to run now.
* When this method is called, Cloud Scheduler will dispatch the job, even
* if the job is already running.
*
*/
public com.google.cloud.scheduler.v1beta1.Job runJob(
com.google.cloud.scheduler.v1beta1.RunJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRunJobMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service CloudScheduler.
*
*
* The Cloud Scheduler API allows external entities to reliably
* schedule asynchronous jobs.
*
*/
public static final class CloudSchedulerFutureStub
extends io.grpc.stub.AbstractFutureStub {
private CloudSchedulerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudSchedulerFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudSchedulerFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists jobs.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.ListJobsResponse>
listJobs(com.google.cloud.scheduler.v1beta1.ListJobsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListJobsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets a job.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
getJob(com.google.cloud.scheduler.v1beta1.GetJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a job.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
createJob(com.google.cloud.scheduler.v1beta1.CreateJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a job.
* If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is
* returned. If the job does not exist, `NOT_FOUND` is returned.
* If UpdateJob does not successfully return, it is possible for the
* job to be in an
* [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED]
* state. A job in this state may not be executed. If this happens, retry the
* UpdateJob request until a successful response is received.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
updateJob(com.google.cloud.scheduler.v1beta1.UpdateJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a job.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteJob(
com.google.cloud.scheduler.v1beta1.DeleteJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Pauses a job.
* If a job is paused then the system will stop executing the job
* until it is re-enabled via
* [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The
* state of the job is stored in
* [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set
* to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A
* job must be in
* [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be
* paused.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
pauseJob(com.google.cloud.scheduler.v1beta1.PauseJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getPauseJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Resume a job.
* This method reenables a job after it has been
* [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The
* state of a job is stored in
* [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this
* method it will be set to
* [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A
* job must be in
* [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be
* resumed.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
resumeJob(com.google.cloud.scheduler.v1beta1.ResumeJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getResumeJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Forces a job to run now.
* When this method is called, Cloud Scheduler will dispatch the job, even
* if the job is already running.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.scheduler.v1beta1.Job>
runJob(com.google.cloud.scheduler.v1beta1.RunJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRunJobMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_JOBS = 0;
private static final int METHODID_GET_JOB = 1;
private static final int METHODID_CREATE_JOB = 2;
private static final int METHODID_UPDATE_JOB = 3;
private static final int METHODID_DELETE_JOB = 4;
private static final int METHODID_PAUSE_JOB = 5;
private static final int METHODID_RESUME_JOB = 6;
private static final int METHODID_RUN_JOB = 7;
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_JOBS:
serviceImpl.listJobs(
(com.google.cloud.scheduler.v1beta1.ListJobsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_JOB:
serviceImpl.getJob(
(com.google.cloud.scheduler.v1beta1.GetJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_JOB:
serviceImpl.createJob(
(com.google.cloud.scheduler.v1beta1.CreateJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_JOB:
serviceImpl.updateJob(
(com.google.cloud.scheduler.v1beta1.UpdateJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_JOB:
serviceImpl.deleteJob(
(com.google.cloud.scheduler.v1beta1.DeleteJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_PAUSE_JOB:
serviceImpl.pauseJob(
(com.google.cloud.scheduler.v1beta1.PauseJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_RESUME_JOB:
serviceImpl.resumeJob(
(com.google.cloud.scheduler.v1beta1.ResumeJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_RUN_JOB:
serviceImpl.runJob(
(com.google.cloud.scheduler.v1beta1.RunJobRequest) 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(
getListJobsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.ListJobsRequest,
com.google.cloud.scheduler.v1beta1.ListJobsResponse>(
service, METHODID_LIST_JOBS)))
.addMethod(
getGetJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.GetJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_GET_JOB)))
.addMethod(
getCreateJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.CreateJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_CREATE_JOB)))
.addMethod(
getUpdateJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.UpdateJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_UPDATE_JOB)))
.addMethod(
getDeleteJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.DeleteJobRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_JOB)))
.addMethod(
getPauseJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.PauseJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_PAUSE_JOB)))
.addMethod(
getResumeJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.ResumeJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_RESUME_JOB)))
.addMethod(
getRunJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.scheduler.v1beta1.RunJobRequest,
com.google.cloud.scheduler.v1beta1.Job>(service, METHODID_RUN_JOB)))
.build();
}
private abstract static class CloudSchedulerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
CloudSchedulerBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.scheduler.v1beta1.SchedulerProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("CloudScheduler");
}
}
private static final class CloudSchedulerFileDescriptorSupplier
extends CloudSchedulerBaseDescriptorSupplier {
CloudSchedulerFileDescriptorSupplier() {}
}
private static final class CloudSchedulerMethodDescriptorSupplier
extends CloudSchedulerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
CloudSchedulerMethodDescriptorSupplier(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 (CloudSchedulerGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new CloudSchedulerFileDescriptorSupplier())
.addMethod(getListJobsMethod())
.addMethod(getGetJobMethod())
.addMethod(getCreateJobMethod())
.addMethod(getUpdateJobMethod())
.addMethod(getDeleteJobMethod())
.addMethod(getPauseJobMethod())
.addMethod(getResumeJobMethod())
.addMethod(getRunJobMethod())
.build();
}
}
}
return result;
}
}