v1beta1

type AvroConfigInitParameters struct {

	// 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.
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type AvroConfigObservation struct {

	// 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.
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type AvroConfigParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type AvroFormatInitParameters struct {
}

type AvroFormatObservation struct {
}

type AvroFormatParameters struct {
}

type AwsKinesisInitParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	AwsRoleArn *string `json:"awsRoleArn,omitempty" tf:"aws_role_arn,omitempty"`

	// The Kinesis consumer ARN to used for ingestion in
	// Enhanced Fan-Out mode. The consumer must be already
	// created and ready to be used.
	ConsumerArn *string `json:"consumerArn,omitempty" tf:"consumer_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// The Kinesis stream ARN to ingest data from.
	StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"`
}

type AwsKinesisObservation struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	AwsRoleArn *string `json:"awsRoleArn,omitempty" tf:"aws_role_arn,omitempty"`

	// The Kinesis consumer ARN to used for ingestion in
	// Enhanced Fan-Out mode. The consumer must be already
	// created and ready to be used.
	ConsumerArn *string `json:"consumerArn,omitempty" tf:"consumer_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// The Kinesis stream ARN to ingest data from.
	StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"`
}

type AwsKinesisParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	// +kubebuilder:validation:Optional
	AwsRoleArn *string `json:"awsRoleArn" tf:"aws_role_arn,omitempty"`

	// The Kinesis consumer ARN to used for ingestion in
	// Enhanced Fan-Out mode. The consumer must be already
	// created and ready to be used.
	// +kubebuilder:validation:Optional
	ConsumerArn *string `json:"consumerArn" tf:"consumer_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	// +kubebuilder:validation:Optional
	GCPServiceAccount *string `json:"gcpServiceAccount" tf:"gcp_service_account,omitempty"`

	// The Kinesis stream ARN to ingest data from.
	// +kubebuilder:validation:Optional
	StreamArn *string `json:"streamArn" tf:"stream_arn,omitempty"`
}

type AwsMskInitParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	AwsRoleArn *string `json:"awsRoleArn,omitempty" tf:"aws_role_arn,omitempty"`

	// ARN that uniquely identifies the MSK cluster.
	ClusterArn *string `json:"clusterArn,omitempty" tf:"cluster_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`
}

type AwsMskObservation struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	AwsRoleArn *string `json:"awsRoleArn,omitempty" tf:"aws_role_arn,omitempty"`

	// ARN that uniquely identifies the MSK cluster.
	ClusterArn *string `json:"clusterArn,omitempty" tf:"cluster_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`
}

type AwsMskParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// MSK. Check the Pub/Sub docs for how to set up this role and the
	// required permissions that need to be attached to it.
	// +kubebuilder:validation:Optional
	AwsRoleArn *string `json:"awsRoleArn" tf:"aws_role_arn,omitempty"`

	// ARN that uniquely identifies the MSK cluster.
	// +kubebuilder:validation:Optional
	ClusterArn *string `json:"clusterArn" tf:"cluster_arn,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	// +kubebuilder:validation:Optional
	GCPServiceAccount *string `json:"gcpServiceAccount" tf:"gcp_service_account,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic" tf:"topic,omitempty"`
}

type AzureEventHubsInitParameters struct {

	// The Azure event hub client ID to use for ingestion.
	ClientID *string `json:"clientId,omitempty" tf:"client_id,omitempty"`

	// The Azure event hub to ingest data from.
	EventHub *string `json:"eventHub,omitempty" tf:"event_hub,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// The Azure event hub namespace to ingest data from.
	Namespace *string `json:"namespace,omitempty" tf:"namespace,omitempty"`

	// The name of the resource group within an Azure subscription.
	ResourceGroup *string `json:"resourceGroup,omitempty" tf:"resource_group,omitempty"`

	// The Azure event hub subscription ID to use for ingestion.
	SubscriptionID *string `json:"subscriptionId,omitempty" tf:"subscription_id,omitempty"`

	// The Azure event hub tenant ID to use for ingestion.
	TenantID *string `json:"tenantId,omitempty" tf:"tenant_id,omitempty"`
}

type AzureEventHubsObservation struct {

	// The Azure event hub client ID to use for ingestion.
	ClientID *string `json:"clientId,omitempty" tf:"client_id,omitempty"`

	// The Azure event hub to ingest data from.
	EventHub *string `json:"eventHub,omitempty" tf:"event_hub,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// The Azure event hub namespace to ingest data from.
	Namespace *string `json:"namespace,omitempty" tf:"namespace,omitempty"`

	// The name of the resource group within an Azure subscription.
	ResourceGroup *string `json:"resourceGroup,omitempty" tf:"resource_group,omitempty"`

	// The Azure event hub subscription ID to use for ingestion.
	SubscriptionID *string `json:"subscriptionId,omitempty" tf:"subscription_id,omitempty"`

	// The Azure event hub tenant ID to use for ingestion.
	TenantID *string `json:"tenantId,omitempty" tf:"tenant_id,omitempty"`
}

type AzureEventHubsParameters struct {

	// The Azure event hub client ID to use for ingestion.
	// +kubebuilder:validation:Optional
	ClientID *string `json:"clientId,omitempty" tf:"client_id,omitempty"`

	// The Azure event hub to ingest data from.
	// +kubebuilder:validation:Optional
	EventHub *string `json:"eventHub,omitempty" tf:"event_hub,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	// +kubebuilder:validation:Optional
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// The Azure event hub namespace to ingest data from.
	// +kubebuilder:validation:Optional
	Namespace *string `json:"namespace,omitempty" tf:"namespace,omitempty"`

	// The name of the resource group within an Azure subscription.
	// +kubebuilder:validation:Optional
	ResourceGroup *string `json:"resourceGroup,omitempty" tf:"resource_group,omitempty"`

	// The Azure event hub subscription ID to use for ingestion.
	// +kubebuilder:validation:Optional
	SubscriptionID *string `json:"subscriptionId,omitempty" tf:"subscription_id,omitempty"`

	// The Azure event hub tenant ID to use for ingestion.
	// +kubebuilder:validation:Optional
	TenantID *string `json:"tenantId,omitempty" tf:"tenant_id,omitempty"`
}

