Package google.registry.batch

Class CloudTasksUtils

java.lang.Object

google.registry.batch.CloudTasksUtils

All Implemented Interfaces:

Serializable

public class CloudTasksUtils
extends Object
implements Serializable

Utilities for dealing with Cloud Tasks.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CloudTasksUtils.GcpCloudTasksClient
static class	CloudTasksUtils.SerializableCloudTasksClient

Constructor Summary

Constructors

Constructor	Description
CloudTasksUtils(Retrier retrier, Clock clock, String projectId, String locationId, String oauthClientId, GoogleCredentialsBundle credential, CloudTasksUtils.SerializableCloudTasksClient client)

Method Summary

Modifier and Type	Method	Description
com.google.cloud.tasks.v2.Task	createGetTask(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params)
com.google.cloud.tasks.v2.Task	createGetTaskWithDelay(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params, org.joda.time.Duration delay)	Create a Task via HTTP.GET that will be delayed for delay.
com.google.cloud.tasks.v2.Task	createGetTaskWithJitter(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params, Optional<Integer> jitterSeconds)	Create a Task via HTTP.GET that will be randomly delayed up to jitterSeconds.
com.google.cloud.tasks.v2.Task	createPostTask(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params)
com.google.cloud.tasks.v2.Task	createPostTaskWithDelay(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params, org.joda.time.Duration delay)	Create a Task via HTTP.POST that will be delayed for delay.
com.google.cloud.tasks.v2.Task	createPostTaskWithJitter(String path, Action.Service service, com.google.common.collect.Multimap<String,String> params, Optional<Integer> jitterSeconds)	Create a Task via HTTP.POST that will be randomly delayed up to jitterSeconds.
com.google.cloud.tasks.v2.Task	enqueue(String queue, com.google.cloud.tasks.v2.Task task)
com.google.common.collect.ImmutableList<com.google.cloud.tasks.v2.Task>	enqueue(String queue, com.google.cloud.tasks.v2.Task... tasks)
com.google.common.collect.ImmutableList<com.google.cloud.tasks.v2.Task>	enqueue(String queue, Iterable<com.google.cloud.tasks.v2.Task> tasks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CloudTasksUtils

@Inject
public CloudTasksUtils(Retrier retrier,
 Clock clock,
 @Config("projectId")
 String projectId,
 @Config("locationId")
 String locationId,
 @Config("oauthClientId")
 String oauthClientId,
 @ApplicationDefaultCredential
 GoogleCredentialsBundle credential,
 CloudTasksUtils.SerializableCloudTasksClient client)

Method Details

enqueue

public com.google.cloud.tasks.v2.Task enqueue(String queue,
 com.google.cloud.tasks.v2.Task task)

enqueue

public com.google.common.collect.ImmutableList<com.google.cloud.tasks.v2.Task> enqueue(String queue,
 Iterable<com.google.cloud.tasks.v2.Task> tasks)

enqueue

public com.google.common.collect.ImmutableList<com.google.cloud.tasks.v2.Task> enqueue(String queue,
 com.google.cloud.tasks.v2.Task... tasks)

createPostTask

public com.google.cloud.tasks.v2.Task createPostTask(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params)

createGetTask

public com.google.cloud.tasks.v2.Task createGetTask(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params)

createPostTaskWithJitter

public com.google.cloud.tasks.v2.Task createPostTaskWithJitter(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params,
 Optional<Integer> jitterSeconds)

Create a Task via HTTP.POST that will be randomly delayed up to jitterSeconds.

createGetTaskWithJitter

public com.google.cloud.tasks.v2.Task createGetTaskWithJitter(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params,
 Optional<Integer> jitterSeconds)

Create a Task via HTTP.GET that will be randomly delayed up to jitterSeconds.

createPostTaskWithDelay

public com.google.cloud.tasks.v2.Task createPostTaskWithDelay(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params,
 org.joda.time.Duration delay)

Create a Task via HTTP.POST that will be delayed for delay.

createGetTaskWithDelay

public com.google.cloud.tasks.v2.Task createGetTaskWithDelay(String path,
 Action.Service service,
 com.google.common.collect.Multimap<String,String> params,
 org.joda.time.Duration delay)

Create a Task via HTTP.GET that will be delayed for delay.