Class CloudSchedulerGrpc.CloudSchedulerFutureStub (2.35.0)

public static final class CloudSchedulerGrpc.CloudSchedulerFutureStub extends AbstractFutureStub<CloudSchedulerGrpc.CloudSchedulerFutureStub>

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.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractFutureStub > CloudSchedulerGrpc.CloudSchedulerFutureStub

Methods

build(Channel channel, CallOptions callOptions)

protected CloudSchedulerGrpc.CloudSchedulerFutureStub build(Channel channel, CallOptions callOptions)
Parameters
NameDescription
channelio.grpc.Channel
callOptionsio.grpc.CallOptions
Returns
TypeDescription
CloudSchedulerGrpc.CloudSchedulerFutureStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createJob(CreateJobRequest request)

public ListenableFuture<Job> createJob(CreateJobRequest request)

Creates a job.

Parameter
NameDescription
requestCreateJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>

deleteJob(DeleteJobRequest request)

public ListenableFuture<Empty> deleteJob(DeleteJobRequest request)

Deletes a job.

Parameter
NameDescription
requestDeleteJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Empty>

getJob(GetJobRequest request)

public ListenableFuture<Job> getJob(GetJobRequest request)

Gets a job.

Parameter
NameDescription
requestGetJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>

listJobs(ListJobsRequest request)

public ListenableFuture<ListJobsResponse> listJobs(ListJobsRequest request)

Lists jobs.

Parameter
NameDescription
requestListJobsRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<ListJobsResponse>

pauseJob(PauseJobRequest request)

public ListenableFuture<Job> pauseJob(PauseJobRequest request)

Pauses a job. If a job is paused then the system will stop executing the job until it is re-enabled via ResumeJob. The state of the job is stored in state; if paused it will be set to Job.State.PAUSED. A job must be in Job.State.ENABLED to be paused.

Parameter
NameDescription
requestPauseJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>

resumeJob(ResumeJobRequest request)

public ListenableFuture<Job> resumeJob(ResumeJobRequest request)

Resume a job. This method reenables a job after it has been Job.State.PAUSED. The state of a job is stored in Job.state; after calling this method it will be set to Job.State.ENABLED. A job must be in Job.State.PAUSED to be resumed.

Parameter
NameDescription
requestResumeJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>

runJob(RunJobRequest request)

public ListenableFuture<Job> runJob(RunJobRequest 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.

Parameter
NameDescription
requestRunJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>

updateJob(UpdateJobRequest request)

public ListenableFuture<Job> updateJob(UpdateJobRequest request)

Updates a job. If successful, the updated 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 state. A job in this state may not be executed. If this happens, retry the UpdateJob request until a successful response is received.

Parameter
NameDescription
requestUpdateJobRequest
Returns
TypeDescription
com.google.common.util.concurrent.ListenableFuture<Job>