type BigqueryConfigInitParameters struct {

	// 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.
	DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"`

	// The service account to use to write to BigQuery. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractParamPath("email",true)
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// Reference to a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailRef *v1.NamespacedReference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.NamespacedSelector `json:"serviceAccountEmailSelector,omitempty" tf:"-"`

	// The name of the table to which to write data, of the form {projectId}.{datasetId}.{tableId}
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// 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.
	UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"`

	// 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.
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type BigqueryConfigObservation struct {

	// 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.
	DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"`

	// The service account to use to write to BigQuery. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// The name of the table to which to write data, of the form {projectId}.{datasetId}.{tableId}
	Table *string `json:"table,omitempty" tf:"table,omitempty"`

	// 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.
	UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"`

	// 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.
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type BigqueryConfigParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	DropUnknownFields *bool `json:"dropUnknownFields,omitempty" tf:"drop_unknown_fields,omitempty"`

	// The service account to use to write to BigQuery. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractParamPath("email",true)
	// +kubebuilder:validation:Optional
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// Reference to a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailRef *v1.NamespacedReference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.NamespacedSelector `json:"serviceAccountEmailSelector,omitempty" tf:"-"`

	// The name of the table to which to write data, of the form {projectId}.{datasetId}.{tableId}
	// +kubebuilder:validation:Optional
	Table *string `json:"table" tf:"table,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	UseTableSchema *bool `json:"useTableSchema,omitempty" tf:"use_table_schema,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	UseTopicSchema *bool `json:"useTopicSchema,omitempty" tf:"use_topic_schema,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type CapacityInitParameters struct {

	// Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	PublishMibPerSec *float64 `json:"publishMibPerSec,omitempty" tf:"publish_mib_per_sec,omitempty"`

	// Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	SubscribeMibPerSec *float64 `json:"subscribeMibPerSec,omitempty" tf:"subscribe_mib_per_sec,omitempty"`
}

type CapacityObservation struct {

	// Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	PublishMibPerSec *float64 `json:"publishMibPerSec,omitempty" tf:"publish_mib_per_sec,omitempty"`

	// Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	SubscribeMibPerSec *float64 `json:"subscribeMibPerSec,omitempty" tf:"subscribe_mib_per_sec,omitempty"`
}

type CapacityParameters struct {

	// Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	// +kubebuilder:validation:Optional
	PublishMibPerSec *float64 `json:"publishMibPerSec" tf:"publish_mib_per_sec,omitempty"`

	// Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	// +kubebuilder:validation:Optional
	SubscribeMibPerSec *float64 `json:"subscribeMibPerSec" tf:"subscribe_mib_per_sec,omitempty"`
}

type CloudStorageConfigInitParameters struct {

	// If set, message data will be written to Cloud Storage in Avro format.
	// Structure is documented below.
	AvroConfig *AvroConfigInitParameters `json:"avroConfig,omitempty" tf:"avro_config,omitempty"`

	// 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://".
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`

	// User-provided format string specifying how to represent datetimes in Cloud Storage filenames.
	FilenameDatetimeFormat *string `json:"filenameDatetimeFormat,omitempty" tf:"filename_datetime_format,omitempty"`

	// User-provided prefix for Cloud Storage filename.
	FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"`

	// User-provided suffix for Cloud Storage filename. Must not end in "/".
	FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"`

	// 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.
	MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"`

	// 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".
	MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"`

	// The maximum messages that can be written to a Cloud Storage file before a new file is created. Min 1000 messages.
	MaxMessages *float64 `json:"maxMessages,omitempty" tf:"max_messages,omitempty"`

	// The service account to use to write to Cloud Storage. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractParamPath("email",true)
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// Reference to a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailRef *v1.NamespacedReference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.NamespacedSelector `json:"serviceAccountEmailSelector,omitempty" tf:"-"`
}

type CloudStorageConfigObservation struct {

	// If set, message data will be written to Cloud Storage in Avro format.
	// Structure is documented below.
	AvroConfig *AvroConfigObservation `json:"avroConfig,omitempty" tf:"avro_config,omitempty"`

	// 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://".
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`

	// User-provided format string specifying how to represent datetimes in Cloud Storage filenames.
	FilenameDatetimeFormat *string `json:"filenameDatetimeFormat,omitempty" tf:"filename_datetime_format,omitempty"`

	// User-provided prefix for Cloud Storage filename.
	FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"`

	// User-provided suffix for Cloud Storage filename. Must not end in "/".
	FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"`

	// 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.
	MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"`

	// 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".
	MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"`

	// The maximum messages that can be written to a Cloud Storage file before a new file is created. Min 1000 messages.
	MaxMessages *float64 `json:"maxMessages,omitempty" tf:"max_messages,omitempty"`

	// The service account to use to write to Cloud Storage. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// (Output)
	// An output-only field that indicates whether or not the subscription can receive messages.
	State *string `json:"state,omitempty" tf:"state,omitempty"`
}

type CloudStorageConfigParameters struct {

	// If set, message data will be written to Cloud Storage in Avro format.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AvroConfig *AvroConfigParameters `json:"avroConfig,omitempty" tf:"avro_config,omitempty"`

	// 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://".
	// +kubebuilder:validation:Optional
	Bucket *string `json:"bucket" tf:"bucket,omitempty"`

	// User-provided format string specifying how to represent datetimes in Cloud Storage filenames.
	// +kubebuilder:validation:Optional
	FilenameDatetimeFormat *string `json:"filenameDatetimeFormat,omitempty" tf:"filename_datetime_format,omitempty"`

	// User-provided prefix for Cloud Storage filename.
	// +kubebuilder:validation:Optional
	FilenamePrefix *string `json:"filenamePrefix,omitempty" tf:"filename_prefix,omitempty"`

	// User-provided suffix for Cloud Storage filename. Must not end in "/".
	// +kubebuilder:validation:Optional
	FilenameSuffix *string `json:"filenameSuffix,omitempty" tf:"filename_suffix,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	MaxBytes *float64 `json:"maxBytes,omitempty" tf:"max_bytes,omitempty"`

	// 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".
	// +kubebuilder:validation:Optional
	MaxDuration *string `json:"maxDuration,omitempty" tf:"max_duration,omitempty"`

	// The maximum messages that can be written to a Cloud Storage file before a new file is created. Min 1000 messages.
	// +kubebuilder:validation:Optional
	MaxMessages *float64 `json:"maxMessages,omitempty" tf:"max_messages,omitempty"`

	// The service account to use to write to Cloud Storage. If not specified, the Pub/Sub
	// service agent,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com, is used.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractParamPath("email",true)
	// +kubebuilder:validation:Optional
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`

	// Reference to a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailRef *v1.NamespacedReference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.NamespacedSelector `json:"serviceAccountEmailSelector,omitempty" tf:"-"`
}

type CloudStorageInitParameters struct {

	// Configuration for reading Cloud Storage data in Avro binary format. The
	// bytes of each object will be set to the data field of a Pub/Sub message.
	AvroFormat *AvroFormatInitParameters `json:"avroFormat,omitempty" tf:"avro_format,omitempty"`

	// Cloud Storage bucket. The bucket name must be without any
	// prefix like "gs://". See the bucket naming requirements:
	// https://cloud.google.com/storage/docs/buckets#naming.
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`

	// Glob pattern used to match objects that will be ingested. If unset, all
	// objects will be ingested. See the supported patterns:
	// https://cloud.google.com/storage/docs/json_api/v1/objects/list#list-objects-and-prefixes-using-glob
	MatchGlob *string `json:"matchGlob,omitempty" tf:"match_glob,omitempty"`

	// The timestamp set in RFC3339 text format. If set, only objects with a
	// larger or equal timestamp will be ingested. Unset by default, meaning
	// all objects will be ingested.
	MinimumObjectCreateTime *string `json:"minimumObjectCreateTime,omitempty" tf:"minimum_object_create_time,omitempty"`

	// Configuration for reading Cloud Storage data written via Cloud Storage
	// subscriptions(See https://cloud.google.com/pubsub/docs/cloudstorage). The
	// data and attributes fields of the originally exported Pub/Sub message
	// will be restored when publishing.
	PubsubAvroFormat *PubsubAvroFormatInitParameters `json:"pubsubAvroFormat,omitempty" tf:"pubsub_avro_format,omitempty"`

	// Configuration for reading Cloud Storage data in text format. Each line of
	// text as specified by the delimiter will be set to the data field of a
	// Pub/Sub message.
	// Structure is documented below.
	TextFormat *TextFormatInitParameters `json:"textFormat,omitempty" tf:"text_format,omitempty"`
}

type CloudStorageObservation struct {

	// Configuration for reading Cloud Storage data in Avro binary format. The
	// bytes of each object will be set to the data field of a Pub/Sub message.
	AvroFormat *AvroFormatParameters `json:"avroFormat,omitempty" tf:"avro_format,omitempty"`

	// Cloud Storage bucket. The bucket name must be without any
	// prefix like "gs://". See the bucket naming requirements:
	// https://cloud.google.com/storage/docs/buckets#naming.
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`

	// Glob pattern used to match objects that will be ingested. If unset, all
	// objects will be ingested. See the supported patterns:
	// https://cloud.google.com/storage/docs/json_api/v1/objects/list#list-objects-and-prefixes-using-glob
	MatchGlob *string `json:"matchGlob,omitempty" tf:"match_glob,omitempty"`

	// The timestamp set in RFC3339 text format. If set, only objects with a
	// larger or equal timestamp will be ingested. Unset by default, meaning
	// all objects will be ingested.
	MinimumObjectCreateTime *string `json:"minimumObjectCreateTime,omitempty" tf:"minimum_object_create_time,omitempty"`

	// Configuration for reading Cloud Storage data written via Cloud Storage
	// subscriptions(See https://cloud.google.com/pubsub/docs/cloudstorage). The
	// data and attributes fields of the originally exported Pub/Sub message
	// will be restored when publishing.
	PubsubAvroFormat *PubsubAvroFormatParameters `json:"pubsubAvroFormat,omitempty" tf:"pubsub_avro_format,omitempty"`

	// Configuration for reading Cloud Storage data in text format. Each line of
	// text as specified by the delimiter will be set to the data field of a
	// Pub/Sub message.
	// Structure is documented below.
	TextFormat *TextFormatObservation `json:"textFormat,omitempty" tf:"text_format,omitempty"`
}

type CloudStorageParameters struct {

	// Configuration for reading Cloud Storage data in Avro binary format. The
	// bytes of each object will be set to the data field of a Pub/Sub message.
	// +kubebuilder:validation:Optional
	AvroFormat *AvroFormatParameters `json:"avroFormat,omitempty" tf:"avro_format,omitempty"`

	// Cloud Storage bucket. The bucket name must be without any
	// prefix like "gs://". See the bucket naming requirements:
	// https://cloud.google.com/storage/docs/buckets#naming.
	// +kubebuilder:validation:Optional
	Bucket *string `json:"bucket" tf:"bucket,omitempty"`

	// Glob pattern used to match objects that will be ingested. If unset, all
	// objects will be ingested. See the supported patterns:
	// https://cloud.google.com/storage/docs/json_api/v1/objects/list#list-objects-and-prefixes-using-glob
	// +kubebuilder:validation:Optional
	MatchGlob *string `json:"matchGlob,omitempty" tf:"match_glob,omitempty"`

	// The timestamp set in RFC3339 text format. If set, only objects with a
	// larger or equal timestamp will be ingested. Unset by default, meaning
	// all objects will be ingested.
	// +kubebuilder:validation:Optional
	MinimumObjectCreateTime *string `json:"minimumObjectCreateTime,omitempty" tf:"minimum_object_create_time,omitempty"`

	// Configuration for reading Cloud Storage data written via Cloud Storage
	// subscriptions(See https://cloud.google.com/pubsub/docs/cloudstorage). The
	// data and attributes fields of the originally exported Pub/Sub message
	// will be restored when publishing.
	// +kubebuilder:validation:Optional
	PubsubAvroFormat *PubsubAvroFormatParameters `json:"pubsubAvroFormat,omitempty" tf:"pubsub_avro_format,omitempty"`

	// Configuration for reading Cloud Storage data in text format. Each line of
	// text as specified by the delimiter will be set to the data field of a
	// Pub/Sub message.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	TextFormat *TextFormatParameters `json:"textFormat,omitempty" tf:"text_format,omitempty"`
}

type ConditionInitParameters struct {
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	Expression *string `json:"expression,omitempty" tf:"expression,omitempty"`

	Title *string `json:"title,omitempty" tf:"title,omitempty"`
}

type ConditionObservation struct {
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	Expression *string `json:"expression,omitempty" tf:"expression,omitempty"`

	Title *string `json:"title,omitempty" tf:"title,omitempty"`
}

type ConditionParameters struct {

	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// +kubebuilder:validation:Optional
	Expression *string `json:"expression" tf:"expression,omitempty"`

	// +kubebuilder:validation:Optional
	Title *string `json:"title" tf:"title,omitempty"`
}

type ConfluentCloudInitParameters struct {

	// The Confluent Cloud bootstrap server. The format is url:port.
	BootstrapServer *string `json:"bootstrapServer,omitempty" tf:"bootstrap_server,omitempty"`

	// The Confluent Cloud cluster ID.
	ClusterID *string `json:"clusterId,omitempty" tf:"cluster_id,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// Identity pool ID to be used for Federated Identity authentication with Confluent Cloud.
	IdentityPoolID *string `json:"identityPoolId,omitempty" tf:"identity_pool_id,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`
}

type ConfluentCloudObservation struct {

	// The Confluent Cloud bootstrap server. The format is url:port.
	BootstrapServer *string `json:"bootstrapServer,omitempty" tf:"bootstrap_server,omitempty"`

	// The Confluent Cloud cluster ID.
	ClusterID *string `json:"clusterId,omitempty" tf:"cluster_id,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	GCPServiceAccount *string `json:"gcpServiceAccount,omitempty" tf:"gcp_service_account,omitempty"`

	// Identity pool ID to be used for Federated Identity authentication with Confluent Cloud.
	IdentityPoolID *string `json:"identityPoolId,omitempty" tf:"identity_pool_id,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`
}

type ConfluentCloudParameters struct {

	// The Confluent Cloud bootstrap server. The format is url:port.
	// +kubebuilder:validation:Optional
	BootstrapServer *string `json:"bootstrapServer" tf:"bootstrap_server,omitempty"`

	// The Confluent Cloud cluster ID.
	// +kubebuilder:validation:Optional
	ClusterID *string `json:"clusterId,omitempty" tf:"cluster_id,omitempty"`

	// The GCP service account to be used for Federated Identity authentication
	// with Confluent Cloud.
	// +kubebuilder:validation:Optional
	GCPServiceAccount *string `json:"gcpServiceAccount" tf:"gcp_service_account,omitempty"`

	// Identity pool ID to be used for Federated Identity authentication with Confluent Cloud.
	// +kubebuilder:validation:Optional
	IdentityPoolID *string `json:"identityPoolId" tf:"identity_pool_id,omitempty"`

	// Name of the Confluent Cloud topic that Pub/Sub will import from.
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic" tf:"topic,omitempty"`
}

type DeadLetterPolicyInitParameters 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.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.Topic
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractResourceID()
	DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"`

	// Reference to a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicRef *v1.NamespacedReference `json:"deadLetterTopicRef,omitempty" tf:"-"`

	// Selector for a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicSelector *v1.NamespacedSelector `json:"deadLetterTopicSelector,omitempty" tf:"-"`

	// 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.
	MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"`
}

type DeadLetterPolicyObservation 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.
	DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"`

	// 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.
	MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"`
}

