Documentation ¶
Index ¶
- func NewPubsubSubscriptionBigqueryConfigOutputReference_Override(p PubsubSubscriptionBigqueryConfigOutputReference, ...)
- func NewPubsubSubscriptionCloudStorageConfigAvroConfigOutputReference_Override(p PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference, ...)
- func NewPubsubSubscriptionCloudStorageConfigOutputReference_Override(p PubsubSubscriptionCloudStorageConfigOutputReference, ...)
- func NewPubsubSubscriptionDeadLetterPolicyOutputReference_Override(p PubsubSubscriptionDeadLetterPolicyOutputReference, ...)
- func NewPubsubSubscriptionExpirationPolicyOutputReference_Override(p PubsubSubscriptionExpirationPolicyOutputReference, ...)
- func NewPubsubSubscriptionPushConfigNoWrapperOutputReference_Override(p PubsubSubscriptionPushConfigNoWrapperOutputReference, ...)
- func NewPubsubSubscriptionPushConfigOidcTokenOutputReference_Override(p PubsubSubscriptionPushConfigOidcTokenOutputReference, ...)
- func NewPubsubSubscriptionPushConfigOutputReference_Override(p PubsubSubscriptionPushConfigOutputReference, ...)
- func NewPubsubSubscriptionRetryPolicyOutputReference_Override(p PubsubSubscriptionRetryPolicyOutputReference, ...)
- func NewPubsubSubscriptionTimeoutsOutputReference_Override(p PubsubSubscriptionTimeoutsOutputReference, ...)
- func NewPubsubSubscription_Override(p PubsubSubscription, scope constructs.Construct, id *string, ...)
- func PubsubSubscription_GenerateConfigForImport(scope constructs.Construct, importToId *string, importFromId *string, ...) cdktf.ImportableResource
- func PubsubSubscription_IsConstruct(x interface{}) *bool
- func PubsubSubscription_IsTerraformElement(x interface{}) *bool
- func PubsubSubscription_IsTerraformResource(x interface{}) *bool
- func PubsubSubscription_TfResourceType() *string
- type PubsubSubscription
- type PubsubSubscriptionBigqueryConfig
- type PubsubSubscriptionBigqueryConfigOutputReference
- type PubsubSubscriptionCloudStorageConfig
- type PubsubSubscriptionCloudStorageConfigAvroConfig
- type PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference
- type PubsubSubscriptionCloudStorageConfigOutputReference
- type PubsubSubscriptionConfig
- type PubsubSubscriptionDeadLetterPolicy
- type PubsubSubscriptionDeadLetterPolicyOutputReference
- type PubsubSubscriptionExpirationPolicy
- type PubsubSubscriptionExpirationPolicyOutputReference
- type PubsubSubscriptionPushConfig
- type PubsubSubscriptionPushConfigNoWrapper
- type PubsubSubscriptionPushConfigNoWrapperOutputReference
- type PubsubSubscriptionPushConfigOidcToken
- type PubsubSubscriptionPushConfigOidcTokenOutputReference
- type PubsubSubscriptionPushConfigOutputReference
- type PubsubSubscriptionRetryPolicy
- type PubsubSubscriptionRetryPolicyOutputReference
- type PubsubSubscriptionTimeouts
- type PubsubSubscriptionTimeoutsOutputReference
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPubsubSubscriptionBigqueryConfigOutputReference_Override ¶
func NewPubsubSubscriptionBigqueryConfigOutputReference_Override(p PubsubSubscriptionBigqueryConfigOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionCloudStorageConfigAvroConfigOutputReference_Override ¶
func NewPubsubSubscriptionCloudStorageConfigAvroConfigOutputReference_Override(p PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionCloudStorageConfigOutputReference_Override ¶
func NewPubsubSubscriptionCloudStorageConfigOutputReference_Override(p PubsubSubscriptionCloudStorageConfigOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionDeadLetterPolicyOutputReference_Override ¶
func NewPubsubSubscriptionDeadLetterPolicyOutputReference_Override(p PubsubSubscriptionDeadLetterPolicyOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionExpirationPolicyOutputReference_Override ¶
func NewPubsubSubscriptionExpirationPolicyOutputReference_Override(p PubsubSubscriptionExpirationPolicyOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionPushConfigNoWrapperOutputReference_Override ¶
func NewPubsubSubscriptionPushConfigNoWrapperOutputReference_Override(p PubsubSubscriptionPushConfigNoWrapperOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionPushConfigOidcTokenOutputReference_Override ¶
func NewPubsubSubscriptionPushConfigOidcTokenOutputReference_Override(p PubsubSubscriptionPushConfigOidcTokenOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionPushConfigOutputReference_Override ¶
func NewPubsubSubscriptionPushConfigOutputReference_Override(p PubsubSubscriptionPushConfigOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionRetryPolicyOutputReference_Override ¶
func NewPubsubSubscriptionRetryPolicyOutputReference_Override(p PubsubSubscriptionRetryPolicyOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscriptionTimeoutsOutputReference_Override ¶
func NewPubsubSubscriptionTimeoutsOutputReference_Override(p PubsubSubscriptionTimeoutsOutputReference, terraformResource cdktf.IInterpolatingParent, terraformAttribute *string)
func NewPubsubSubscription_Override ¶
func NewPubsubSubscription_Override(p PubsubSubscription, scope constructs.Construct, id *string, config *PubsubSubscriptionConfig)
Create a new {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription google_pubsub_subscription} Resource.
func PubsubSubscription_GenerateConfigForImport ¶
func PubsubSubscription_GenerateConfigForImport(scope constructs.Construct, importToId *string, importFromId *string, provider cdktf.TerraformProvider) cdktf.ImportableResource
Generates CDKTF code for importing a PubsubSubscription resource upon running "cdktf plan <stack-name>".
func PubsubSubscription_IsConstruct ¶
func PubsubSubscription_IsConstruct(x interface{}) *bool
Checks if `x` is a construct.
Use this method instead of `instanceof` to properly detect `Construct` instances, even when the construct library is symlinked.
Explanation: in JavaScript, multiple copies of the `constructs` library on disk are seen as independent, completely different libraries. As a consequence, the class `Construct` in each copy of the `constructs` library is seen as a different class, and an instance of one class will not test as `instanceof` the other class. `npm install` will not create installations like this, but users may manually symlink construct libraries together or use a monorepo tool: in those cases, multiple copies of the `constructs` library can be accidentally installed, and `instanceof` will behave unpredictably. It is safest to avoid using `instanceof`, and using this type-testing method instead.
Returns: true if `x` is an object created from a class which extends `Construct`.
func PubsubSubscription_IsTerraformElement ¶
func PubsubSubscription_IsTerraformElement(x interface{}) *bool
Experimental.
func PubsubSubscription_IsTerraformResource ¶
func PubsubSubscription_IsTerraformResource(x interface{}) *bool
Experimental.
func PubsubSubscription_TfResourceType ¶
func PubsubSubscription_TfResourceType() *string
Types ¶
type PubsubSubscription ¶
type PubsubSubscription interface { cdktf.TerraformResource AckDeadlineSeconds() *float64 SetAckDeadlineSeconds(val *float64) AckDeadlineSecondsInput() *float64 BigqueryConfig() PubsubSubscriptionBigqueryConfigOutputReference BigqueryConfigInput() *PubsubSubscriptionBigqueryConfig // Experimental. CdktfStack() cdktf.TerraformStack CloudStorageConfig() PubsubSubscriptionCloudStorageConfigOutputReference CloudStorageConfigInput() *PubsubSubscriptionCloudStorageConfig // Experimental. Connection() interface{} // Experimental. SetConnection(val interface{}) // Experimental. ConstructNodeMetadata() *map[string]interface{} // Experimental. Count() interface{} // Experimental. SetCount(val interface{}) DeadLetterPolicy() PubsubSubscriptionDeadLetterPolicyOutputReference DeadLetterPolicyInput() *PubsubSubscriptionDeadLetterPolicy // Experimental. DependsOn() *[]*string // Experimental. SetDependsOn(val *[]*string) EffectiveLabels() cdktf.StringMap EnableExactlyOnceDelivery() interface{} SetEnableExactlyOnceDelivery(val interface{}) EnableExactlyOnceDeliveryInput() interface{} EnableMessageOrdering() interface{} SetEnableMessageOrdering(val interface{}) EnableMessageOrderingInput() interface{} ExpirationPolicy() PubsubSubscriptionExpirationPolicyOutputReference ExpirationPolicyInput() *PubsubSubscriptionExpirationPolicy Filter() *string SetFilter(val *string) FilterInput() *string // Experimental. ForEach() cdktf.ITerraformIterator // Experimental. SetForEach(val cdktf.ITerraformIterator) // Experimental. Fqn() *string // Experimental. FriendlyUniqueId() *string Id() *string SetId(val *string) IdInput() *string Labels() *map[string]*string SetLabels(val *map[string]*string) LabelsInput() *map[string]*string // Experimental. Lifecycle() *cdktf.TerraformResourceLifecycle // Experimental. SetLifecycle(val *cdktf.TerraformResourceLifecycle) MessageRetentionDuration() *string SetMessageRetentionDuration(val *string) MessageRetentionDurationInput() *string Name() *string SetName(val *string) NameInput() *string // The tree node. Node() constructs.Node Project() *string SetProject(val *string) ProjectInput() *string // Experimental. Provider() cdktf.TerraformProvider // Experimental. SetProvider(val cdktf.TerraformProvider) // Experimental. Provisioners() *[]interface{} // Experimental. SetProvisioners(val *[]interface{}) PushConfig() PubsubSubscriptionPushConfigOutputReference PushConfigInput() *PubsubSubscriptionPushConfig // Experimental. RawOverrides() interface{} RetainAckedMessages() interface{} SetRetainAckedMessages(val interface{}) RetainAckedMessagesInput() interface{} RetryPolicy() PubsubSubscriptionRetryPolicyOutputReference RetryPolicyInput() *PubsubSubscriptionRetryPolicy // Experimental. TerraformGeneratorMetadata() *cdktf.TerraformProviderGeneratorMetadata TerraformLabels() cdktf.StringMap // Experimental. TerraformMetaArguments() *map[string]interface{} // Experimental. TerraformResourceType() *string Timeouts() PubsubSubscriptionTimeoutsOutputReference TimeoutsInput() interface{} Topic() *string SetTopic(val *string) TopicInput() *string // Adds a user defined moveTarget string to this resource to be later used in .moveTo(moveTarget) to resolve the location of the move. // Experimental. AddMoveTarget(moveTarget *string) // Experimental. AddOverride(path *string, value interface{}) // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. HasResourceMove() interface{} // Experimental. ImportFrom(id *string, provider cdktf.TerraformProvider) // Experimental. InterpolationForAttribute(terraformAttribute *string) cdktf.IResolvable // Move the resource corresponding to "id" to this resource. // // Note that the resource being moved from must be marked as moved using it's instance function. // Experimental. MoveFromId(id *string) // Moves this resource to the target resource given by moveTarget. // Experimental. MoveTo(moveTarget *string, index interface{}) // Moves this resource to the resource corresponding to "id". // Experimental. MoveToId(id *string) // Overrides the auto-generated logical ID with a specific ID. // Experimental. OverrideLogicalId(newLogicalId *string) PutBigqueryConfig(value *PubsubSubscriptionBigqueryConfig) PutCloudStorageConfig(value *PubsubSubscriptionCloudStorageConfig) PutDeadLetterPolicy(value *PubsubSubscriptionDeadLetterPolicy) PutExpirationPolicy(value *PubsubSubscriptionExpirationPolicy) PutPushConfig(value *PubsubSubscriptionPushConfig) PutRetryPolicy(value *PubsubSubscriptionRetryPolicy) PutTimeouts(value *PubsubSubscriptionTimeouts) ResetAckDeadlineSeconds() ResetBigqueryConfig() ResetCloudStorageConfig() ResetDeadLetterPolicy() ResetEnableExactlyOnceDelivery() ResetEnableMessageOrdering() ResetExpirationPolicy() ResetFilter() ResetId() ResetLabels() ResetMessageRetentionDuration() // Resets a previously passed logical Id to use the auto-generated logical id again. // Experimental. ResetOverrideLogicalId() ResetProject() ResetPushConfig() ResetRetainAckedMessages() ResetRetryPolicy() ResetTimeouts() SynthesizeAttributes() *map[string]interface{} SynthesizeHclAttributes() *map[string]interface{} // Experimental. ToHclTerraform() interface{} // Experimental. ToMetadata() interface{} // Returns a string representation of this construct. ToString() *string // Adds this resource to the terraform JSON output. // Experimental. ToTerraform() interface{} }
Represents a {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription google_pubsub_subscription}.
func NewPubsubSubscription ¶
func NewPubsubSubscription(scope constructs.Construct, id *string, config *PubsubSubscriptionConfig) PubsubSubscription
Create a new {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription google_pubsub_subscription} Resource.
type PubsubSubscriptionBigqueryConfig ¶
type PubsubSubscriptionBigqueryConfig struct { // The name of the table to which to write data, of the form {projectId}.{datasetId}.{tableId}. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#table PubsubSubscription#table} Table *string `field:"required" json:"table" yaml:"table"` // When true and use_topic_schema or use_table_schema is true, any fields that are a part of the topic schema or message schema that are not part of the BigQuery table schema are dropped when writing to BigQuery. // // Otherwise, the schemas must be kept in sync // and any messages with extra fields are not written and remain in the subscription's backlog. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#drop_unknown_fields PubsubSubscription#drop_unknown_fields} DropUnknownFields interface{} `field:"optional" json:"dropUnknownFields" yaml:"dropUnknownFields"` // The service account to use to write to BigQuery. If not specified, the Pub/Sub [service agent](https://cloud.google.com/iam/docs/service-agents), service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#service_account_email PubsubSubscription#service_account_email} ServiceAccountEmail *string `field:"optional" json:"serviceAccountEmail" yaml:"serviceAccountEmail"` // When true, use the BigQuery table's schema as the columns to write to in BigQuery. // // Messages // must be published in JSON format. Only one of use_topic_schema and use_table_schema can be set. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#use_table_schema PubsubSubscription#use_table_schema} UseTableSchema interface{} `field:"optional" json:"useTableSchema" yaml:"useTableSchema"` // When true, use the topic's schema as the columns to write to in BigQuery, if it exists. // // Only one of use_topic_schema and use_table_schema can be set. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#use_topic_schema PubsubSubscription#use_topic_schema} UseTopicSchema interface{} `field:"optional" json:"useTopicSchema" yaml:"useTopicSchema"` // When true, write the subscription name, messageId, publishTime, attributes, and orderingKey to additional columns in the table. // // The subscription name, messageId, and publishTime fields are put in their own columns while all other message properties (other than data) are written to a JSON object in the attributes column. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#write_metadata PubsubSubscription#write_metadata} WriteMetadata interface{} `field:"optional" json:"writeMetadata" yaml:"writeMetadata"` }
type PubsubSubscriptionBigqueryConfigOutputReference ¶
type PubsubSubscriptionBigqueryConfigOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string DropUnknownFields() interface{} SetDropUnknownFields(val interface{}) DropUnknownFieldsInput() interface{} // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionBigqueryConfig SetInternalValue(val *PubsubSubscriptionBigqueryConfig) ServiceAccountEmail() *string SetServiceAccountEmail(val *string) ServiceAccountEmailInput() *string Table() *string SetTable(val *string) TableInput() *string // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) UseTableSchema() interface{} SetUseTableSchema(val interface{}) UseTableSchemaInput() interface{} UseTopicSchema() interface{} SetUseTopicSchema(val interface{}) UseTopicSchemaInput() interface{} WriteMetadata() interface{} SetWriteMetadata(val interface{}) WriteMetadataInput() interface{} // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetDropUnknownFields() ResetServiceAccountEmail() ResetUseTableSchema() ResetUseTopicSchema() ResetWriteMetadata() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionBigqueryConfigOutputReference ¶
func NewPubsubSubscriptionBigqueryConfigOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionBigqueryConfigOutputReference
type PubsubSubscriptionCloudStorageConfig ¶
type PubsubSubscriptionCloudStorageConfig struct { // User-provided name for the Cloud Storage bucket. // // The bucket must be created by the user. The bucket name must be without any prefix like "gs://". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#bucket PubsubSubscription#bucket} Bucket *string `field:"required" json:"bucket" yaml:"bucket"` // avro_config block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#avro_config PubsubSubscription#avro_config} AvroConfig *PubsubSubscriptionCloudStorageConfigAvroConfig `field:"optional" json:"avroConfig" yaml:"avroConfig"` // User-provided format string specifying how to represent datetimes in Cloud Storage filenames. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#filename_datetime_format PubsubSubscription#filename_datetime_format} FilenameDatetimeFormat *string `field:"optional" json:"filenameDatetimeFormat" yaml:"filenameDatetimeFormat"` // User-provided prefix for Cloud Storage filename. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#filename_prefix PubsubSubscription#filename_prefix} FilenamePrefix *string `field:"optional" json:"filenamePrefix" yaml:"filenamePrefix"` // User-provided suffix for Cloud Storage filename. Must not end in "/". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#filename_suffix PubsubSubscription#filename_suffix} FilenameSuffix *string `field:"optional" json:"filenameSuffix" yaml:"filenameSuffix"` // The maximum bytes that can be written to a Cloud Storage file before a new file is created. // // Min 1 KB, max 10 GiB. // The maxBytes limit may be exceeded in cases where messages are larger than the limit. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#max_bytes PubsubSubscription#max_bytes} MaxBytes *float64 `field:"optional" json:"maxBytes" yaml:"maxBytes"` // The maximum duration that can elapse before a new Cloud Storage file is created. // // Min 1 minute, max 10 minutes, default 5 minutes. // May not exceed the subscription's acknowledgement deadline. // A duration in seconds with up to nine fractional digits, ending with 's'. Example: "3.5s". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#max_duration PubsubSubscription#max_duration} MaxDuration *string `field:"optional" json:"maxDuration" yaml:"maxDuration"` // The maximum messages that can be written to a Cloud Storage file before a new file is created. // // Min 1000 messages. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#max_messages PubsubSubscription#max_messages} MaxMessages *float64 `field:"optional" json:"maxMessages" yaml:"maxMessages"` // The service account to use to write to Cloud Storage. If not specified, the Pub/Sub [service agent](https://cloud.google.com/iam/docs/service-agents), service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#service_account_email PubsubSubscription#service_account_email} ServiceAccountEmail *string `field:"optional" json:"serviceAccountEmail" yaml:"serviceAccountEmail"` }
type PubsubSubscriptionCloudStorageConfigAvroConfig ¶
type PubsubSubscriptionCloudStorageConfigAvroConfig struct { // When true, the output Cloud Storage file will be serialized using the topic schema, if it exists. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#use_topic_schema PubsubSubscription#use_topic_schema} UseTopicSchema interface{} `field:"optional" json:"useTopicSchema" yaml:"useTopicSchema"` // When true, write the subscription name, messageId, publishTime, attributes, and orderingKey as additional fields in the output. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#write_metadata PubsubSubscription#write_metadata} WriteMetadata interface{} `field:"optional" json:"writeMetadata" yaml:"writeMetadata"` }
type PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference ¶
type PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionCloudStorageConfigAvroConfig SetInternalValue(val *PubsubSubscriptionCloudStorageConfigAvroConfig) // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) UseTopicSchema() interface{} SetUseTopicSchema(val interface{}) UseTopicSchemaInput() interface{} WriteMetadata() interface{} SetWriteMetadata(val interface{}) WriteMetadataInput() interface{} // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetUseTopicSchema() ResetWriteMetadata() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionCloudStorageConfigAvroConfigOutputReference ¶
func NewPubsubSubscriptionCloudStorageConfigAvroConfigOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference
type PubsubSubscriptionCloudStorageConfigOutputReference ¶
type PubsubSubscriptionCloudStorageConfigOutputReference interface { cdktf.ComplexObject AvroConfig() PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference AvroConfigInput() *PubsubSubscriptionCloudStorageConfigAvroConfig Bucket() *string SetBucket(val *string) BucketInput() *string // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string FilenameDatetimeFormat() *string SetFilenameDatetimeFormat(val *string) FilenameDatetimeFormatInput() *string FilenamePrefix() *string SetFilenamePrefix(val *string) FilenamePrefixInput() *string FilenameSuffix() *string SetFilenameSuffix(val *string) FilenameSuffixInput() *string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionCloudStorageConfig SetInternalValue(val *PubsubSubscriptionCloudStorageConfig) MaxBytes() *float64 SetMaxBytes(val *float64) MaxBytesInput() *float64 MaxDuration() *string SetMaxDuration(val *string) MaxDurationInput() *string MaxMessages() *float64 SetMaxMessages(val *float64) MaxMessagesInput() *float64 ServiceAccountEmail() *string SetServiceAccountEmail(val *string) ServiceAccountEmailInput() *string State() *string // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable PutAvroConfig(value *PubsubSubscriptionCloudStorageConfigAvroConfig) ResetAvroConfig() ResetFilenameDatetimeFormat() ResetFilenamePrefix() ResetFilenameSuffix() ResetMaxBytes() ResetMaxDuration() ResetMaxMessages() ResetServiceAccountEmail() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionCloudStorageConfigOutputReference ¶
func NewPubsubSubscriptionCloudStorageConfigOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionCloudStorageConfigOutputReference
type PubsubSubscriptionConfig ¶
type PubsubSubscriptionConfig struct { // Experimental. Connection interface{} `field:"optional" json:"connection" yaml:"connection"` // Experimental. Count interface{} `field:"optional" json:"count" yaml:"count"` // Experimental. DependsOn *[]cdktf.ITerraformDependable `field:"optional" json:"dependsOn" yaml:"dependsOn"` // Experimental. ForEach cdktf.ITerraformIterator `field:"optional" json:"forEach" yaml:"forEach"` // Experimental. Lifecycle *cdktf.TerraformResourceLifecycle `field:"optional" json:"lifecycle" yaml:"lifecycle"` // Experimental. Provider cdktf.TerraformProvider `field:"optional" json:"provider" yaml:"provider"` // Experimental. Provisioners *[]interface{} `field:"optional" json:"provisioners" yaml:"provisioners"` // Name of the subscription. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#name PubsubSubscription#name} Name *string `field:"required" json:"name" yaml:"name"` // A reference to a Topic resource, of the form projects/{project}/topics/{{name}} (as in the id property of a google_pubsub_topic), or just a topic name if the topic is in the same project as the subscription. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#topic PubsubSubscription#topic} Topic *string `field:"required" json:"topic" yaml:"topic"` // This value is the maximum time after a subscriber receives a message before the subscriber should acknowledge the message. // // After message // delivery but before the ack deadline expires and before the message is // acknowledged, it is an outstanding message and will not be delivered // again during that time (on a best-effort basis). // // For pull subscriptions, this value is used as the initial value for // the ack deadline. To override this value for a given message, call // subscriptions.modifyAckDeadline with the corresponding ackId if using // pull. The minimum custom deadline you can specify is 10 seconds. The // maximum custom deadline you can specify is 600 seconds (10 minutes). // If this parameter is 0, a default value of 10 seconds is used. // // For push delivery, this value is also used to set the request timeout // for the call to the push endpoint. // // If the subscriber never acknowledges the message, the Pub/Sub system // will eventually redeliver the message. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#ack_deadline_seconds PubsubSubscription#ack_deadline_seconds} AckDeadlineSeconds *float64 `field:"optional" json:"ackDeadlineSeconds" yaml:"ackDeadlineSeconds"` // bigquery_config block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#bigquery_config PubsubSubscription#bigquery_config} BigqueryConfig *PubsubSubscriptionBigqueryConfig `field:"optional" json:"bigqueryConfig" yaml:"bigqueryConfig"` // cloud_storage_config block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#cloud_storage_config PubsubSubscription#cloud_storage_config} CloudStorageConfig *PubsubSubscriptionCloudStorageConfig `field:"optional" json:"cloudStorageConfig" yaml:"cloudStorageConfig"` // dead_letter_policy block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#dead_letter_policy PubsubSubscription#dead_letter_policy} DeadLetterPolicy *PubsubSubscriptionDeadLetterPolicy `field:"optional" json:"deadLetterPolicy" yaml:"deadLetterPolicy"` // If 'true', Pub/Sub provides the following guarantees for the delivery of a message with a given value of messageId on this Subscriptions': - The message sent to a subscriber is guaranteed not to be resent before the message's acknowledgement deadline expires. // // - An acknowledged message will not be resent to a subscriber. // // Note that subscribers may still receive multiple copies of a message when 'enable_exactly_once_delivery' // is true if the message was published multiple times by a publisher client. These copies are considered distinct by Pub/Sub and have distinct messageId values // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#enable_exactly_once_delivery PubsubSubscription#enable_exactly_once_delivery} EnableExactlyOnceDelivery interface{} `field:"optional" json:"enableExactlyOnceDelivery" yaml:"enableExactlyOnceDelivery"` // If 'true', messages published with the same orderingKey in PubsubMessage will be delivered to the subscribers in the order in which they are received by the Pub/Sub system. // // Otherwise, they // may be delivered in any order. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#enable_message_ordering PubsubSubscription#enable_message_ordering} EnableMessageOrdering interface{} `field:"optional" json:"enableMessageOrdering" yaml:"enableMessageOrdering"` // expiration_policy block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#expiration_policy PubsubSubscription#expiration_policy} ExpirationPolicy *PubsubSubscriptionExpirationPolicy `field:"optional" json:"expirationPolicy" yaml:"expirationPolicy"` // The subscription only delivers the messages that match the filter. // // Pub/Sub automatically acknowledges the messages that don't match the filter. You can filter messages // by their attributes. The maximum length of a filter is 256 bytes. After creating the subscription, // you can't modify the filter. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#filter PubsubSubscription#filter} Filter *string `field:"optional" json:"filter" yaml:"filter"` // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#id PubsubSubscription#id}. // // Please be aware that the id field is automatically added to all resources in Terraform providers using a Terraform provider SDK version below 2. // If you experience problems setting this value it might not be settable. Please take a look at the provider documentation to ensure it should be settable. Id *string `field:"optional" json:"id" yaml:"id"` // A set of key/value label pairs to assign to this Subscription. // // **Note**: This field is non-authoritative, and will only manage the labels present in your configuration. // Please refer to the field 'effective_labels' for all of the labels present on the resource. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#labels PubsubSubscription#labels} Labels *map[string]*string `field:"optional" json:"labels" yaml:"labels"` // How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. // // If // retain_acked_messages is true, then this also configures the retention // of acknowledged messages, and thus configures how far back in time a // subscriptions.seek can be done. Defaults to 7 days. Cannot be more // than 31 days ('"2678400s"') or less than 10 minutes ('"600s"'). // // A duration in seconds with up to nine fractional digits, terminated // by 's'. Example: '"600.5s"'. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#message_retention_duration PubsubSubscription#message_retention_duration} MessageRetentionDuration *string `field:"optional" json:"messageRetentionDuration" yaml:"messageRetentionDuration"` // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#project PubsubSubscription#project}. Project *string `field:"optional" json:"project" yaml:"project"` // push_config block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#push_config PubsubSubscription#push_config} PushConfig *PubsubSubscriptionPushConfig `field:"optional" json:"pushConfig" yaml:"pushConfig"` // Indicates whether to retain acknowledged messages. // // If 'true', then // messages are not expunged from the subscription's backlog, even if // they are acknowledged, until they fall out of the // messageRetentionDuration window. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#retain_acked_messages PubsubSubscription#retain_acked_messages} RetainAckedMessages interface{} `field:"optional" json:"retainAckedMessages" yaml:"retainAckedMessages"` // retry_policy block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#retry_policy PubsubSubscription#retry_policy} RetryPolicy *PubsubSubscriptionRetryPolicy `field:"optional" json:"retryPolicy" yaml:"retryPolicy"` // timeouts block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#timeouts PubsubSubscription#timeouts} Timeouts *PubsubSubscriptionTimeouts `field:"optional" json:"timeouts" yaml:"timeouts"` }
type PubsubSubscriptionDeadLetterPolicy ¶
type PubsubSubscriptionDeadLetterPolicy struct { // The name of the topic to which dead letter messages should be published. Format is 'projects/{project}/topics/{topic}'. // // The Cloud Pub/Sub service account associated with the enclosing subscription's // parent project (i.e., // service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have // permission to Publish() to this topic. // // The operation will fail if the topic does not exist. // Users should ensure that there is a subscription attached to this topic // since messages published to a topic with no subscriptions are lost. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#dead_letter_topic PubsubSubscription#dead_letter_topic} DeadLetterTopic *string `field:"optional" json:"deadLetterTopic" yaml:"deadLetterTopic"` // The maximum number of delivery attempts for any message. The value must be between 5 and 100. // // The number of delivery attempts is defined as 1 + (the sum of number of // NACKs and number of times the acknowledgement deadline has been exceeded for the message). // // A NACK is any call to ModifyAckDeadline with a 0 deadline. Note that // client libraries may automatically extend ack_deadlines. // // This field will be honored on a best effort basis. // // If this parameter is 0, a default value of 5 is used. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#max_delivery_attempts PubsubSubscription#max_delivery_attempts} MaxDeliveryAttempts *float64 `field:"optional" json:"maxDeliveryAttempts" yaml:"maxDeliveryAttempts"` }
type PubsubSubscriptionDeadLetterPolicyOutputReference ¶
type PubsubSubscriptionDeadLetterPolicyOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string DeadLetterTopic() *string SetDeadLetterTopic(val *string) DeadLetterTopicInput() *string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionDeadLetterPolicy SetInternalValue(val *PubsubSubscriptionDeadLetterPolicy) MaxDeliveryAttempts() *float64 SetMaxDeliveryAttempts(val *float64) MaxDeliveryAttemptsInput() *float64 // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetDeadLetterTopic() ResetMaxDeliveryAttempts() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionDeadLetterPolicyOutputReference ¶
func NewPubsubSubscriptionDeadLetterPolicyOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionDeadLetterPolicyOutputReference
type PubsubSubscriptionExpirationPolicy ¶
type PubsubSubscriptionExpirationPolicy struct { // Specifies the "time-to-live" duration for an associated resource. // // The // resource expires if it is not active for a period of ttl. // If ttl is set to "", the associated resource never expires. // A duration in seconds with up to nine fractional digits, terminated by 's'. // Example - "3.5s". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#ttl PubsubSubscription#ttl} Ttl *string `field:"required" json:"ttl" yaml:"ttl"` }
type PubsubSubscriptionExpirationPolicyOutputReference ¶
type PubsubSubscriptionExpirationPolicyOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionExpirationPolicy SetInternalValue(val *PubsubSubscriptionExpirationPolicy) // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) Ttl() *string SetTtl(val *string) TtlInput() *string // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionExpirationPolicyOutputReference ¶
func NewPubsubSubscriptionExpirationPolicyOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionExpirationPolicyOutputReference
type PubsubSubscriptionPushConfig ¶
type PubsubSubscriptionPushConfig struct { // A URL locating the endpoint to which messages should be pushed. For example, a Webhook endpoint might use "https://example.com/push". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#push_endpoint PubsubSubscription#push_endpoint} PushEndpoint *string `field:"required" json:"pushEndpoint" yaml:"pushEndpoint"` // Endpoint configuration attributes. // // Every endpoint has a set of API supported attributes that can // be used to control different aspects of the message delivery. // // The currently supported attribute is x-goog-version, which you // can use to change the format of the pushed message. This // attribute indicates the version of the data expected by // the endpoint. This controls the shape of the pushed message // (i.e., its fields and metadata). The endpoint version is // based on the version of the Pub/Sub API. // // If not present during the subscriptions.create call, // it will default to the version of the API used to make // such call. If not present during a subscriptions.modifyPushConfig // call, its value will not be changed. subscriptions.get // calls will always return a valid version, even if the // subscription was created without this attribute. // // The possible values for this attribute are: // // - v1beta1: uses the push format defined in the v1beta1 Pub/Sub API. // - v1 or v1beta2: uses the push format defined in the v1 Pub/Sub API. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#attributes PubsubSubscription#attributes} Attributes *map[string]*string `field:"optional" json:"attributes" yaml:"attributes"` // no_wrapper block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#no_wrapper PubsubSubscription#no_wrapper} NoWrapper *PubsubSubscriptionPushConfigNoWrapper `field:"optional" json:"noWrapper" yaml:"noWrapper"` // oidc_token block. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#oidc_token PubsubSubscription#oidc_token} OidcToken *PubsubSubscriptionPushConfigOidcToken `field:"optional" json:"oidcToken" yaml:"oidcToken"` }
type PubsubSubscriptionPushConfigNoWrapper ¶
type PubsubSubscriptionPushConfigNoWrapper struct { // When true, writes the Pub/Sub message metadata to 'x-goog-pubsub-<KEY>:<VAL>' headers of the HTTP request. // // Writes the // Pub/Sub message attributes to '<KEY>:<VAL>' headers of the HTTP request. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#write_metadata PubsubSubscription#write_metadata} WriteMetadata interface{} `field:"required" json:"writeMetadata" yaml:"writeMetadata"` }
type PubsubSubscriptionPushConfigNoWrapperOutputReference ¶
type PubsubSubscriptionPushConfigNoWrapperOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionPushConfigNoWrapper SetInternalValue(val *PubsubSubscriptionPushConfigNoWrapper) // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) WriteMetadata() interface{} SetWriteMetadata(val interface{}) WriteMetadataInput() interface{} // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionPushConfigNoWrapperOutputReference ¶
func NewPubsubSubscriptionPushConfigNoWrapperOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionPushConfigNoWrapperOutputReference
type PubsubSubscriptionPushConfigOidcToken ¶
type PubsubSubscriptionPushConfigOidcToken struct { // Service account email to be used for generating the OIDC token. // // The caller (for subscriptions.create, subscriptions.patch, and // subscriptions.modifyPushConfig RPCs) must have the // iam.serviceAccounts.actAs permission for the service account. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#service_account_email PubsubSubscription#service_account_email} ServiceAccountEmail *string `field:"required" json:"serviceAccountEmail" yaml:"serviceAccountEmail"` // Audience to be used when generating OIDC token. // // The audience claim // identifies the recipients that the JWT is intended for. The audience // value is a single case-sensitive string. Having multiple values (array) // for the audience field is not supported. More info about the OIDC JWT // token audience here: https://tools.ietf.org/html/rfc7519#section-4.1.3 // Note: if not specified, the Push endpoint URL will be used. // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#audience PubsubSubscription#audience} Audience *string `field:"optional" json:"audience" yaml:"audience"` }
type PubsubSubscriptionPushConfigOidcTokenOutputReference ¶
type PubsubSubscriptionPushConfigOidcTokenOutputReference interface { cdktf.ComplexObject Audience() *string SetAudience(val *string) AudienceInput() *string // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionPushConfigOidcToken SetInternalValue(val *PubsubSubscriptionPushConfigOidcToken) ServiceAccountEmail() *string SetServiceAccountEmail(val *string) ServiceAccountEmailInput() *string // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetAudience() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionPushConfigOidcTokenOutputReference ¶
func NewPubsubSubscriptionPushConfigOidcTokenOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionPushConfigOidcTokenOutputReference
type PubsubSubscriptionPushConfigOutputReference ¶
type PubsubSubscriptionPushConfigOutputReference interface { cdktf.ComplexObject Attributes() *map[string]*string SetAttributes(val *map[string]*string) AttributesInput() *map[string]*string // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionPushConfig SetInternalValue(val *PubsubSubscriptionPushConfig) NoWrapper() PubsubSubscriptionPushConfigNoWrapperOutputReference NoWrapperInput() *PubsubSubscriptionPushConfigNoWrapper OidcToken() PubsubSubscriptionPushConfigOidcTokenOutputReference OidcTokenInput() *PubsubSubscriptionPushConfigOidcToken PushEndpoint() *string SetPushEndpoint(val *string) PushEndpointInput() *string // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable PutNoWrapper(value *PubsubSubscriptionPushConfigNoWrapper) PutOidcToken(value *PubsubSubscriptionPushConfigOidcToken) ResetAttributes() ResetNoWrapper() ResetOidcToken() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionPushConfigOutputReference ¶
func NewPubsubSubscriptionPushConfigOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionPushConfigOutputReference
type PubsubSubscriptionRetryPolicy ¶
type PubsubSubscriptionRetryPolicy struct { // The maximum delay between consecutive deliveries of a given message. // // Value should be between 0 and 600 seconds. Defaults to 600 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#maximum_backoff PubsubSubscription#maximum_backoff} MaximumBackoff *string `field:"optional" json:"maximumBackoff" yaml:"maximumBackoff"` // The minimum delay between consecutive deliveries of a given message. // // Value should be between 0 and 600 seconds. Defaults to 10 seconds. // A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". // // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#minimum_backoff PubsubSubscription#minimum_backoff} MinimumBackoff *string `field:"optional" json:"minimumBackoff" yaml:"minimumBackoff"` }
type PubsubSubscriptionRetryPolicyOutputReference ¶
type PubsubSubscriptionRetryPolicyOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string // Experimental. Fqn() *string InternalValue() *PubsubSubscriptionRetryPolicy SetInternalValue(val *PubsubSubscriptionRetryPolicy) MaximumBackoff() *string SetMaximumBackoff(val *string) MaximumBackoffInput() *string MinimumBackoff() *string SetMinimumBackoff(val *string) MinimumBackoffInput() *string // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetMaximumBackoff() ResetMinimumBackoff() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionRetryPolicyOutputReference ¶
func NewPubsubSubscriptionRetryPolicyOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionRetryPolicyOutputReference
type PubsubSubscriptionTimeouts ¶
type PubsubSubscriptionTimeouts struct { // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#create PubsubSubscription#create}. Create *string `field:"optional" json:"create" yaml:"create"` // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#delete PubsubSubscription#delete}. Delete *string `field:"optional" json:"delete" yaml:"delete"` // Docs at Terraform Registry: {@link https://registry.terraform.io/providers/hashicorp/google/6.14.1/docs/resources/pubsub_subscription#update PubsubSubscription#update}. Update *string `field:"optional" json:"update" yaml:"update"` }
type PubsubSubscriptionTimeoutsOutputReference ¶
type PubsubSubscriptionTimeoutsOutputReference interface { cdktf.ComplexObject // the index of the complex object in a list. // Experimental. ComplexObjectIndex() interface{} // Experimental. SetComplexObjectIndex(val interface{}) // set to true if this item is from inside a set and needs tolist() for accessing it set to "0" for single list items. // Experimental. ComplexObjectIsFromSet() *bool // Experimental. SetComplexObjectIsFromSet(val *bool) Create() *string SetCreate(val *string) CreateInput() *string // The creation stack of this resolvable which will be appended to errors thrown during resolution. // // If this returns an empty array the stack will not be attached. // Experimental. CreationStack() *[]*string Delete() *string SetDelete(val *string) DeleteInput() *string // Experimental. Fqn() *string InternalValue() interface{} SetInternalValue(val interface{}) // Experimental. TerraformAttribute() *string // Experimental. SetTerraformAttribute(val *string) // Experimental. TerraformResource() cdktf.IInterpolatingParent // Experimental. SetTerraformResource(val cdktf.IInterpolatingParent) Update() *string SetUpdate(val *string) UpdateInput() *string // Experimental. ComputeFqn() *string // Experimental. GetAnyMapAttribute(terraformAttribute *string) *map[string]interface{} // Experimental. GetBooleanAttribute(terraformAttribute *string) cdktf.IResolvable // Experimental. GetBooleanMapAttribute(terraformAttribute *string) *map[string]*bool // Experimental. GetListAttribute(terraformAttribute *string) *[]*string // Experimental. GetNumberAttribute(terraformAttribute *string) *float64 // Experimental. GetNumberListAttribute(terraformAttribute *string) *[]*float64 // Experimental. GetNumberMapAttribute(terraformAttribute *string) *map[string]*float64 // Experimental. GetStringAttribute(terraformAttribute *string) *string // Experimental. GetStringMapAttribute(terraformAttribute *string) *map[string]*string // Experimental. InterpolationAsList() cdktf.IResolvable // Experimental. InterpolationForAttribute(property *string) cdktf.IResolvable ResetCreate() ResetDelete() ResetUpdate() // Produce the Token's value at resolution time. // Experimental. Resolve(_context cdktf.IResolveContext) interface{} // Return a string representation of this resolvable object. // // Returns a reversible string representation. // Experimental. ToString() *string }
func NewPubsubSubscriptionTimeoutsOutputReference ¶
func NewPubsubSubscriptionTimeoutsOutputReference(terraformResource cdktf.IInterpolatingParent, terraformAttribute *string) PubsubSubscriptionTimeoutsOutputReference
Source Files ¶
- PubsubSubscription.go
- PubsubSubscriptionBigqueryConfig.go
- PubsubSubscriptionBigqueryConfigOutputReference.go
- PubsubSubscriptionBigqueryConfigOutputReference__checks.go
- PubsubSubscriptionCloudStorageConfig.go
- PubsubSubscriptionCloudStorageConfigAvroConfig.go
- PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference.go
- PubsubSubscriptionCloudStorageConfigAvroConfigOutputReference__checks.go
- PubsubSubscriptionCloudStorageConfigOutputReference.go
- PubsubSubscriptionCloudStorageConfigOutputReference__checks.go
- PubsubSubscriptionConfig.go
- PubsubSubscriptionDeadLetterPolicy.go
- PubsubSubscriptionDeadLetterPolicyOutputReference.go
- PubsubSubscriptionDeadLetterPolicyOutputReference__checks.go
- PubsubSubscriptionExpirationPolicy.go
- PubsubSubscriptionExpirationPolicyOutputReference.go
- PubsubSubscriptionExpirationPolicyOutputReference__checks.go
- PubsubSubscriptionPushConfig.go
- PubsubSubscriptionPushConfigNoWrapper.go
- PubsubSubscriptionPushConfigNoWrapperOutputReference.go
- PubsubSubscriptionPushConfigNoWrapperOutputReference__checks.go
- PubsubSubscriptionPushConfigOidcToken.go
- PubsubSubscriptionPushConfigOidcTokenOutputReference.go
- PubsubSubscriptionPushConfigOidcTokenOutputReference__checks.go
- PubsubSubscriptionPushConfigOutputReference.go
- PubsubSubscriptionPushConfigOutputReference__checks.go
- PubsubSubscriptionRetryPolicy.go
- PubsubSubscriptionRetryPolicyOutputReference.go
- PubsubSubscriptionRetryPolicyOutputReference__checks.go
- PubsubSubscriptionTimeouts.go
- PubsubSubscriptionTimeoutsOutputReference.go
- PubsubSubscriptionTimeoutsOutputReference__checks.go
- PubsubSubscription__checks.go
- main.go