pulumi-gcp-kotlin/com.pulumi.gcp.pubsub.kotlin/LiteSubscription

LiteSubscription

class LiteSubscription : KotlinCustomResource

A named resource representing the stream of messages from a single, specific topic, to be delivered to the subscribing application. To get more information about Subscription, see:

Example Usage

Pubsub Lite Subscription Basic

import * as pulumi from "@pulumi/pulumi";
import * as gcp from "@pulumi/gcp";
const project = gcp.organizations.getProject({});
const example = new gcp.pubsub.LiteTopic("example", {
    name: "example-topic",
    project: project.then(project => project.number),
    partitionConfig: {
        count: 1,
        capacity: {
            publishMibPerSec: 4,
            subscribeMibPerSec: 8,
        },
    },
    retentionConfig: {
        perPartitionBytes: "32212254720",
    },
});
const exampleLiteSubscription = new gcp.pubsub.LiteSubscription("example", {
    name: "example-subscription",
    topic: example.name,
    deliveryConfig: {
        deliveryRequirement: "DELIVER_AFTER_STORED",
    },
});
Content copied to clipboard
import pulumi
import pulumi_gcp as gcp
project = gcp.organizations.get_project()
example = gcp.pubsub.LiteTopic("example",
    name="example-topic",
    project=project.number,
    partition_config={
        "count": 1,
        "capacity": {
            "publish_mib_per_sec": 4,
            "subscribe_mib_per_sec": 8,
        },
    },
    retention_config={
        "per_partition_bytes": "32212254720",
    })