type DeadLetterPolicyParameters 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.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.Topic
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/v2/pkg/resource.ExtractResourceID()
	// +kubebuilder:validation:Optional
	DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic,omitempty"`

	// Reference to a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicRef *v1.NamespacedReference `json:"deadLetterTopicRef,omitempty" tf:"-"`

	// Selector for a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicSelector *v1.NamespacedSelector `json:"deadLetterTopicSelector,omitempty" tf:"-"`

	// 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.
	// +kubebuilder:validation:Optional
	MaxDeliveryAttempts *float64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts,omitempty"`
}

type DeliveryConfigInitParameters struct {

	// When this subscription should send messages to subscribers relative to messages persistence in storage.
	// Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED.
	DeliveryRequirement *string `json:"deliveryRequirement,omitempty" tf:"delivery_requirement,omitempty"`
}

type DeliveryConfigObservation struct {

	// When this subscription should send messages to subscribers relative to messages persistence in storage.
	// Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED.
	DeliveryRequirement *string `json:"deliveryRequirement,omitempty" tf:"delivery_requirement,omitempty"`
}

type DeliveryConfigParameters struct {

	// When this subscription should send messages to subscribers relative to messages persistence in storage.
	// Possible values are: DELIVER_IMMEDIATELY, DELIVER_AFTER_STORED, DELIVERY_REQUIREMENT_UNSPECIFIED.
	// +kubebuilder:validation:Optional
	DeliveryRequirement *string `json:"deliveryRequirement" tf:"delivery_requirement,omitempty"`
}

