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

Package-level declarations

Types

data class GetSchemaIamPolicyResult(val etag: String, val id: String, val policyData: String, val project: String, val schema: String)

A collection of values returned by getSchemaIamPolicy.

GetSubscriptionBigqueryConfig

data class GetSubscriptionBigqueryConfig(val dropUnknownFields: Boolean, val serviceAccountEmail: String, val table: String, val useTableSchema: Boolean, val useTopicSchema: Boolean, val writeMetadata: Boolean)

GetSubscriptionCloudStorageConfig

data class GetSubscriptionCloudStorageConfig(val avroConfigs: List<GetSubscriptionCloudStorageConfigAvroConfig>, val bucket: String, val filenameDatetimeFormat: String, val filenamePrefix: String, val filenameSuffix: String, val maxBytes: Int, val maxDuration: String, val maxMessages: Int, val serviceAccountEmail: String, val state: String)

GetSubscriptionCloudStorageConfigAvroConfig

data class GetSubscriptionCloudStorageConfigAvroConfig(val useTopicSchema: Boolean, val writeMetadata: Boolean)

GetSubscriptionDeadLetterPolicy

data class GetSubscriptionDeadLetterPolicy(val deadLetterTopic: String, val maxDeliveryAttempts: Int)

GetSubscriptionExpirationPolicy

data class GetSubscriptionExpirationPolicy(val ttl: String)

GetSubscriptionIamPolicyResult

data class GetSubscriptionIamPolicyResult(val etag: String, val id: String, val policyData: String, val project: String, val subscription: String)

A collection of values returned by getSubscriptionIamPolicy.

GetSubscriptionPushConfig

data class GetSubscriptionPushConfig(val attributes: Map<String, String>, val noWrappers: List<GetSubscriptionPushConfigNoWrapper>, val oidcTokens: List<GetSubscriptionPushConfigOidcToken>, val pushEndpoint: String)

GetSubscriptionPushConfigNoWrapper

data class GetSubscriptionPushConfigNoWrapper(val writeMetadata: Boolean)

GetSubscriptionPushConfigOidcToken

data class GetSubscriptionPushConfigOidcToken(val audience: String, val serviceAccountEmail: String)

GetSubscriptionResult

data class GetSubscriptionResult(val ackDeadlineSeconds: Int, val bigqueryConfigs: List<GetSubscriptionBigqueryConfig>, val cloudStorageConfigs: List<GetSubscriptionCloudStorageConfig>, val deadLetterPolicies: List<GetSubscriptionDeadLetterPolicy>, val effectiveLabels: Map<String, String>, val enableExactlyOnceDelivery: Boolean, val enableMessageOrdering: Boolean, val expirationPolicies: List<GetSubscriptionExpirationPolicy>, val filter: String, val id: String, val labels: Map<String, String>, val messageRetentionDuration: String, val name: String, val project: String? = null, val pulumiLabels: Map<String, String>, val pushConfigs: List<GetSubscriptionPushConfig>, val retainAckedMessages: Boolean, val retryPolicies: List<GetSubscriptionRetryPolicy>, val topic: String)

A collection of values returned by getSubscription.

GetSubscriptionRetryPolicy

data class GetSubscriptionRetryPolicy(val maximumBackoff: String, val minimumBackoff: String)

GetTopicIamPolicyResult

data class GetTopicIamPolicyResult(val etag: String, val id: String, val policyData: String, val project: String, val topic: String)

A collection of values returned by getTopicIamPolicy.

GetTopicIngestionDataSourceSetting

data class GetTopicIngestionDataSourceSetting(val awsKineses: List<GetTopicIngestionDataSourceSettingAwsKinese>, val awsMsks: List<GetTopicIngestionDataSourceSettingAwsMsk>, val azureEventHubs: List<GetTopicIngestionDataSourceSettingAzureEventHub>, val cloudStorages: List<GetTopicIngestionDataSourceSettingCloudStorage>, val confluentClouds: List<GetTopicIngestionDataSourceSettingConfluentCloud>, val platformLogsSettings: List<GetTopicIngestionDataSourceSettingPlatformLogsSetting>)

GetTopicIngestionDataSourceSettingAwsKinese

data class GetTopicIngestionDataSourceSettingAwsKinese(val awsRoleArn: String, val consumerArn: String, val gcpServiceAccount: String, val streamArn: String)

GetTopicIngestionDataSourceSettingAwsMsk

data class GetTopicIngestionDataSourceSettingAwsMsk(val awsRoleArn: String, val clusterArn: String, val gcpServiceAccount: String, val topic: String)

