pulumi-gcp-kotlin/com.pulumi.gcp.cloudtasks.kotlin/Queue

Queue

class Queue : KotlinCustomResource

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());
    }
}

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());
    }
}

Import

Queue can be imported using any of these accepted formats

$ pulumi import gcp:cloudtasks/queue:Queue default projects/{{project}}/locations/{{location}}/queues/{{name}}

$ pulumi import gcp:cloudtasks/queue:Queue default {{project}}/{{location}}/{{name}}

$ pulumi import gcp:cloudtasks/queue:Queue default {{location}}/{{name}}

Properties

appEngineRoutingOverride

val appEngineRoutingOverride: Output<QueueAppEngineRoutingOverride>?

Overrides for task-level appEngineRouting. These settings apply only to App Engine tasks in this queue Structure is documented below.

val id: Output<String>

location

val location: Output<String>

The location of the queue

name

val name: Output<String>

The queue name.

project

val project: Output<String>

The ID of the project in which the resource belongs. If it is not provided, the provider project is used.

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

rateLimits

val rateLimits: Output<QueueRateLimits>

Rate limits for task dispatches. The queue's actual dispatch rate is the result of:

retryConfig

val retryConfig: Output<QueueRetryConfig>

Settings that determine the retry behavior. Structure is documented below.

stackdriverLoggingConfig

val stackdriverLoggingConfig: Output<QueueStackdriverLoggingConfig>?

Configuration options for writing logs to Stackdriver Logging. Structure is documented below.

urn

val urn: Output<String>