type ExpirationPolicyInitParameters 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".
	TTL *string `json:"ttl,omitempty" tf:"ttl,omitempty"`
}

type ExpirationPolicyObservation 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".
	TTL *string `json:"ttl,omitempty" tf:"ttl,omitempty"`
}

type ExpirationPolicyParameters 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".
	// +kubebuilder:validation:Optional
	TTL *string `json:"ttl" tf:"ttl,omitempty"`
}

type IngestionDataSourceSettingsInitParameters struct {

	// Settings for ingestion from Amazon Kinesis Data Streams.
	// Structure is documented below.
	AwsKinesis *AwsKinesisInitParameters `json:"awsKinesis,omitempty" tf:"aws_kinesis,omitempty"`

	// Settings for ingestion from Amazon Managed Streaming for Apache Kafka.
	// Structure is documented below.
	AwsMsk *AwsMskInitParameters `json:"awsMsk,omitempty" tf:"aws_msk,omitempty"`

	// Settings for ingestion from Azure Event Hubs.
	// Structure is documented below.
	AzureEventHubs *AzureEventHubsInitParameters `json:"azureEventHubs,omitempty" tf:"azure_event_hubs,omitempty"`

	// Settings for ingestion from Cloud Storage.
	// Structure is documented below.
	CloudStorage *CloudStorageInitParameters `json:"cloudStorage,omitempty" tf:"cloud_storage,omitempty"`

	// Settings for ingestion from Confluent Cloud.
	// Structure is documented below.
	ConfluentCloud *ConfluentCloudInitParameters `json:"confluentCloud,omitempty" tf:"confluent_cloud,omitempty"`

	// Settings for Platform Logs regarding ingestion to Pub/Sub. If unset,
	// no Platform Logs will be generated.'
	// Structure is documented below.
	PlatformLogsSettings *PlatformLogsSettingsInitParameters `json:"platformLogsSettings,omitempty" tf:"platform_logs_settings,omitempty"`
}