GetTopicIngestionDataSourceSettingAzureEventHub

data class GetTopicIngestionDataSourceSettingAzureEventHub(val clientId: String, val eventHub: String, val gcpServiceAccount: String, val namespace: String, val resourceGroup: String, val subscriptionId: String, val tenantId: String)

GetTopicIngestionDataSourceSettingCloudStorage

data class GetTopicIngestionDataSourceSettingCloudStorage(val avroFormats: List<GetTopicIngestionDataSourceSettingCloudStorageAvroFormat>, val bucket: String, val matchGlob: String, val minimumObjectCreateTime: String, val pubsubAvroFormats: List<GetTopicIngestionDataSourceSettingCloudStoragePubsubAvroFormat>, val textFormats: List<GetTopicIngestionDataSourceSettingCloudStorageTextFormat>)

GetTopicIngestionDataSourceSettingCloudStorageAvroFormat

class GetTopicIngestionDataSourceSettingCloudStorageAvroFormat

GetTopicIngestionDataSourceSettingCloudStoragePubsubAvroFormat

class GetTopicIngestionDataSourceSettingCloudStoragePubsubAvroFormat

GetTopicIngestionDataSourceSettingCloudStorageTextFormat

data class GetTopicIngestionDataSourceSettingCloudStorageTextFormat(val delimiter: String)

GetTopicIngestionDataSourceSettingConfluentCloud

data class GetTopicIngestionDataSourceSettingConfluentCloud(val bootstrapServer: String, val clusterId: String, val gcpServiceAccount: String, val identityPoolId: String, val topic: String)

GetTopicIngestionDataSourceSettingPlatformLogsSetting

data class GetTopicIngestionDataSourceSettingPlatformLogsSetting(val severity: String)

GetTopicMessageStoragePolicy

data class GetTopicMessageStoragePolicy(val allowedPersistenceRegions: List<String>, val enforceInTransit: Boolean)

GetTopicResult

data class GetTopicResult(val effectiveLabels: Map<String, String>, val id: String, val ingestionDataSourceSettings: List<GetTopicIngestionDataSourceSetting>, val kmsKeyName: String, val labels: Map<String, String>, val messageRetentionDuration: String, val messageStoragePolicies: List<GetTopicMessageStoragePolicy>, val name: String, val project: String? = null, val pulumiLabels: Map<String, String>, val schemaSettings: List<GetTopicSchemaSetting>)

A collection of values returned by getTopic.

GetTopicSchemaSetting

data class GetTopicSchemaSetting(val encoding: String, val schema: String)

LiteSubscriptionDeliveryConfig

data class LiteSubscriptionDeliveryConfig(val deliveryRequirement: String)

LiteTopicPartitionConfig

data class LiteTopicPartitionConfig(val capacity: LiteTopicPartitionConfigCapacity? = null, val count: Int)

LiteTopicPartitionConfigCapacity

data class LiteTopicPartitionConfigCapacity(val publishMibPerSec: Int, val subscribeMibPerSec: Int)

LiteTopicReservationConfig

data class LiteTopicReservationConfig(val throughputReservation: String? = null)

LiteTopicRetentionConfig

data class LiteTopicRetentionConfig(val perPartitionBytes: String, val period: String? = null)

SchemaIamBindingCondition

data class SchemaIamBindingCondition(val description: String? = null, val expression: String, val title: String)

SchemaIamMemberCondition

data class SchemaIamMemberCondition(val description: String? = null, val expression: String, val title: String)

SubscriptionBigqueryConfig

data class SubscriptionBigqueryConfig(val dropUnknownFields: Boolean? = null, val serviceAccountEmail: String? = null, val table: String, val useTableSchema: Boolean? = null, val useTopicSchema: Boolean? = null, val writeMetadata: Boolean? = null)

SubscriptionCloudStorageConfig

data class SubscriptionCloudStorageConfig(val avroConfig: SubscriptionCloudStorageConfigAvroConfig? = null, val bucket: String, val filenameDatetimeFormat: String? = null, val filenamePrefix: String? = null, val filenameSuffix: String? = null, val maxBytes: Int? = null, val maxDuration: String? = null, val maxMessages: Int? = null, val serviceAccountEmail: String? = null, val state: String? = null)

SubscriptionCloudStorageConfigAvroConfig

data class SubscriptionCloudStorageConfigAvroConfig(val useTopicSchema: Boolean? = null, val writeMetadata: Boolean? = null)

SubscriptionDeadLetterPolicy

