Class HttpJsonCloudTasksStub
- java.lang.Object
-
- com.google.cloud.tasks.v2beta2.stub.CloudTasksStub
-
- com.google.cloud.tasks.v2beta2.stub.HttpJsonCloudTasksStub
-
- All Implemented Interfaces:
com.google.api.gax.core.BackgroundResource
,AutoCloseable
@BetaApi @Generated("by gapic-generator-java") public class HttpJsonCloudTasksStub extends CloudTasksStub
REST stub implementation for the CloudTasks service API.This class is for advanced usage and reflects the underlying API directly.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
HttpJsonCloudTasksStub(CloudTasksStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext)
Constructs an instance of HttpJsonCloudTasksStub, using the given settings.protected
HttpJsonCloudTasksStub(CloudTasksStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.httpjson.HttpJsonStubCallableFactory callableFactory)
Constructs an instance of HttpJsonCloudTasksStub, using the given settings.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description com.google.api.gax.rpc.UnaryCallable<AcknowledgeTaskRequest,com.google.protobuf.Empty>
acknowledgeTaskCallable()
boolean
awaitTermination(long duration, TimeUnit unit)
com.google.api.gax.rpc.UnaryCallable<BufferTaskRequest,BufferTaskResponse>
bufferTaskCallable()
com.google.api.gax.rpc.UnaryCallable<CancelLeaseRequest,Task>
cancelLeaseCallable()
void
close()
static HttpJsonCloudTasksStub
create(com.google.api.gax.rpc.ClientContext clientContext)
static HttpJsonCloudTasksStub
create(com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.httpjson.HttpJsonStubCallableFactory callableFactory)
static HttpJsonCloudTasksStub
create(CloudTasksStubSettings settings)
com.google.api.gax.rpc.UnaryCallable<CreateQueueRequest,Queue>
createQueueCallable()
com.google.api.gax.rpc.UnaryCallable<CreateTaskRequest,Task>
createTaskCallable()
com.google.api.gax.rpc.UnaryCallable<DeleteQueueRequest,com.google.protobuf.Empty>
deleteQueueCallable()
com.google.api.gax.rpc.UnaryCallable<DeleteTaskRequest,com.google.protobuf.Empty>
deleteTaskCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy>
getIamPolicyCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location>
getLocationCallable()
static List<com.google.api.gax.httpjson.ApiMethodDescriptor>
getMethodDescriptors()
com.google.api.gax.rpc.UnaryCallable<GetQueueRequest,Queue>
getQueueCallable()
com.google.api.gax.rpc.UnaryCallable<GetTaskRequest,Task>
getTaskCallable()
boolean
isShutdown()
boolean
isTerminated()
com.google.api.gax.rpc.UnaryCallable<LeaseTasksRequest,LeaseTasksResponse>
leaseTasksCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse>
listLocationsCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,CloudTasksClient.ListLocationsPagedResponse>
listLocationsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListQueuesRequest,ListQueuesResponse>
listQueuesCallable()
com.google.api.gax.rpc.UnaryCallable<ListQueuesRequest,CloudTasksClient.ListQueuesPagedResponse>
listQueuesPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListTasksRequest,ListTasksResponse>
listTasksCallable()
com.google.api.gax.rpc.UnaryCallable<ListTasksRequest,CloudTasksClient.ListTasksPagedResponse>
listTasksPagedCallable()
com.google.api.gax.rpc.UnaryCallable<PauseQueueRequest,Queue>
pauseQueueCallable()
com.google.api.gax.rpc.UnaryCallable<PurgeQueueRequest,Queue>
purgeQueueCallable()
com.google.api.gax.rpc.UnaryCallable<RenewLeaseRequest,Task>
renewLeaseCallable()
com.google.api.gax.rpc.UnaryCallable<ResumeQueueRequest,Queue>
resumeQueueCallable()
com.google.api.gax.rpc.UnaryCallable<RunTaskRequest,Task>
runTaskCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy>
setIamPolicyCallable()
void
shutdown()
void
shutdownNow()
com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse>
testIamPermissionsCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateQueueRequest,Queue>
updateQueueCallable()
com.google.api.gax.rpc.UnaryCallable<UploadQueueYamlRequest,com.google.protobuf.Empty>
uploadQueueYamlCallable()
-
-
-
Constructor Detail
-
HttpJsonCloudTasksStub
protected HttpJsonCloudTasksStub(CloudTasksStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext) throws IOException
Constructs an instance of HttpJsonCloudTasksStub, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.- Throws:
IOException
-
HttpJsonCloudTasksStub
protected HttpJsonCloudTasksStub(CloudTasksStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.httpjson.HttpJsonStubCallableFactory callableFactory) throws IOException
Constructs an instance of HttpJsonCloudTasksStub, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.- Throws:
IOException
-
-
Method Detail
-
create
public static final HttpJsonCloudTasksStub create(CloudTasksStubSettings settings) throws IOException
- Throws:
IOException
-
create
public static final HttpJsonCloudTasksStub create(com.google.api.gax.rpc.ClientContext clientContext) throws IOException
- Throws:
IOException
-
create
public static final HttpJsonCloudTasksStub create(com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.httpjson.HttpJsonStubCallableFactory callableFactory) throws IOException
- Throws:
IOException
-
getMethodDescriptors
@InternalApi public static List<com.google.api.gax.httpjson.ApiMethodDescriptor> getMethodDescriptors()
-
listQueuesCallable
public com.google.api.gax.rpc.UnaryCallable<ListQueuesRequest,ListQueuesResponse> listQueuesCallable()
- Overrides:
listQueuesCallable
in classCloudTasksStub
-
listQueuesPagedCallable
public com.google.api.gax.rpc.UnaryCallable<ListQueuesRequest,CloudTasksClient.ListQueuesPagedResponse> listQueuesPagedCallable()
- Overrides:
listQueuesPagedCallable
in classCloudTasksStub
-
getQueueCallable
public com.google.api.gax.rpc.UnaryCallable<GetQueueRequest,Queue> getQueueCallable()
- Overrides:
getQueueCallable
in classCloudTasksStub
-
createQueueCallable
public com.google.api.gax.rpc.UnaryCallable<CreateQueueRequest,Queue> createQueueCallable()
- Overrides:
createQueueCallable
in classCloudTasksStub
-
updateQueueCallable
public com.google.api.gax.rpc.UnaryCallable<UpdateQueueRequest,Queue> updateQueueCallable()
- Overrides:
updateQueueCallable
in classCloudTasksStub
-
deleteQueueCallable
public com.google.api.gax.rpc.UnaryCallable<DeleteQueueRequest,com.google.protobuf.Empty> deleteQueueCallable()
- Overrides:
deleteQueueCallable
in classCloudTasksStub
-
purgeQueueCallable
public com.google.api.gax.rpc.UnaryCallable<PurgeQueueRequest,Queue> purgeQueueCallable()
- Overrides:
purgeQueueCallable
in classCloudTasksStub
-
pauseQueueCallable
public com.google.api.gax.rpc.UnaryCallable<PauseQueueRequest,Queue> pauseQueueCallable()
- Overrides:
pauseQueueCallable
in classCloudTasksStub
-
resumeQueueCallable
public com.google.api.gax.rpc.UnaryCallable<ResumeQueueRequest,Queue> resumeQueueCallable()
- Overrides:
resumeQueueCallable
in classCloudTasksStub
-
getIamPolicyCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.GetIamPolicyRequest,com.google.iam.v1.Policy> getIamPolicyCallable()
- Overrides:
getIamPolicyCallable
in classCloudTasksStub
-
setIamPolicyCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.SetIamPolicyRequest,com.google.iam.v1.Policy> setIamPolicyCallable()
- Overrides:
setIamPolicyCallable
in classCloudTasksStub
-
testIamPermissionsCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.iam.v1.TestIamPermissionsRequest,com.google.iam.v1.TestIamPermissionsResponse> testIamPermissionsCallable()
- Overrides:
testIamPermissionsCallable
in classCloudTasksStub
-
listTasksCallable
public com.google.api.gax.rpc.UnaryCallable<ListTasksRequest,ListTasksResponse> listTasksCallable()
- Overrides:
listTasksCallable
in classCloudTasksStub
-
listTasksPagedCallable
public com.google.api.gax.rpc.UnaryCallable<ListTasksRequest,CloudTasksClient.ListTasksPagedResponse> listTasksPagedCallable()
- Overrides:
listTasksPagedCallable
in classCloudTasksStub
-
getTaskCallable
public com.google.api.gax.rpc.UnaryCallable<GetTaskRequest,Task> getTaskCallable()
- Overrides:
getTaskCallable
in classCloudTasksStub
-
createTaskCallable
public com.google.api.gax.rpc.UnaryCallable<CreateTaskRequest,Task> createTaskCallable()
- Overrides:
createTaskCallable
in classCloudTasksStub
-
deleteTaskCallable
public com.google.api.gax.rpc.UnaryCallable<DeleteTaskRequest,com.google.protobuf.Empty> deleteTaskCallable()
- Overrides:
deleteTaskCallable
in classCloudTasksStub
-
leaseTasksCallable
public com.google.api.gax.rpc.UnaryCallable<LeaseTasksRequest,LeaseTasksResponse> leaseTasksCallable()
- Overrides:
leaseTasksCallable
in classCloudTasksStub
-
acknowledgeTaskCallable
public com.google.api.gax.rpc.UnaryCallable<AcknowledgeTaskRequest,com.google.protobuf.Empty> acknowledgeTaskCallable()
- Overrides:
acknowledgeTaskCallable
in classCloudTasksStub
-
renewLeaseCallable
public com.google.api.gax.rpc.UnaryCallable<RenewLeaseRequest,Task> renewLeaseCallable()
- Overrides:
renewLeaseCallable
in classCloudTasksStub
-
cancelLeaseCallable
public com.google.api.gax.rpc.UnaryCallable<CancelLeaseRequest,Task> cancelLeaseCallable()
- Overrides:
cancelLeaseCallable
in classCloudTasksStub
-
runTaskCallable
public com.google.api.gax.rpc.UnaryCallable<RunTaskRequest,Task> runTaskCallable()
- Overrides:
runTaskCallable
in classCloudTasksStub
-
bufferTaskCallable
public com.google.api.gax.rpc.UnaryCallable<BufferTaskRequest,BufferTaskResponse> bufferTaskCallable()
- Overrides:
bufferTaskCallable
in classCloudTasksStub
-
listLocationsCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse> listLocationsCallable()
- Overrides:
listLocationsCallable
in classCloudTasksStub
-
listLocationsPagedCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,CloudTasksClient.ListLocationsPagedResponse> listLocationsPagedCallable()
- Overrides:
listLocationsPagedCallable
in classCloudTasksStub
-
getLocationCallable
public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location> getLocationCallable()
- Overrides:
getLocationCallable
in classCloudTasksStub
-
uploadQueueYamlCallable
public com.google.api.gax.rpc.UnaryCallable<UploadQueueYamlRequest,com.google.protobuf.Empty> uploadQueueYamlCallable()
- Overrides:
uploadQueueYamlCallable
in classCloudTasksStub
-
close
public final void close()
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in classCloudTasksStub
-
shutdown
public void shutdown()
-
isShutdown
public boolean isShutdown()
-
isTerminated
public boolean isTerminated()
-
shutdownNow
public void shutdownNow()
-
awaitTermination
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
- Throws:
InterruptedException
-
-