type IngestionDataSourceSettingsObservation struct {

	// Settings for ingestion from Amazon Kinesis Data Streams.
	// Structure is documented below.
	AwsKinesis *AwsKinesisObservation `json:"awsKinesis,omitempty" tf:"aws_kinesis,omitempty"`

	// Settings for ingestion from Amazon Managed Streaming for Apache Kafka.
	// Structure is documented below.
	AwsMsk *AwsMskObservation `json:"awsMsk,omitempty" tf:"aws_msk,omitempty"`

	// Settings for ingestion from Azure Event Hubs.
	// Structure is documented below.
	AzureEventHubs *AzureEventHubsObservation `json:"azureEventHubs,omitempty" tf:"azure_event_hubs,omitempty"`

	// Settings for ingestion from Cloud Storage.
	// Structure is documented below.
	CloudStorage *CloudStorageObservation `json:"cloudStorage,omitempty" tf:"cloud_storage,omitempty"`

	// Settings for ingestion from Confluent Cloud.
	// Structure is documented below.
	ConfluentCloud *ConfluentCloudObservation `json:"confluentCloud,omitempty" tf:"confluent_cloud,omitempty"`

	// Settings for Platform Logs regarding ingestion to Pub/Sub. If unset,
	// no Platform Logs will be generated.'
	// Structure is documented below.
	PlatformLogsSettings *PlatformLogsSettingsObservation `json:"platformLogsSettings,omitempty" tf:"platform_logs_settings,omitempty"`
}

type IngestionDataSourceSettingsParameters struct {

	// Settings for ingestion from Amazon Kinesis Data Streams.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AwsKinesis *AwsKinesisParameters `json:"awsKinesis,omitempty" tf:"aws_kinesis,omitempty"`

	// Settings for ingestion from Amazon Managed Streaming for Apache Kafka.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AwsMsk *AwsMskParameters `json:"awsMsk,omitempty" tf:"aws_msk,omitempty"`

	// Settings for ingestion from Azure Event Hubs.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AzureEventHubs *AzureEventHubsParameters `json:"azureEventHubs,omitempty" tf:"azure_event_hubs,omitempty"`

	// Settings for ingestion from Cloud Storage.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	CloudStorage *CloudStorageParameters `json:"cloudStorage,omitempty" tf:"cloud_storage,omitempty"`

	// Settings for ingestion from Confluent Cloud.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	ConfluentCloud *ConfluentCloudParameters `json:"confluentCloud,omitempty" tf:"confluent_cloud,omitempty"`

	// Settings for Platform Logs regarding ingestion to Pub/Sub. If unset,
	// no Platform Logs will be generated.'
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	PlatformLogsSettings *PlatformLogsSettingsParameters `json:"platformLogsSettings,omitempty" tf:"platform_logs_settings,omitempty"`
}

type JavascriptUdfInitParameters struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	Code *string `json:"code,omitempty" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
}

type JavascriptUdfObservation struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	Code *string `json:"code,omitempty" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
}

type JavascriptUdfParameters struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	// +kubebuilder:validation:Optional
	Code *string `json:"code" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	// +kubebuilder:validation:Optional
	FunctionName *string `json:"functionName" tf:"function_name,omitempty"`
}

type LiteReservation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.throughputCapacity) || (has(self.initProvider) && has(self.initProvider.throughputCapacity))",message="spec.forProvider.throughputCapacity is a required parameter"
	Spec   LiteReservationSpec   `json:"spec"`
	Status LiteReservationStatus `json:"status,omitempty"`
}

type LiteReservationInitParameters struct {

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The reserved throughput capacity. Every unit of throughput capacity is
	// equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed
	// messages.
	ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"`
}

type LiteReservationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []LiteReservation `json:"items"`
}

type LiteReservationObservation struct {

	// an identifier for the resource with format projects/{{project}}/locations/{{region}}/reservations/{{name}}
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite reservation.
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// The reserved throughput capacity. Every unit of throughput capacity is
	// equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed
	// messages.
	ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"`
}

type LiteReservationParameters struct {

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite reservation.
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"region,omitempty"`

	// The reserved throughput capacity. Every unit of throughput capacity is
	// equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed
	// messages.
	// +kubebuilder:validation:Optional
	ThroughputCapacity *float64 `json:"throughputCapacity,omitempty" tf:"throughput_capacity,omitempty"`
}

type LiteReservationSpec struct {
	v2.ManagedResourceSpec `json:",inline"`
	ForProvider            LiteReservationParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider LiteReservationInitParameters `json:"initProvider,omitempty"`
}

type LiteReservationStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        LiteReservationObservation `json:"atProvider,omitempty"`
}

type LiteSubscription struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              LiteSubscriptionSpec   `json:"spec"`
	Status            LiteSubscriptionStatus `json:"status,omitempty"`
}

type LiteSubscriptionInitParameters struct {

	// The settings for this subscription's message delivery.
	// Structure is documented below.
	DeliveryConfig *DeliveryConfigInitParameters `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// A reference to a Topic resource.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.LiteTopic
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

	// Reference to a LiteTopic in pubsub to populate topic.
	// +kubebuilder:validation:Optional
	TopicRef *v1.NamespacedReference `json:"topicRef,omitempty" tf:"-"`

	// Selector for a LiteTopic in pubsub to populate topic.
	// +kubebuilder:validation:Optional
	TopicSelector *v1.NamespacedSelector `json:"topicSelector,omitempty" tf:"-"`
}

type LiteSubscriptionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []LiteSubscription `json:"items"`
}

type LiteSubscriptionObservation struct {

	// The settings for this subscription's message delivery.
	// Structure is documented below.
	DeliveryConfig *DeliveryConfigObservation `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"`

	// an identifier for the resource with format projects/{{project}}/locations/{{zone}}/subscriptions/{{name}}
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// A reference to a Topic resource.
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

	// The zone of the pubsub lite topic.
	Zone *string `json:"zone,omitempty" tf:"zone,omitempty"`
}

type LiteSubscriptionParameters struct {

	// The settings for this subscription's message delivery.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	DeliveryConfig *DeliveryConfigParameters `json:"deliveryConfig,omitempty" tf:"delivery_config,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// A reference to a Topic resource.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.LiteTopic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

	// Reference to a LiteTopic in pubsub to populate topic.
	// +kubebuilder:validation:Optional
	TopicRef *v1.NamespacedReference `json:"topicRef,omitempty" tf:"-"`

	// Selector for a LiteTopic in pubsub to populate topic.
	// +kubebuilder:validation:Optional
	TopicSelector *v1.NamespacedSelector `json:"topicSelector,omitempty" tf:"-"`

	// The zone of the pubsub lite topic.
	// +kubebuilder:validation:Required
	Zone *string `json:"zone" tf:"zone,omitempty"`
}