example_lite_subscription = gcp.pubsub.LiteSubscription("example",
    name="example-subscription",
    topic=example.name,
    delivery_config={
        "delivery_requirement": "DELIVER_AFTER_STORED",
    })
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Gcp = Pulumi.Gcp;
return await Deployment.RunAsync(() =>
{
    var project = Gcp.Organizations.GetProject.Invoke();
    var example = new Gcp.PubSub.LiteTopic("example", new()
    {
        Name = "example-topic",
        Project = project.Apply(getProjectResult => getProjectResult.Number),
        PartitionConfig = new Gcp.PubSub.Inputs.LiteTopicPartitionConfigArgs
        {
            Count = 1,
            Capacity = new Gcp.PubSub.Inputs.LiteTopicPartitionConfigCapacityArgs
            {
                PublishMibPerSec = 4,
                SubscribeMibPerSec = 8,
            },
        },
        RetentionConfig = new Gcp.PubSub.Inputs.LiteTopicRetentionConfigArgs
        {
            PerPartitionBytes = "32212254720",
        },
    });
    var exampleLiteSubscription = new Gcp.PubSub.LiteSubscription("example", new()
    {
        Name = "example-subscription",
        Topic = example.Name,
        DeliveryConfig = new Gcp.PubSub.Inputs.LiteSubscriptionDeliveryConfigArgs
        {
            DeliveryRequirement = "DELIVER_AFTER_STORED",
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/organizations"
	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/pubsub"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		project, err := organizations.LookupProject(ctx, &organizations.LookupProjectArgs{}, nil)
		if err != nil {
			return err
		}
		example, err := pubsub.NewLiteTopic(ctx, "example", &pubsub.LiteTopicArgs{
			Name:    pulumi.String("example-topic"),
			Project: pulumi.String(project.Number),
			PartitionConfig: &pubsub.LiteTopicPartitionConfigArgs{
				Count: pulumi.Int(1),
				Capacity: &pubsub.LiteTopicPartitionConfigCapacityArgs{
					PublishMibPerSec:   pulumi.Int(4),
					SubscribeMibPerSec: pulumi.Int(8),
				},
			},
			RetentionConfig: &pubsub.LiteTopicRetentionConfigArgs{
				PerPartitionBytes: pulumi.String("32212254720"),
			},
		})
		if err != nil {
			return err
		}
		_, err = pubsub.NewLiteSubscription(ctx, "example", &pubsub.LiteSubscriptionArgs{
			Name:  pulumi.String("example-subscription"),
			Topic: example.Name,
			DeliveryConfig: &pubsub.LiteSubscriptionDeliveryConfigArgs{
				DeliveryRequirement: pulumi.String("DELIVER_AFTER_STORED"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.organizations.OrganizationsFunctions;
import com.pulumi.gcp.organizations.inputs.GetProjectArgs;
import com.pulumi.gcp.pubsub.LiteTopic;
import com.pulumi.gcp.pubsub.LiteTopicArgs;
import com.pulumi.gcp.pubsub.inputs.LiteTopicPartitionConfigArgs;
import com.pulumi.gcp.pubsub.inputs.LiteTopicPartitionConfigCapacityArgs;
import com.pulumi.gcp.pubsub.inputs.LiteTopicRetentionConfigArgs;
import com.pulumi.gcp.pubsub.LiteSubscription;
import com.pulumi.gcp.pubsub.LiteSubscriptionArgs;
import com.pulumi.gcp.pubsub.inputs.LiteSubscriptionDeliveryConfigArgs;
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) {
        final var project = OrganizationsFunctions.getProject(GetProjectArgs.builder()
            .build());
        var example = new LiteTopic("example", LiteTopicArgs.builder()
            .name("example-topic")
            .project(project.number())
            .partitionConfig(LiteTopicPartitionConfigArgs.builder()
                .count(1)
                .capacity(LiteTopicPartitionConfigCapacityArgs.builder()
                    .publishMibPerSec(4)
                    .subscribeMibPerSec(8)
                    .build())
                .build())
            .retentionConfig(LiteTopicRetentionConfigArgs.builder()
                .perPartitionBytes("32212254720")
                .build())
            .build());
        var exampleLiteSubscription = new LiteSubscription("exampleLiteSubscription", LiteSubscriptionArgs.builder()
            .name("example-subscription")
            .topic(example.name())
            .deliveryConfig(LiteSubscriptionDeliveryConfigArgs.builder()
                .deliveryRequirement("DELIVER_AFTER_STORED")
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: gcp:pubsub:LiteTopic
    properties:
      name: example-topic
      project: ${project.number}
      partitionConfig:
        count: 1
        capacity:
          publishMibPerSec: 4
          subscribeMibPerSec: 8
      retentionConfig:
        perPartitionBytes: 3.221225472e+10
  exampleLiteSubscription:
    type: gcp:pubsub:LiteSubscription
    name: example
    properties:
      name: example-subscription
      topic: ${example.name}
      deliveryConfig:
        deliveryRequirement: DELIVER_AFTER_STORED
variables:
  project:
    fn::invoke:
      function: gcp:organizations:getProject
      arguments: {}
Content copied to clipboard

Import

Subscription can be imported using any of these accepted formats:

  • projects/{{project}}/locations/{{zone}}/subscriptions/{{name}}

  • {{project}}/{{zone}}/{{name}}

  • {{zone}}/{{name}}

  • {{name}} When using the pulumi import command, Subscription can be imported using one of the formats above. For example:

$ pulumi import gcp:pubsub/liteSubscription:LiteSubscription default projects/{{project}}/locations/{{zone}}/subscriptions/{{name}}
Content copied to clipboard
$ pulumi import gcp:pubsub/liteSubscription:LiteSubscription default {{project}}/{{zone}}/{{name}}
Content copied to clipboard
$ pulumi import gcp:pubsub/liteSubscription:LiteSubscription default {{zone}}/{{name}}
Content copied to clipboard
$ pulumi import gcp:pubsub/liteSubscription:LiteSubscription default {{name}}
Content copied to clipboard

Properties

Link copied to clipboard
val deliveryConfig: Output<LiteSubscriptionDeliveryConfig>?

The settings for this subscription's message delivery. Structure is documented below.

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val name: Output<String>

Name of the subscription.

Link copied to clipboard
val project: Output<String>

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

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val region: Output<String>?

The region of the pubsub lite topic.

Link copied to clipboard
val topic: Output<String>

A reference to a Topic resource.

Link copied to clipboard
val urn: Output<String>
Link copied to clipboard
val zone: Output<String>?

The zone of the pubsub lite topic.