Queue Args
data class QueueArgs(val appEngineRoutingOverride: Output<QueueAppEngineRoutingOverrideArgs>? = null, val location: Output<String>? = null, val name: Output<String>? = null, val project: Output<String>? = null, val rateLimits: Output<QueueRateLimitsArgs>? = null, val retryConfig: Output<QueueRetryConfigArgs>? = null, val stackdriverLoggingConfig: Output<QueueStackdriverLoggingConfigArgs>? = null) : ConvertibleToJava<QueueArgs>
A named resource to which messages are sent by publishers.
Warning: This resource requires an App Engine application to be created on the project you're provisioning it on. If you haven't already enabled it, you can create a
gcp.appengine.Application
resource to do so. This resource's location will be the same as the App Engine location specified.
Example Usage
Queue Basic
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.cloudtasks.Queue;
import com.pulumi.gcp.cloudtasks.QueueArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var default_ = new Queue("default", QueueArgs.builder()
.location("us-central1")
.build());
}
}
Content copied to clipboard
Cloud Tasks Queue Advanced
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.cloudtasks.Queue;
import com.pulumi.gcp.cloudtasks.QueueArgs;
import com.pulumi.gcp.cloudtasks.inputs.QueueAppEngineRoutingOverrideArgs;
import com.pulumi.gcp.cloudtasks.inputs.QueueRateLimitsArgs;
import com.pulumi.gcp.cloudtasks.inputs.QueueRetryConfigArgs;
import com.pulumi.gcp.cloudtasks.inputs.QueueStackdriverLoggingConfigArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var advancedConfiguration = new Queue("advancedConfiguration", QueueArgs.builder()
.appEngineRoutingOverride(QueueAppEngineRoutingOverrideArgs.builder()
.instance("test")
.service("worker")
.version("1.0")
.build())
.location("us-central1")
.rateLimits(QueueRateLimitsArgs.builder()
.maxConcurrentDispatches(3)
.maxDispatchesPerSecond(2)
.build())
.retryConfig(QueueRetryConfigArgs.builder()
.maxAttempts(5)
.maxBackoff("3s")
.maxDoublings(1)
.maxRetryDuration("4s")
.minBackoff("2s")
.build())
.stackdriverLoggingConfig(QueueStackdriverLoggingConfigArgs.builder()
.samplingRatio(0.9)
.build())
.build());
}
}
Content copied to clipboard
Import
Queue can be imported using any of these accepted formats
$ pulumi import gcp:cloudtasks/queue:Queue default projects/{{project}}/locations/{{location}}/queues/{{name}}
Content copied to clipboard
$ pulumi import gcp:cloudtasks/queue:Queue default {{project}}/{{location}}/{{name}}
Content copied to clipboard
$ pulumi import gcp:cloudtasks/queue:Queue default {{location}}/{{name}}
Content copied to clipboard
Constructors
Link copied to clipboard
fun QueueArgs(appEngineRoutingOverride: Output<QueueAppEngineRoutingOverrideArgs>? = null, location: Output<String>? = null, name: Output<String>? = null, project: Output<String>? = null, rateLimits: Output<QueueRateLimitsArgs>? = null, retryConfig: Output<QueueRetryConfigArgs>? = null, stackdriverLoggingConfig: Output<QueueStackdriverLoggingConfigArgs>? = null)