type LiteSubscriptionSpec struct {
	v2.ManagedResourceSpec `json:",inline"`
	ForProvider            LiteSubscriptionParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider LiteSubscriptionInitParameters `json:"initProvider,omitempty"`
}

type LiteSubscriptionStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        LiteSubscriptionObservation `json:"atProvider,omitempty"`
}

type LiteTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.partitionConfig) || (has(self.initProvider) && has(self.initProvider.partitionConfig))",message="spec.forProvider.partitionConfig is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.retentionConfig) || (has(self.initProvider) && has(self.initProvider.retentionConfig))",message="spec.forProvider.retentionConfig is a required parameter"
	Spec   LiteTopicSpec   `json:"spec"`
	Status LiteTopicStatus `json:"status,omitempty"`
}

type LiteTopicInitParameters struct {

	// The settings for this topic's partitions.
	// Structure is documented below.
	PartitionConfig *PartitionConfigInitParameters `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// The settings for this topic's Reservation usage.
	// Structure is documented below.
	ReservationConfig *ReservationConfigInitParameters `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"`

	// The settings for a topic's message retention.
	// Structure is documented below.
	RetentionConfig *RetentionConfigInitParameters `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"`
}

type LiteTopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []LiteTopic `json:"items"`
}

type LiteTopicObservation struct {

	// an identifier for the resource with format projects/{{project}}/locations/{{zone}}/topics/{{name}}
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The settings for this topic's partitions.
	// Structure is documented below.
	PartitionConfig *PartitionConfigObservation `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// The settings for this topic's Reservation usage.
	// Structure is documented below.
	ReservationConfig *ReservationConfigObservation `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"`

	// The settings for a topic's message retention.
	// Structure is documented below.
	RetentionConfig *RetentionConfigObservation `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"`

	// The zone of the pubsub lite topic.
	Zone *string `json:"zone,omitempty" tf:"zone,omitempty"`
}

type LiteTopicParameters struct {

	// The settings for this topic's partitions.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	PartitionConfig *PartitionConfigParameters `json:"partitionConfig,omitempty" tf:"partition_config,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The region of the pubsub lite topic.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// The settings for this topic's Reservation usage.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	ReservationConfig *ReservationConfigParameters `json:"reservationConfig,omitempty" tf:"reservation_config,omitempty"`

	// The settings for a topic's message retention.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	RetentionConfig *RetentionConfigParameters `json:"retentionConfig,omitempty" tf:"retention_config,omitempty"`

	// The zone of the pubsub lite topic.
	// +kubebuilder:validation:Required
	Zone *string `json:"zone" tf:"zone,omitempty"`
}

type LiteTopicSpec struct {
	v2.ManagedResourceSpec `json:",inline"`
	ForProvider            LiteTopicParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider LiteTopicInitParameters `json:"initProvider,omitempty"`
}

type LiteTopicStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        LiteTopicObservation `json:"atProvider,omitempty"`
}

type MessageStoragePolicyInitParameters struct {

	// A list of IDs of GCP regions where messages that are published to
	// the topic may be persisted in storage. Messages published by
	// publishers running in non-allowed GCP regions (or running outside
	// of GCP altogether) will be routed for storage in one of the
	// allowed regions. An empty list means that no regions are allowed,
	// and is not a valid configuration.
	// +listType=set
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"`

	// If true, allowedPersistenceRegions is also used to enforce in-transit
	// guarantees for messages. That is, Pub/Sub will fail topics.publish
	// operations on this topic and subscribe operations on any subscription
	// attached to this topic in any region that is not in allowedPersistenceRegions.
	EnforceInTransit *bool `json:"enforceInTransit,omitempty" tf:"enforce_in_transit,omitempty"`
}

type MessageStoragePolicyObservation struct {

	// A list of IDs of GCP regions where messages that are published to
	// the topic may be persisted in storage. Messages published by
	// publishers running in non-allowed GCP regions (or running outside
	// of GCP altogether) will be routed for storage in one of the
	// allowed regions. An empty list means that no regions are allowed,
	// and is not a valid configuration.
	// +listType=set
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"`

	// If true, allowedPersistenceRegions is also used to enforce in-transit
	// guarantees for messages. That is, Pub/Sub will fail topics.publish
	// operations on this topic and subscribe operations on any subscription
	// attached to this topic in any region that is not in allowedPersistenceRegions.
	EnforceInTransit *bool `json:"enforceInTransit,omitempty" tf:"enforce_in_transit,omitempty"`
}

type MessageStoragePolicyParameters struct {

	// A list of IDs of GCP regions where messages that are published to
	// the topic may be persisted in storage. Messages published by
	// publishers running in non-allowed GCP regions (or running outside
	// of GCP altogether) will be routed for storage in one of the
	// allowed regions. An empty list means that no regions are allowed,
	// and is not a valid configuration.
	// +kubebuilder:validation:Optional
	// +listType=set
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions" tf:"allowed_persistence_regions,omitempty"`

	// If true, allowedPersistenceRegions is also used to enforce in-transit
	// guarantees for messages. That is, Pub/Sub will fail topics.publish
	// operations on this topic and subscribe operations on any subscription
	// attached to this topic in any region that is not in allowedPersistenceRegions.
	// +kubebuilder:validation:Optional
	EnforceInTransit *bool `json:"enforceInTransit,omitempty" tf:"enforce_in_transit,omitempty"`
}

type MessageTransformsInitParameters struct {

	// Controls whether or not to use this transform. If not set or false,
	// the transform will be applied to messages. Default: true.
	Disabled *bool `json:"disabled,omitempty" tf:"disabled,omitempty"`

	// Javascript User Defined Function. If multiple Javascript UDFs are specified on a resource,
	// each one must have a unique function_name.
	// Structure is documented below.
	JavascriptUdf *JavascriptUdfInitParameters `json:"javascriptUdf,omitempty" tf:"javascript_udf,omitempty"`
}

type MessageTransformsJavascriptUdfInitParameters struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	Code *string `json:"code,omitempty" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
}

type MessageTransformsJavascriptUdfObservation struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	Code *string `json:"code,omitempty" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
}