data class SubscriptionDeadLetterPolicy(val deadLetterTopic: String? = null, val maxDeliveryAttempts: Int? = null)

SubscriptionExpirationPolicy

data class SubscriptionExpirationPolicy(val ttl: String)

SubscriptionIAMBindingCondition

data class SubscriptionIAMBindingCondition(val description: String? = null, val expression: String, val title: String)

SubscriptionIAMMemberCondition

data class SubscriptionIAMMemberCondition(val description: String? = null, val expression: String, val title: String)

SubscriptionPushConfig

data class SubscriptionPushConfig(val attributes: Map<String, String>? = null, val noWrapper: SubscriptionPushConfigNoWrapper? = null, val oidcToken: SubscriptionPushConfigOidcToken? = null, val pushEndpoint: String)

SubscriptionPushConfigNoWrapper

data class SubscriptionPushConfigNoWrapper(val writeMetadata: Boolean)

SubscriptionPushConfigOidcToken

data class SubscriptionPushConfigOidcToken(val audience: String? = null, val serviceAccountEmail: String)

SubscriptionRetryPolicy

data class SubscriptionRetryPolicy(val maximumBackoff: String? = null, val minimumBackoff: String? = null)

TopicIAMBindingCondition

data class TopicIAMBindingCondition(val description: String? = null, val expression: String, val title: String)

TopicIAMMemberCondition

data class TopicIAMMemberCondition(val description: String? = null, val expression: String, val title: String)

TopicIngestionDataSourceSettings

data class TopicIngestionDataSourceSettings(val awsKinesis: TopicIngestionDataSourceSettingsAwsKinesis? = null, val awsMsk: TopicIngestionDataSourceSettingsAwsMsk? = null, val azureEventHubs: TopicIngestionDataSourceSettingsAzureEventHubs? = null, val cloudStorage: TopicIngestionDataSourceSettingsCloudStorage? = null, val confluentCloud: TopicIngestionDataSourceSettingsConfluentCloud? = null, val platformLogsSettings: TopicIngestionDataSourceSettingsPlatformLogsSettings? = null)

TopicIngestionDataSourceSettingsAwsKinesis

data class TopicIngestionDataSourceSettingsAwsKinesis(val awsRoleArn: String, val consumerArn: String, val gcpServiceAccount: String, val streamArn: String)

TopicIngestionDataSourceSettingsAwsMsk

data class TopicIngestionDataSourceSettingsAwsMsk(val awsRoleArn: String, val clusterArn: String, val gcpServiceAccount: String, val topic: String)

TopicIngestionDataSourceSettingsAzureEventHubs

data class TopicIngestionDataSourceSettingsAzureEventHubs(val clientId: String? = null, val eventHub: String? = null, val gcpServiceAccount: String? = null, val namespace: String? = null, val resourceGroup: String? = null, val subscriptionId: String? = null, val tenantId: String? = null)

TopicIngestionDataSourceSettingsCloudStorage

data class TopicIngestionDataSourceSettingsCloudStorage(val avroFormat: TopicIngestionDataSourceSettingsCloudStorageAvroFormat? = null, val bucket: String, val matchGlob: String? = null, val minimumObjectCreateTime: String? = null, val pubsubAvroFormat: TopicIngestionDataSourceSettingsCloudStoragePubsubAvroFormat? = null, val textFormat: TopicIngestionDataSourceSettingsCloudStorageTextFormat? = null)

TopicIngestionDataSourceSettingsCloudStorageAvroFormat

class TopicIngestionDataSourceSettingsCloudStorageAvroFormat

TopicIngestionDataSourceSettingsCloudStoragePubsubAvroFormat

class TopicIngestionDataSourceSettingsCloudStoragePubsubAvroFormat

TopicIngestionDataSourceSettingsCloudStorageTextFormat

data class TopicIngestionDataSourceSettingsCloudStorageTextFormat(val delimiter: String? = null)

TopicIngestionDataSourceSettingsConfluentCloud

data class TopicIngestionDataSourceSettingsConfluentCloud(val bootstrapServer: String, val clusterId: String? = null, val gcpServiceAccount: String, val identityPoolId: String, val topic: String)

TopicIngestionDataSourceSettingsPlatformLogsSettings

data class TopicIngestionDataSourceSettingsPlatformLogsSettings(val severity: String? = null)

TopicMessageStoragePolicy

data class TopicMessageStoragePolicy(val allowedPersistenceRegions: List<String>, val enforceInTransit: Boolean? = null)

TopicSchemaSettings

data class TopicSchemaSettings(val encoding: String? = null, val schema: String)