type MessageTransformsJavascriptUdfParameters struct {

	// JavaScript code that contains a function function_name with the
	// following signature:
	// +kubebuilder:validation:Optional
	Code *string `json:"code" tf:"code,omitempty"`

	// Name of the JavaScript function that should be applied to Pub/Sub messages.
	// +kubebuilder:validation:Optional
	FunctionName *string `json:"functionName" tf:"function_name,omitempty"`
}

type MessageTransformsObservation struct {

	// Controls whether or not to use this transform. If not set or false,
	// the transform will be applied to messages. Default: true.
	Disabled *bool `json:"disabled,omitempty" tf:"disabled,omitempty"`

	// Javascript User Defined Function. If multiple Javascript UDFs are specified on a resource,
	// each one must have a unique function_name.
	// Structure is documented below.
	JavascriptUdf *JavascriptUdfObservation `json:"javascriptUdf,omitempty" tf:"javascript_udf,omitempty"`
}

type MessageTransformsParameters struct {

	// Controls whether or not to use this transform. If not set or false,
	// the transform will be applied to messages. Default: true.
	// +kubebuilder:validation:Optional
	Disabled *bool `json:"disabled,omitempty" tf:"disabled,omitempty"`

	// Javascript User Defined Function. If multiple Javascript UDFs are specified on a resource,
	// each one must have a unique function_name.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	JavascriptUdf *JavascriptUdfParameters `json:"javascriptUdf,omitempty" tf:"javascript_udf,omitempty"`
}

type NoWrapperInitParameters 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type NoWrapperObservation 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.
	WriteMetadata *bool `json:"writeMetadata,omitempty" tf:"write_metadata,omitempty"`
}

type NoWrapperParameters 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.
	// +kubebuilder:validation:Optional
	WriteMetadata *bool `json:"writeMetadata" tf:"write_metadata,omitempty"`
}

type OidcTokenInitParameters struct {

	// 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.
	Audience *string `json:"audience,omitempty" tf:"audience,omitempty"`

	// 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.
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`
}

type OidcTokenObservation struct {

	// 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.
	Audience *string `json:"audience,omitempty" tf:"audience,omitempty"`

	// 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.
	ServiceAccountEmail *string `json:"serviceAccountEmail,omitempty" tf:"service_account_email,omitempty"`
}

type OidcTokenParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	Audience *string `json:"audience,omitempty" tf:"audience,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	ServiceAccountEmail *string `json:"serviceAccountEmail" tf:"service_account_email,omitempty"`
}

type PartitionConfigInitParameters struct {

	// The capacity configuration.
	// Structure is documented below.
	Capacity *CapacityInitParameters `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// The number of partitions in the topic. Must be at least 1.
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

type PartitionConfigObservation struct {

	// The capacity configuration.
	// Structure is documented below.
	Capacity *CapacityObservation `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// The number of partitions in the topic. Must be at least 1.
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

type PartitionConfigParameters struct {

	// The capacity configuration.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	Capacity *CapacityParameters `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// The number of partitions in the topic. Must be at least 1.
	// +kubebuilder:validation:Optional
	Count *float64 `json:"count" tf:"count,omitempty"`
}

type PlatformLogsSettingsInitParameters struct {

	// The minimum severity level of Platform Logs that will be written. If unspecified,
	// no Platform Logs will be written.
	// Default value is SEVERITY_UNSPECIFIED.
	// Possible values are: SEVERITY_UNSPECIFIED, DISABLED, DEBUG, INFO, WARNING, ERROR.
	Severity *string `json:"severity,omitempty" tf:"severity,omitempty"`
}

type PlatformLogsSettingsObservation struct {

	// The minimum severity level of Platform Logs that will be written. If unspecified,
	// no Platform Logs will be written.
	// Default value is SEVERITY_UNSPECIFIED.
	// Possible values are: SEVERITY_UNSPECIFIED, DISABLED, DEBUG, INFO, WARNING, ERROR.
	Severity *string `json:"severity,omitempty" tf:"severity,omitempty"`
}

type PlatformLogsSettingsParameters struct {

	// The minimum severity level of Platform Logs that will be written. If unspecified,
	// no Platform Logs will be written.
	// Default value is SEVERITY_UNSPECIFIED.
	// Possible values are: SEVERITY_UNSPECIFIED, DISABLED, DEBUG, INFO, WARNING, ERROR.
	// +kubebuilder:validation:Optional
	Severity *string `json:"severity,omitempty" tf:"severity,omitempty"`
}

type PubsubAvroFormatInitParameters struct {
}

type PubsubAvroFormatObservation struct {
}

type PubsubAvroFormatParameters struct {
}

type PushConfigInitParameters struct {

	// 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:
	// +mapType=granular
	Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"`

	// When set, the payload to the push endpoint is not wrapped.Sets the
	// data field as the HTTP body for delivery.
	// Structure is documented below.
	NoWrapper *NoWrapperInitParameters `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"`

	// If specified, Pub/Sub will generate and attach an OIDC JWT token as
	// an Authorization header in the HTTP request for every pushed message.
	// Structure is documented below.
	OidcToken *OidcTokenInitParameters `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"`

	// A URL locating the endpoint to which messages should be pushed.
	// For example, a Webhook endpoint might use
	// "https://example.com/push".
	PushEndpoint *string `json:"pushEndpoint,omitempty" tf:"push_endpoint,omitempty"`
}

type PushConfigObservation struct {

	// 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:
	// +mapType=granular
	Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"`

	// When set, the payload to the push endpoint is not wrapped.Sets the
	// data field as the HTTP body for delivery.
	// Structure is documented below.
	NoWrapper *NoWrapperObservation `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"`

	// If specified, Pub/Sub will generate and attach an OIDC JWT token as
	// an Authorization header in the HTTP request for every pushed message.
	// Structure is documented below.
	OidcToken *OidcTokenObservation `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"`

	// A URL locating the endpoint to which messages should be pushed.
	// For example, a Webhook endpoint might use
	// "https://example.com/push".
	PushEndpoint *string `json:"pushEndpoint,omitempty" tf:"push_endpoint,omitempty"`
}

type PushConfigParameters struct {

	// 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:
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,omitempty"`

	// When set, the payload to the push endpoint is not wrapped.Sets the
	// data field as the HTTP body for delivery.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	NoWrapper *NoWrapperParameters `json:"noWrapper,omitempty" tf:"no_wrapper,omitempty"`

	// If specified, Pub/Sub will generate and attach an OIDC JWT token as
	// an Authorization header in the HTTP request for every pushed message.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	OidcToken *OidcTokenParameters `json:"oidcToken,omitempty" tf:"oidc_token,omitempty"`

	// A URL locating the endpoint to which messages should be pushed.
	// For example, a Webhook endpoint might use
	// "https://example.com/push".
	// +kubebuilder:validation:Optional
	PushEndpoint *string `json:"pushEndpoint" tf:"push_endpoint,omitempty"`
}

type ReservationConfigInitParameters struct {

	// The Reservation to use for this topic's throughput capacity.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.LiteReservation
	ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"`

	// Reference to a LiteReservation in pubsub to populate throughputReservation.
	// +kubebuilder:validation:Optional
	ThroughputReservationRef *v1.NamespacedReference `json:"throughputReservationRef,omitempty" tf:"-"`

	// Selector for a LiteReservation in pubsub to populate throughputReservation.
	// +kubebuilder:validation:Optional
	ThroughputReservationSelector *v1.NamespacedSelector `json:"throughputReservationSelector,omitempty" tf:"-"`
}

type ReservationConfigObservation struct {

	// The Reservation to use for this topic's throughput capacity.
	ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"`
}

type ReservationConfigParameters struct {

	// The Reservation to use for this topic's throughput capacity.
	// +crossplane:generate:reference:type=github.com/johngray-glitch/provider-upjet-gcp/v2/apis/namespaced/pubsub/v1beta1.LiteReservation
	// +kubebuilder:validation:Optional
	ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"`

	// Reference to a LiteReservation in pubsub to populate throughputReservation.
	// +kubebuilder:validation:Optional
	ThroughputReservationRef *v1.NamespacedReference `json:"throughputReservationRef,omitempty" tf:"-"`

	// Selector for a LiteReservation in pubsub to populate throughputReservation.
	// +kubebuilder:validation:Optional
	ThroughputReservationSelector *v1.NamespacedSelector `json:"throughputReservationSelector,omitempty" tf:"-"`
}

type RetentionConfigInitParameters struct {

	// The provisioned storage, in bytes, per partition. If the number of bytes stored
	// in any of the topic's partitions grows beyond this value, older messages will be
	// dropped to make room for newer ones, regardless of the value of period.
	PerPartitionBytes *string `json:"perPartitionBytes,omitempty" tf:"per_partition_bytes,omitempty"`

	// How long a published message is retained. If unset, messages will be retained as
	// long as the bytes retained for each partition is below perPartitionBytes. A
	// duration in seconds with up to nine fractional digits, terminated by 's'.
	// Example: "3.5s".
	Period *string `json:"period,omitempty" tf:"period,omitempty"`
}

type RetentionConfigObservation struct {

	// The provisioned storage, in bytes, per partition. If the number of bytes stored
	// in any of the topic's partitions grows beyond this value, older messages will be
	// dropped to make room for newer ones, regardless of the value of period.
	PerPartitionBytes *string `json:"perPartitionBytes,omitempty" tf:"per_partition_bytes,omitempty"`

	// How long a published message is retained. If unset, messages will be retained as
	// long as the bytes retained for each partition is below perPartitionBytes. A
	// duration in seconds with up to nine fractional digits, terminated by 's'.
	// Example: "3.5s".
	Period *string `json:"period,omitempty" tf:"period,omitempty"`
}

type RetentionConfigParameters struct {

	// The provisioned storage, in bytes, per partition. If the number of bytes stored
	// in any of the topic's partitions grows beyond this value, older messages will be
	// dropped to make room for newer ones, regardless of the value of period.
	// +kubebuilder:validation:Optional
	PerPartitionBytes *string `json:"perPartitionBytes" tf:"per_partition_bytes,omitempty"`

	// How long a published message is retained. If unset, messages will be retained as
	// long as the bytes retained for each partition is below perPartitionBytes. A
	// duration in seconds with up to nine fractional digits, terminated by 's'.
	// Example: "3.5s".
	// +kubebuilder:validation:Optional
	Period *string `json:"period,omitempty" tf:"period,omitempty"`
}

type RetryPolicyInitParameters 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".
	MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"`

	// 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".
	MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"`
}

type RetryPolicyObservation 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".
	MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"`

	// 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".
	MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"`
}

type RetryPolicyParameters 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".
	// +kubebuilder:validation:Optional
	MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"`

	// 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".
	// +kubebuilder:validation:Optional
	MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"`
}

type Schema struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SchemaSpec   `json:"spec"`
	Status            SchemaStatus `json:"status,omitempty"`
}

type SchemaInitParameters struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type. Changes
	// to the definition commit new schema revisions.
	// A schema can only have up to 20 revisions, so updates that fail with an
	// error indicating that the limit has been reached require manually
	// deleting old revisions.
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The type of the schema definition
	// Default value is TYPE_UNSPECIFIED.
	// Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

type SchemaList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Schema `json:"items"`
}

type SchemaObservation struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type. Changes
	// to the definition commit new schema revisions.
	// A schema can only have up to 20 revisions, so updates that fail with an
	// error indicating that the limit has been reached require manually
	// deleting old revisions.
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

	// an identifier for the resource with format projects/{{project}}/schemas/{{name}}
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The type of the schema definition
	// Default value is TYPE_UNSPECIFIED.
	// Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

type SchemaParameters struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type. Changes
	// to the definition commit new schema revisions.
	// A schema can only have up to 20 revisions, so updates that fail with an
	// error indicating that the limit has been reached require manually
	// deleting old revisions.
	// +kubebuilder:validation:Optional
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// The type of the schema definition
	// Default value is TYPE_UNSPECIFIED.
	// Possible values are: TYPE_UNSPECIFIED, PROTOCOL_BUFFER, AVRO.
	// +kubebuilder:validation:Optional
	Type *string `json:"type,omitempty" tf:"type,omitempty"`
}

type SchemaSettingsInitParameters struct {

	// The encoding of messages validated against schema.
	// Default value is ENCODING_UNSPECIFIED.
	// Possible values are: ENCODING_UNSPECIFIED, JSON, BINARY.
	Encoding *string `json:"encoding,omitempty" tf:"encoding,omitempty"`

	// The name of the schema that messages published should be
	// validated against. Format is projects/{project}/schemas/{schema}.
	// The value of this field will be deleted-schema
	// if the schema has been deleted.
	Schema *string `json:"schema,omitempty" tf:"schema,omitempty"`
}