v1beta2

package
v1.10.0-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 5, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Overview

+kubebuilder:object:generate=true +groupName=pubsub.gcp.upbound.io +versionName=v1beta2

Index

Constants

View Source 
const (
	CRDGroup   = "pubsub.gcp.upbound.io"
	CRDVersion = "v1beta2"
)

Package type metadata.

Variables

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	LiteSubscription_Kind             = "LiteSubscription"
	LiteSubscription_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: LiteSubscription_Kind}.String()
	LiteSubscription_KindAPIVersion   = LiteSubscription_Kind + "." + CRDGroupVersion.String()
	LiteSubscription_GroupVersionKind = CRDGroupVersion.WithKind(LiteSubscription_Kind)
)

Repository type metadata.

View Source 
var (
	LiteTopic_Kind             = "LiteTopic"
	LiteTopic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: LiteTopic_Kind}.String()
	LiteTopic_KindAPIVersion   = LiteTopic_Kind + "." + CRDGroupVersion.String()
	LiteTopic_GroupVersionKind = CRDGroupVersion.WithKind(LiteTopic_Kind)
)

Repository type metadata.

View Source 
var (
	Subscription_Kind             = "Subscription"
	Subscription_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Subscription_Kind}.String()
	Subscription_KindAPIVersion   = Subscription_Kind + "." + CRDGroupVersion.String()
	Subscription_GroupVersionKind = CRDGroupVersion.WithKind(Subscription_Kind)
)

Repository type metadata.

View Source 
var (
	SubscriptionIAMMember_Kind             = "SubscriptionIAMMember"
	SubscriptionIAMMember_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: SubscriptionIAMMember_Kind}.String()
	SubscriptionIAMMember_KindAPIVersion   = SubscriptionIAMMember_Kind + "." + CRDGroupVersion.String()
	SubscriptionIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(SubscriptionIAMMember_Kind)
)

Repository type metadata.

View Source 
var (
	Topic_Kind             = "Topic"
	Topic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Topic_Kind}.String()
	Topic_KindAPIVersion   = Topic_Kind + "." + CRDGroupVersion.String()
	Topic_GroupVersionKind = CRDGroupVersion.WithKind(Topic_Kind)
)

Repository type metadata.

View Source 
var (
	TopicIAMMember_Kind             = "TopicIAMMember"
	TopicIAMMember_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: TopicIAMMember_Kind}.String()
	TopicIAMMember_KindAPIVersion   = TopicIAMMember_Kind + "." + CRDGroupVersion.String()
	TopicIAMMember_GroupVersionKind = CRDGroupVersion.WithKind(TopicIAMMember_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type AvroConfigInitParameters 

type AvroConfigInitParameters 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"`
}

func (*AvroConfigInitParameters) DeepCopy 

func (in *AvroConfigInitParameters) DeepCopy() *AvroConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigInitParameters.

func (*AvroConfigInitParameters) DeepCopyInto 

func (in *AvroConfigInitParameters) DeepCopyInto(out *AvroConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AvroConfigObservation 

type AvroConfigObservation 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"`
}

func (*AvroConfigObservation) DeepCopy 

func (in *AvroConfigObservation) DeepCopy() *AvroConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigObservation.

func (*AvroConfigObservation) DeepCopyInto 

func (in *AvroConfigObservation) DeepCopyInto(out *AvroConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AvroConfigParameters 

type AvroConfigParameters 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,omitempty" tf:"write_metadata,omitempty"`
}

func (*AvroConfigParameters) DeepCopy 

func (in *AvroConfigParameters) DeepCopy() *AvroConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AvroConfigParameters.

func (*AvroConfigParameters) DeepCopyInto 

func (in *AvroConfigParameters) DeepCopyInto(out *AvroConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AwsKinesisInitParameters added in v1.5.0 

type AwsKinesisInitParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// Kinesis. 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 Kinesis (via a AssumeRoleWithWebIdentity call for the provided
	// role). The awsRoleArn must be set up with accounts.google.com:sub
	// equals to this service account number.
	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"`
}

func (*AwsKinesisInitParameters) DeepCopy added in v1.5.0 

func (in *AwsKinesisInitParameters) DeepCopy() *AwsKinesisInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsKinesisInitParameters.

func (*AwsKinesisInitParameters) DeepCopyInto added in v1.5.0 

func (in *AwsKinesisInitParameters) DeepCopyInto(out *AwsKinesisInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AwsKinesisObservation added in v1.5.0 

type AwsKinesisObservation struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// Kinesis. 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 Kinesis (via a AssumeRoleWithWebIdentity call for the provided
	// role). The awsRoleArn must be set up with accounts.google.com:sub
	// equals to this service account number.
	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"`
}

func (*AwsKinesisObservation) DeepCopy added in v1.5.0 

func (in *AwsKinesisObservation) DeepCopy() *AwsKinesisObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsKinesisObservation.

func (*AwsKinesisObservation) DeepCopyInto added in v1.5.0 

func (in *AwsKinesisObservation) DeepCopyInto(out *AwsKinesisObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AwsKinesisParameters added in v1.5.0 

type AwsKinesisParameters struct {

	// AWS role ARN to be used for Federated Identity authentication with
	// Kinesis. 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 Kinesis (via a AssumeRoleWithWebIdentity call for the provided
	// role). The awsRoleArn must be set up with accounts.google.com:sub
	// equals to this service account number.
	// +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"`
}

func (*AwsKinesisParameters) DeepCopy added in v1.5.0 

func (in *AwsKinesisParameters) DeepCopy() *AwsKinesisParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsKinesisParameters.

func (*AwsKinesisParameters) DeepCopyInto added in v1.5.0 

func (in *AwsKinesisParameters) DeepCopyInto(out *AwsKinesisParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BigqueryConfigInitParameters 

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/upbound/provider-gcp/apis/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.Selector `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"`
}

func (*BigqueryConfigInitParameters) DeepCopy 

func (in *BigqueryConfigInitParameters) DeepCopy() *BigqueryConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigInitParameters.

func (*BigqueryConfigInitParameters) DeepCopyInto 

func (in *BigqueryConfigInitParameters) DeepCopyInto(out *BigqueryConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BigqueryConfigObservation 

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"`
}

func (*BigqueryConfigObservation) DeepCopy 

func (in *BigqueryConfigObservation) DeepCopy() *BigqueryConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigObservation.

func (*BigqueryConfigObservation) DeepCopyInto 

func (in *BigqueryConfigObservation) DeepCopyInto(out *BigqueryConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BigqueryConfigParameters 

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/upbound/provider-gcp/apis/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

	// Selector for a ServiceAccount in cloudplatform to populate serviceAccountEmail.
	// +kubebuilder:validation:Optional
	ServiceAccountEmailSelector *v1.Selector `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"`
}

func (*BigqueryConfigParameters) DeepCopy 

func (in *BigqueryConfigParameters) DeepCopy() *BigqueryConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BigqueryConfigParameters.

func (*BigqueryConfigParameters) DeepCopyInto 

func (in *BigqueryConfigParameters) DeepCopyInto(out *BigqueryConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CapacityInitParameters 

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"`
}

func (*CapacityInitParameters) DeepCopy 

func (in *CapacityInitParameters) DeepCopy() *CapacityInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityInitParameters.

func (*CapacityInitParameters) DeepCopyInto 

func (in *CapacityInitParameters) DeepCopyInto(out *CapacityInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CapacityObservation 

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"`
}

func (*CapacityObservation) DeepCopy 

func (in *CapacityObservation) DeepCopy() *CapacityObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityObservation.

func (*CapacityObservation) DeepCopyInto 

func (in *CapacityObservation) DeepCopyInto(out *CapacityObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CapacityParameters 

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"`
}

func (*CapacityParameters) DeepCopy 

func (in *CapacityParameters) DeepCopy() *CapacityParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityParameters.

func (*CapacityParameters) DeepCopyInto 

func (in *CapacityParameters) DeepCopyInto(out *CapacityParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudStorageConfigInitParameters 

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 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/upbound/provider-gcp/apis/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

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

func (*CloudStorageConfigInitParameters) DeepCopy 

func (in *CloudStorageConfigInitParameters) DeepCopy() *CloudStorageConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigInitParameters.

func (*CloudStorageConfigInitParameters) DeepCopyInto 

func (in *CloudStorageConfigInitParameters) DeepCopyInto(out *CloudStorageConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudStorageConfigObservation 

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 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"`
}

func (*CloudStorageConfigObservation) DeepCopy 

func (in *CloudStorageConfigObservation) DeepCopy() *CloudStorageConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigObservation.

func (*CloudStorageConfigObservation) DeepCopyInto 

func (in *CloudStorageConfigObservation) DeepCopyInto(out *CloudStorageConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudStorageConfigParameters 

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 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/upbound/provider-gcp/apis/cloudplatform/v1beta1.ServiceAccount
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"serviceAccountEmailRef,omitempty" tf:"-"`

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

func (*CloudStorageConfigParameters) DeepCopy 

func (in *CloudStorageConfigParameters) DeepCopy() *CloudStorageConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudStorageConfigParameters.

func (*CloudStorageConfigParameters) DeepCopyInto 

func (in *CloudStorageConfigParameters) DeepCopyInto(out *CloudStorageConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConditionInitParameters 

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"`
}

func (*ConditionInitParameters) DeepCopy 

func (in *ConditionInitParameters) DeepCopy() *ConditionInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionInitParameters.

func (*ConditionInitParameters) DeepCopyInto 

func (in *ConditionInitParameters) DeepCopyInto(out *ConditionInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConditionObservation 

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"`
}

func (*ConditionObservation) DeepCopy 

func (in *ConditionObservation) DeepCopy() *ConditionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionObservation.

func (*ConditionObservation) DeepCopyInto 

func (in *ConditionObservation) DeepCopyInto(out *ConditionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConditionParameters 

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"`
}

func (*ConditionParameters) DeepCopy 

func (in *ConditionParameters) DeepCopy() *ConditionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionParameters.

func (*ConditionParameters) DeepCopyInto 

func (in *ConditionParameters) DeepCopyInto(out *ConditionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeadLetterPolicyInitParameters 

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/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"deadLetterTopicRef,omitempty" tf:"-"`

	// Selector for a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicSelector *v1.Selector `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"`
}

func (*DeadLetterPolicyInitParameters) DeepCopy 

func (in *DeadLetterPolicyInitParameters) DeepCopy() *DeadLetterPolicyInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyInitParameters.

func (*DeadLetterPolicyInitParameters) DeepCopyInto 

func (in *DeadLetterPolicyInitParameters) DeepCopyInto(out *DeadLetterPolicyInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeadLetterPolicyObservation 

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"`
}

func (*DeadLetterPolicyObservation) DeepCopy 

func (in *DeadLetterPolicyObservation) DeepCopy() *DeadLetterPolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyObservation.

func (*DeadLetterPolicyObservation) DeepCopyInto 

func (in *DeadLetterPolicyObservation) DeepCopyInto(out *DeadLetterPolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeadLetterPolicyParameters 

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/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/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.Reference `json:"deadLetterTopicRef,omitempty" tf:"-"`

	// Selector for a Topic in pubsub to populate deadLetterTopic.
	// +kubebuilder:validation:Optional
	DeadLetterTopicSelector *v1.Selector `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"`
}

func (*DeadLetterPolicyParameters) DeepCopy 

func (in *DeadLetterPolicyParameters) DeepCopy() *DeadLetterPolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterPolicyParameters.

func (*DeadLetterPolicyParameters) DeepCopyInto 

func (in *DeadLetterPolicyParameters) DeepCopyInto(out *DeadLetterPolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeliveryConfigInitParameters 

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"`
}

func (*DeliveryConfigInitParameters) DeepCopy 

func (in *DeliveryConfigInitParameters) DeepCopy() *DeliveryConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigInitParameters.

func (*DeliveryConfigInitParameters) DeepCopyInto 

func (in *DeliveryConfigInitParameters) DeepCopyInto(out *DeliveryConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeliveryConfigObservation 

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"`
}

func (*DeliveryConfigObservation) DeepCopy 

func (in *DeliveryConfigObservation) DeepCopy() *DeliveryConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigObservation.

func (*DeliveryConfigObservation) DeepCopyInto 

func (in *DeliveryConfigObservation) DeepCopyInto(out *DeliveryConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeliveryConfigParameters 

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"`
}

func (*DeliveryConfigParameters) DeepCopy 

func (in *DeliveryConfigParameters) DeepCopy() *DeliveryConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeliveryConfigParameters.

func (*DeliveryConfigParameters) DeepCopyInto 

func (in *DeliveryConfigParameters) DeepCopyInto(out *DeliveryConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExpirationPolicyInitParameters 

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"`
}

func (*ExpirationPolicyInitParameters) DeepCopy 

func (in *ExpirationPolicyInitParameters) DeepCopy() *ExpirationPolicyInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyInitParameters.

func (*ExpirationPolicyInitParameters) DeepCopyInto 

func (in *ExpirationPolicyInitParameters) DeepCopyInto(out *ExpirationPolicyInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExpirationPolicyObservation 

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"`
}

func (*ExpirationPolicyObservation) DeepCopy 

func (in *ExpirationPolicyObservation) DeepCopy() *ExpirationPolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyObservation.

func (*ExpirationPolicyObservation) DeepCopyInto 

func (in *ExpirationPolicyObservation) DeepCopyInto(out *ExpirationPolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExpirationPolicyParameters 

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"`
}

func (*ExpirationPolicyParameters) DeepCopy 

func (in *ExpirationPolicyParameters) DeepCopy() *ExpirationPolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExpirationPolicyParameters.

func (*ExpirationPolicyParameters) DeepCopyInto 

func (in *ExpirationPolicyParameters) DeepCopyInto(out *ExpirationPolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IngestionDataSourceSettingsInitParameters added in v1.5.0 

type IngestionDataSourceSettingsInitParameters struct {

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

func (*IngestionDataSourceSettingsInitParameters) DeepCopy added in v1.5.0 

func (in *IngestionDataSourceSettingsInitParameters) DeepCopy() *IngestionDataSourceSettingsInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IngestionDataSourceSettingsInitParameters.

func (*IngestionDataSourceSettingsInitParameters) DeepCopyInto added in v1.5.0 

func (in *IngestionDataSourceSettingsInitParameters) DeepCopyInto(out *IngestionDataSourceSettingsInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IngestionDataSourceSettingsObservation added in v1.5.0 

type IngestionDataSourceSettingsObservation struct {

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

func (*IngestionDataSourceSettingsObservation) DeepCopy added in v1.5.0 

func (in *IngestionDataSourceSettingsObservation) DeepCopy() *IngestionDataSourceSettingsObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IngestionDataSourceSettingsObservation.

func (*IngestionDataSourceSettingsObservation) DeepCopyInto added in v1.5.0 

func (in *IngestionDataSourceSettingsObservation) DeepCopyInto(out *IngestionDataSourceSettingsObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IngestionDataSourceSettingsParameters added in v1.5.0 

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"`
}

func (*IngestionDataSourceSettingsParameters) DeepCopy added in v1.5.0 

func (in *IngestionDataSourceSettingsParameters) DeepCopy() *IngestionDataSourceSettingsParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IngestionDataSourceSettingsParameters.

func (*IngestionDataSourceSettingsParameters) DeepCopyInto added in v1.5.0 

func (in *IngestionDataSourceSettingsParameters) DeepCopyInto(out *IngestionDataSourceSettingsParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteSubscription 

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

LiteSubscription is the Schema for the LiteSubscriptions API. A named resource representing the stream of messages from a single, specific topic, to be delivered to the subscribing application. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*LiteSubscription) DeepCopy 

func (in *LiteSubscription) DeepCopy() *LiteSubscription

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscription.

func (*LiteSubscription) DeepCopyInto 

func (in *LiteSubscription) DeepCopyInto(out *LiteSubscription)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LiteSubscription) DeepCopyObject 

func (in *LiteSubscription) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LiteSubscription) GetCondition 

func (mg *LiteSubscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this LiteSubscription.

func (*LiteSubscription) GetConnectionDetailsMapping 

func (tr *LiteSubscription) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this LiteSubscription

func (*LiteSubscription) GetDeletionPolicy 

func (mg *LiteSubscription) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this LiteSubscription.

func (*LiteSubscription) GetID 

func (tr *LiteSubscription) GetID() string

GetID returns ID of underlying Terraform resource of this LiteSubscription

func (*LiteSubscription) GetInitParameters 

func (tr *LiteSubscription) GetInitParameters() (map[string]any, error)

GetInitParameters of this LiteSubscription

func (*LiteSubscription) GetManagementPolicies 

func (mg *LiteSubscription) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this LiteSubscription.

func (*LiteSubscription) GetMergedParameters 

func (tr *LiteSubscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this LiteSubscription

func (*LiteSubscription) GetObservation 

func (tr *LiteSubscription) GetObservation() (map[string]any, error)

GetObservation of this LiteSubscription

func (*LiteSubscription) GetParameters 

func (tr *LiteSubscription) GetParameters() (map[string]any, error)

GetParameters of this LiteSubscription

func (*LiteSubscription) GetProviderConfigReference 

func (mg *LiteSubscription) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this LiteSubscription.

func (*LiteSubscription) GetPublishConnectionDetailsTo 

func (mg *LiteSubscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this LiteSubscription.

func (*LiteSubscription) GetTerraformResourceType 

func (mg *LiteSubscription) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this LiteSubscription

func (*LiteSubscription) GetTerraformSchemaVersion 

func (tr *LiteSubscription) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*LiteSubscription) GetWriteConnectionSecretToReference 

func (mg *LiteSubscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this LiteSubscription.

func (*LiteSubscription) Hub 

func (tr *LiteSubscription) Hub()

Hub marks this type as a conversion hub.

func (*LiteSubscription) LateInitialize 

func (tr *LiteSubscription) LateInitialize(attrs []byte) (bool, error)

LateInitialize this LiteSubscription using its observed tfState. returns True if there are any spec changes for the resource.

func (*LiteSubscription) ResolveReferences 

func (mg *LiteSubscription) ResolveReferences(
	ctx context.Context, c client.Reader) error

func (*LiteSubscription) SetConditions 

func (mg *LiteSubscription) SetConditions(c ...xpv1.Condition)

SetConditions of this LiteSubscription.

func (*LiteSubscription) SetDeletionPolicy 

func (mg *LiteSubscription) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this LiteSubscription.

func (*LiteSubscription) SetManagementPolicies 

func (mg *LiteSubscription) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this LiteSubscription.

func (*LiteSubscription) SetObservation 

func (tr *LiteSubscription) SetObservation(obs map[string]any) error

SetObservation for this LiteSubscription

func (*LiteSubscription) SetParameters 

func (tr *LiteSubscription) SetParameters(params map[string]any) error

SetParameters for this LiteSubscription

func (*LiteSubscription) SetProviderConfigReference 

func (mg *LiteSubscription) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this LiteSubscription.

func (*LiteSubscription) SetPublishConnectionDetailsTo 

func (mg *LiteSubscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this LiteSubscription.

func (*LiteSubscription) SetWriteConnectionSecretToReference 

func (mg *LiteSubscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this LiteSubscription.

type LiteSubscriptionInitParameters 

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/upbound/provider-gcp/apis/pubsub/v1beta2.LiteTopic
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*LiteSubscriptionInitParameters) DeepCopy 

func (in *LiteSubscriptionInitParameters) DeepCopy() *LiteSubscriptionInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionInitParameters.

func (*LiteSubscriptionInitParameters) DeepCopyInto 

func (in *LiteSubscriptionInitParameters) DeepCopyInto(out *LiteSubscriptionInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteSubscriptionList 

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

LiteSubscriptionList contains a list of LiteSubscriptions

func (*LiteSubscriptionList) DeepCopy 

func (in *LiteSubscriptionList) DeepCopy() *LiteSubscriptionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionList.

func (*LiteSubscriptionList) DeepCopyInto 

func (in *LiteSubscriptionList) DeepCopyInto(out *LiteSubscriptionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LiteSubscriptionList) DeepCopyObject 

func (in *LiteSubscriptionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LiteSubscriptionList) GetItems 

func (l *LiteSubscriptionList) GetItems() []resource.Managed

GetItems of this LiteSubscriptionList.

type LiteSubscriptionObservation 

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"`
}

func (*LiteSubscriptionObservation) DeepCopy 

func (in *LiteSubscriptionObservation) DeepCopy() *LiteSubscriptionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionObservation.

func (*LiteSubscriptionObservation) DeepCopyInto 

func (in *LiteSubscriptionObservation) DeepCopyInto(out *LiteSubscriptionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteSubscriptionParameters 

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/upbound/provider-gcp/apis/pubsub/v1beta2.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.Reference `json:"topicRef,omitempty" tf:"-"`

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

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

func (*LiteSubscriptionParameters) DeepCopy 

func (in *LiteSubscriptionParameters) DeepCopy() *LiteSubscriptionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionParameters.

func (*LiteSubscriptionParameters) DeepCopyInto 

func (in *LiteSubscriptionParameters) DeepCopyInto(out *LiteSubscriptionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteSubscriptionSpec 

type LiteSubscriptionSpec struct {
	v1.ResourceSpec `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"`
}

LiteSubscriptionSpec defines the desired state of LiteSubscription

func (*LiteSubscriptionSpec) DeepCopy 

func (in *LiteSubscriptionSpec) DeepCopy() *LiteSubscriptionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionSpec.

func (*LiteSubscriptionSpec) DeepCopyInto 

func (in *LiteSubscriptionSpec) DeepCopyInto(out *LiteSubscriptionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteSubscriptionStatus 

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

LiteSubscriptionStatus defines the observed state of LiteSubscription.

func (*LiteSubscriptionStatus) DeepCopy 

func (in *LiteSubscriptionStatus) DeepCopy() *LiteSubscriptionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteSubscriptionStatus.

func (*LiteSubscriptionStatus) DeepCopyInto 

func (in *LiteSubscriptionStatus) DeepCopyInto(out *LiteSubscriptionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteTopic 

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"`
}

LiteTopic is the Schema for the LiteTopics API. A named resource to which messages are sent by publishers. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*LiteTopic) DeepCopy 

func (in *LiteTopic) DeepCopy() *LiteTopic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopic.

func (*LiteTopic) DeepCopyInto 

func (in *LiteTopic) DeepCopyInto(out *LiteTopic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LiteTopic) DeepCopyObject 

func (in *LiteTopic) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LiteTopic) GetCondition 

func (mg *LiteTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this LiteTopic.

func (*LiteTopic) GetConnectionDetailsMapping 

func (tr *LiteTopic) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this LiteTopic

func (*LiteTopic) GetDeletionPolicy 

func (mg *LiteTopic) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this LiteTopic.

func (*LiteTopic) GetID 

func (tr *LiteTopic) GetID() string

GetID returns ID of underlying Terraform resource of this LiteTopic

func (*LiteTopic) GetInitParameters 

func (tr *LiteTopic) GetInitParameters() (map[string]any, error)

GetInitParameters of this LiteTopic

func (*LiteTopic) GetManagementPolicies 

func (mg *LiteTopic) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this LiteTopic.

func (*LiteTopic) GetMergedParameters 

func (tr *LiteTopic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this LiteTopic

func (*LiteTopic) GetObservation 

func (tr *LiteTopic) GetObservation() (map[string]any, error)

GetObservation of this LiteTopic

func (*LiteTopic) GetParameters 

func (tr *LiteTopic) GetParameters() (map[string]any, error)

GetParameters of this LiteTopic

func (*LiteTopic) GetProviderConfigReference 

func (mg *LiteTopic) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this LiteTopic.

func (*LiteTopic) GetPublishConnectionDetailsTo 

func (mg *LiteTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this LiteTopic.

func (*LiteTopic) GetTerraformResourceType 

func (mg *LiteTopic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this LiteTopic

func (*LiteTopic) GetTerraformSchemaVersion 

func (tr *LiteTopic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*LiteTopic) GetWriteConnectionSecretToReference 

func (mg *LiteTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this LiteTopic.

func (*LiteTopic) Hub 

func (tr *LiteTopic) Hub()

Hub marks this type as a conversion hub.

func (*LiteTopic) LateInitialize 

func (tr *LiteTopic) LateInitialize(attrs []byte) (bool, error)

LateInitialize this LiteTopic using its observed tfState. returns True if there are any spec changes for the resource.

func (*LiteTopic) ResolveReferences 

func (mg *LiteTopic) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this LiteTopic.

func (*LiteTopic) SetConditions 

func (mg *LiteTopic) SetConditions(c ...xpv1.Condition)

SetConditions of this LiteTopic.

func (*LiteTopic) SetDeletionPolicy 

func (mg *LiteTopic) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this LiteTopic.

func (*LiteTopic) SetManagementPolicies 

func (mg *LiteTopic) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this LiteTopic.

func (*LiteTopic) SetObservation 

func (tr *LiteTopic) SetObservation(obs map[string]any) error

SetObservation for this LiteTopic

func (*LiteTopic) SetParameters 

func (tr *LiteTopic) SetParameters(params map[string]any) error

SetParameters for this LiteTopic

func (*LiteTopic) SetProviderConfigReference 

func (mg *LiteTopic) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this LiteTopic.

func (*LiteTopic) SetPublishConnectionDetailsTo 

func (mg *LiteTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this LiteTopic.

func (*LiteTopic) SetWriteConnectionSecretToReference 

func (mg *LiteTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this LiteTopic.

type LiteTopicInitParameters 

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"`
}

func (*LiteTopicInitParameters) DeepCopy 

func (in *LiteTopicInitParameters) DeepCopy() *LiteTopicInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicInitParameters.

func (*LiteTopicInitParameters) DeepCopyInto 

func (in *LiteTopicInitParameters) DeepCopyInto(out *LiteTopicInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteTopicList 

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

LiteTopicList contains a list of LiteTopics

func (*LiteTopicList) DeepCopy 

func (in *LiteTopicList) DeepCopy() *LiteTopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicList.

func (*LiteTopicList) DeepCopyInto 

func (in *LiteTopicList) DeepCopyInto(out *LiteTopicList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LiteTopicList) DeepCopyObject 

func (in *LiteTopicList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*LiteTopicList) GetItems 

func (l *LiteTopicList) GetItems() []resource.Managed

GetItems of this LiteTopicList.

type LiteTopicObservation 

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"`
}

func (*LiteTopicObservation) DeepCopy 

func (in *LiteTopicObservation) DeepCopy() *LiteTopicObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicObservation.

func (*LiteTopicObservation) DeepCopyInto 

func (in *LiteTopicObservation) DeepCopyInto(out *LiteTopicObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteTopicParameters 

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"`
}

func (*LiteTopicParameters) DeepCopy 

func (in *LiteTopicParameters) DeepCopy() *LiteTopicParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicParameters.

func (*LiteTopicParameters) DeepCopyInto 

func (in *LiteTopicParameters) DeepCopyInto(out *LiteTopicParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteTopicSpec 

type LiteTopicSpec struct {
	v1.ResourceSpec `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"`
}

LiteTopicSpec defines the desired state of LiteTopic

func (*LiteTopicSpec) DeepCopy 

func (in *LiteTopicSpec) DeepCopy() *LiteTopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicSpec.

func (*LiteTopicSpec) DeepCopyInto 

func (in *LiteTopicSpec) DeepCopyInto(out *LiteTopicSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LiteTopicStatus 

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

LiteTopicStatus defines the observed state of LiteTopic.

func (*LiteTopicStatus) DeepCopy 

func (in *LiteTopicStatus) DeepCopy() *LiteTopicStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LiteTopicStatus.

func (*LiteTopicStatus) DeepCopyInto 

func (in *LiteTopicStatus) DeepCopyInto(out *LiteTopicStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MessageStoragePolicyInitParameters 

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.
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"`
}

func (*MessageStoragePolicyInitParameters) DeepCopy 

func (in *MessageStoragePolicyInitParameters) DeepCopy() *MessageStoragePolicyInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyInitParameters.

func (*MessageStoragePolicyInitParameters) DeepCopyInto 

func (in *MessageStoragePolicyInitParameters) DeepCopyInto(out *MessageStoragePolicyInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MessageStoragePolicyObservation 

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.
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions,omitempty" tf:"allowed_persistence_regions,omitempty"`
}

func (*MessageStoragePolicyObservation) DeepCopy 

func (in *MessageStoragePolicyObservation) DeepCopy() *MessageStoragePolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyObservation.

func (*MessageStoragePolicyObservation) DeepCopyInto 

func (in *MessageStoragePolicyObservation) DeepCopyInto(out *MessageStoragePolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MessageStoragePolicyParameters 

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
	AllowedPersistenceRegions []*string `json:"allowedPersistenceRegions" tf:"allowed_persistence_regions,omitempty"`
}

func (*MessageStoragePolicyParameters) DeepCopy 

func (in *MessageStoragePolicyParameters) DeepCopy() *MessageStoragePolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageStoragePolicyParameters.

func (*MessageStoragePolicyParameters) DeepCopyInto 

func (in *MessageStoragePolicyParameters) DeepCopyInto(out *MessageStoragePolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NoWrapperInitParameters 

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"`
}

func (*NoWrapperInitParameters) DeepCopy 

func (in *NoWrapperInitParameters) DeepCopy() *NoWrapperInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperInitParameters.

func (*NoWrapperInitParameters) DeepCopyInto 

func (in *NoWrapperInitParameters) DeepCopyInto(out *NoWrapperInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NoWrapperObservation 

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"`
}

func (*NoWrapperObservation) DeepCopy 

func (in *NoWrapperObservation) DeepCopy() *NoWrapperObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperObservation.

func (*NoWrapperObservation) DeepCopyInto 

func (in *NoWrapperObservation) DeepCopyInto(out *NoWrapperObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NoWrapperParameters 

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"`
}

func (*NoWrapperParameters) DeepCopy 

func (in *NoWrapperParameters) DeepCopy() *NoWrapperParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoWrapperParameters.

func (*NoWrapperParameters) DeepCopyInto 

func (in *NoWrapperParameters) DeepCopyInto(out *NoWrapperParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OidcTokenInitParameters 

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"`
}

func (*OidcTokenInitParameters) DeepCopy 

func (in *OidcTokenInitParameters) DeepCopy() *OidcTokenInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenInitParameters.

func (*OidcTokenInitParameters) DeepCopyInto 

func (in *OidcTokenInitParameters) DeepCopyInto(out *OidcTokenInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OidcTokenObservation 

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"`
}

func (*OidcTokenObservation) DeepCopy 

func (in *OidcTokenObservation) DeepCopy() *OidcTokenObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenObservation.

func (*OidcTokenObservation) DeepCopyInto 

func (in *OidcTokenObservation) DeepCopyInto(out *OidcTokenObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OidcTokenParameters 

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"`
}

func (*OidcTokenParameters) DeepCopy 

func (in *OidcTokenParameters) DeepCopy() *OidcTokenParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OidcTokenParameters.

func (*OidcTokenParameters) DeepCopyInto 

func (in *OidcTokenParameters) DeepCopyInto(out *OidcTokenParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PartitionConfigInitParameters 

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"`
}

func (*PartitionConfigInitParameters) DeepCopy 

func (in *PartitionConfigInitParameters) DeepCopy() *PartitionConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigInitParameters.

func (*PartitionConfigInitParameters) DeepCopyInto 

func (in *PartitionConfigInitParameters) DeepCopyInto(out *PartitionConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PartitionConfigObservation 

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"`
}

func (*PartitionConfigObservation) DeepCopy 

func (in *PartitionConfigObservation) DeepCopy() *PartitionConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigObservation.

func (*PartitionConfigObservation) DeepCopyInto 

func (in *PartitionConfigObservation) DeepCopyInto(out *PartitionConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PartitionConfigParameters 

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"`
}

func (*PartitionConfigParameters) DeepCopy 

func (in *PartitionConfigParameters) DeepCopy() *PartitionConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PartitionConfigParameters.

func (*PartitionConfigParameters) DeepCopyInto 

func (in *PartitionConfigParameters) DeepCopyInto(out *PartitionConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PushConfigInitParameters 

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"`
}

func (*PushConfigInitParameters) DeepCopy 

func (in *PushConfigInitParameters) DeepCopy() *PushConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigInitParameters.

func (*PushConfigInitParameters) DeepCopyInto 

func (in *PushConfigInitParameters) DeepCopyInto(out *PushConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PushConfigObservation 

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"`
}

func (*PushConfigObservation) DeepCopy 

func (in *PushConfigObservation) DeepCopy() *PushConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigObservation.

func (*PushConfigObservation) DeepCopyInto 

func (in *PushConfigObservation) DeepCopyInto(out *PushConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PushConfigParameters 

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"`
}

func (*PushConfigParameters) DeepCopy 

func (in *PushConfigParameters) DeepCopy() *PushConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PushConfigParameters.

func (*PushConfigParameters) DeepCopyInto 

func (in *PushConfigParameters) DeepCopyInto(out *PushConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReservationConfigInitParameters 

type ReservationConfigInitParameters struct {

	// The Reservation to use for this topic's throughput capacity.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/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.Reference `json:"throughputReservationRef,omitempty" tf:"-"`

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

func (*ReservationConfigInitParameters) DeepCopy 

func (in *ReservationConfigInitParameters) DeepCopy() *ReservationConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigInitParameters.

func (*ReservationConfigInitParameters) DeepCopyInto 

func (in *ReservationConfigInitParameters) DeepCopyInto(out *ReservationConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReservationConfigObservation 

type ReservationConfigObservation struct {

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

func (*ReservationConfigObservation) DeepCopy 

func (in *ReservationConfigObservation) DeepCopy() *ReservationConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigObservation.

func (*ReservationConfigObservation) DeepCopyInto 

func (in *ReservationConfigObservation) DeepCopyInto(out *ReservationConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReservationConfigParameters 

type ReservationConfigParameters struct {

	// The Reservation to use for this topic's throughput capacity.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/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.Reference `json:"throughputReservationRef,omitempty" tf:"-"`

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

func (*ReservationConfigParameters) DeepCopy 

func (in *ReservationConfigParameters) DeepCopy() *ReservationConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReservationConfigParameters.

func (*ReservationConfigParameters) DeepCopyInto 

func (in *ReservationConfigParameters) DeepCopyInto(out *ReservationConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetentionConfigInitParameters 

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"`
}

func (*RetentionConfigInitParameters) DeepCopy 

func (in *RetentionConfigInitParameters) DeepCopy() *RetentionConfigInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigInitParameters.

func (*RetentionConfigInitParameters) DeepCopyInto 

func (in *RetentionConfigInitParameters) DeepCopyInto(out *RetentionConfigInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetentionConfigObservation 

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"`
}

func (*RetentionConfigObservation) DeepCopy 

func (in *RetentionConfigObservation) DeepCopy() *RetentionConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigObservation.

func (*RetentionConfigObservation) DeepCopyInto 

func (in *RetentionConfigObservation) DeepCopyInto(out *RetentionConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetentionConfigParameters 

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"`
}

func (*RetentionConfigParameters) DeepCopy 

func (in *RetentionConfigParameters) DeepCopy() *RetentionConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetentionConfigParameters.

func (*RetentionConfigParameters) DeepCopyInto 

func (in *RetentionConfigParameters) DeepCopyInto(out *RetentionConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryPolicyInitParameters 

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"`
}

func (*RetryPolicyInitParameters) DeepCopy 

func (in *RetryPolicyInitParameters) DeepCopy() *RetryPolicyInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyInitParameters.

func (*RetryPolicyInitParameters) DeepCopyInto 

func (in *RetryPolicyInitParameters) DeepCopyInto(out *RetryPolicyInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryPolicyObservation 

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"`
}

func (*RetryPolicyObservation) DeepCopy 

func (in *RetryPolicyObservation) DeepCopy() *RetryPolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyObservation.

func (*RetryPolicyObservation) DeepCopyInto 

func (in *RetryPolicyObservation) DeepCopyInto(out *RetryPolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryPolicyParameters 

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"`
}

func (*RetryPolicyParameters) DeepCopy 

func (in *RetryPolicyParameters) DeepCopy() *RetryPolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryPolicyParameters.

func (*RetryPolicyParameters) DeepCopyInto 

func (in *RetryPolicyParameters) DeepCopyInto(out *RetryPolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SchemaSettingsInitParameters 

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"`
}

func (*SchemaSettingsInitParameters) DeepCopy 

func (in *SchemaSettingsInitParameters) DeepCopy() *SchemaSettingsInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsInitParameters.

func (*SchemaSettingsInitParameters) DeepCopyInto 

func (in *SchemaSettingsInitParameters) DeepCopyInto(out *SchemaSettingsInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SchemaSettingsObservation 

type SchemaSettingsObservation 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"`
}

func (*SchemaSettingsObservation) DeepCopy 

func (in *SchemaSettingsObservation) DeepCopy() *SchemaSettingsObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsObservation.

func (*SchemaSettingsObservation) DeepCopyInto 

func (in *SchemaSettingsObservation) DeepCopyInto(out *SchemaSettingsObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SchemaSettingsParameters 

type SchemaSettingsParameters struct {

	// The encoding of messages validated against schema.
	// Default value is ENCODING_UNSPECIFIED.
	// Possible values are: ENCODING_UNSPECIFIED, JSON, BINARY.
	// +kubebuilder:validation:Optional
	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.
	// +kubebuilder:validation:Optional
	Schema *string `json:"schema" tf:"schema,omitempty"`
}

func (*SchemaSettingsParameters) DeepCopy 

func (in *SchemaSettingsParameters) DeepCopy() *SchemaSettingsParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaSettingsParameters.

func (*SchemaSettingsParameters) DeepCopyInto 

func (in *SchemaSettingsParameters) DeepCopyInto(out *SchemaSettingsParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Subscription 

type Subscription struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionSpec   `json:"spec"`
	Status            SubscriptionStatus `json:"status,omitempty"`
}

Subscription is the Schema for the Subscriptions API. A named resource representing the stream of messages from a single, specific topic, to be delivered to the subscribing application. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*Subscription) DeepCopy 

func (in *Subscription) DeepCopy() *Subscription

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Subscription.

func (*Subscription) DeepCopyInto 

func (in *Subscription) DeepCopyInto(out *Subscription)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Subscription) DeepCopyObject 

func (in *Subscription) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Subscription) GetCondition 

func (mg *Subscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Subscription.

func (*Subscription) GetConnectionDetailsMapping 

func (tr *Subscription) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Subscription

func (*Subscription) GetDeletionPolicy 

func (mg *Subscription) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Subscription.

func (*Subscription) GetID 

func (tr *Subscription) GetID() string

GetID returns ID of underlying Terraform resource of this Subscription

func (*Subscription) GetInitParameters 

func (tr *Subscription) GetInitParameters() (map[string]any, error)

GetInitParameters of this Subscription

func (*Subscription) GetManagementPolicies 

func (mg *Subscription) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Subscription.

func (*Subscription) GetMergedParameters 

func (tr *Subscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Subscription

func (*Subscription) GetObservation 

func (tr *Subscription) GetObservation() (map[string]any, error)

GetObservation of this Subscription

func (*Subscription) GetParameters 

func (tr *Subscription) GetParameters() (map[string]any, error)

GetParameters of this Subscription

func (*Subscription) GetProviderConfigReference 

func (mg *Subscription) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Subscription.

func (*Subscription) GetPublishConnectionDetailsTo 

func (mg *Subscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Subscription.

func (*Subscription) GetTerraformResourceType 

func (mg *Subscription) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Subscription

func (*Subscription) GetTerraformSchemaVersion 

func (tr *Subscription) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Subscription) GetWriteConnectionSecretToReference 

func (mg *Subscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Subscription.

func (*Subscription) Hub 

func (tr *Subscription) Hub()

Hub marks this type as a conversion hub.

func (*Subscription) LateInitialize 

func (tr *Subscription) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Subscription using its observed tfState. returns True if there are any spec changes for the resource.

func (*Subscription) ResolveReferences 

func (mg *Subscription) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Subscription.

func (*Subscription) SetConditions 

func (mg *Subscription) SetConditions(c ...xpv1.Condition)

SetConditions of this Subscription.

func (*Subscription) SetDeletionPolicy 

func (mg *Subscription) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Subscription.

func (*Subscription) SetManagementPolicies 

func (mg *Subscription) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Subscription.

func (*Subscription) SetObservation 

func (tr *Subscription) SetObservation(obs map[string]any) error

SetObservation for this Subscription

func (*Subscription) SetParameters 

func (tr *Subscription) SetParameters(params map[string]any) error

SetParameters for this Subscription

func (*Subscription) SetProviderConfigReference 

func (mg *Subscription) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Subscription.

func (*Subscription) SetPublishConnectionDetailsTo 

func (mg *Subscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Subscription.

func (*Subscription) SetWriteConnectionSecretToReference 

func (mg *Subscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Subscription.

type SubscriptionIAMMember 

type SubscriptionIAMMember 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.member) || (has(self.initProvider) && has(self.initProvider.member))",message="spec.forProvider.member is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.role) || (has(self.initProvider) && has(self.initProvider.role))",message="spec.forProvider.role is a required parameter"
	Spec   SubscriptionIAMMemberSpec   `json:"spec"`
	Status SubscriptionIAMMemberStatus `json:"status,omitempty"`
}

SubscriptionIAMMember is the Schema for the SubscriptionIAMMembers API. <no value> +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*SubscriptionIAMMember) DeepCopy 

func (in *SubscriptionIAMMember) DeepCopy() *SubscriptionIAMMember

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMember.

func (*SubscriptionIAMMember) DeepCopyInto 

func (in *SubscriptionIAMMember) DeepCopyInto(out *SubscriptionIAMMember)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SubscriptionIAMMember) DeepCopyObject 

func (in *SubscriptionIAMMember) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SubscriptionIAMMember) GetCondition 

func (mg *SubscriptionIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetConnectionDetailsMapping 

func (tr *SubscriptionIAMMember) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetDeletionPolicy 

func (mg *SubscriptionIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetID 

func (tr *SubscriptionIAMMember) GetID() string

GetID returns ID of underlying Terraform resource of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetInitParameters 

func (tr *SubscriptionIAMMember) GetInitParameters() (map[string]any, error)

GetInitParameters of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetManagementPolicies 

func (mg *SubscriptionIAMMember) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetMergedParameters 

func (tr *SubscriptionIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetObservation 

func (tr *SubscriptionIAMMember) GetObservation() (map[string]any, error)

GetObservation of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetParameters 

func (tr *SubscriptionIAMMember) GetParameters() (map[string]any, error)

GetParameters of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetProviderConfigReference 

func (mg *SubscriptionIAMMember) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetPublishConnectionDetailsTo 

func (mg *SubscriptionIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetTerraformResourceType 

func (mg *SubscriptionIAMMember) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetTerraformSchemaVersion 

func (tr *SubscriptionIAMMember) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*SubscriptionIAMMember) GetWriteConnectionSecretToReference 

func (mg *SubscriptionIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) Hub 

func (tr *SubscriptionIAMMember) Hub()

Hub marks this type as a conversion hub.

func (*SubscriptionIAMMember) LateInitialize 

func (tr *SubscriptionIAMMember) LateInitialize(attrs []byte) (bool, error)

LateInitialize this SubscriptionIAMMember using its observed tfState. returns True if there are any spec changes for the resource.

func (*SubscriptionIAMMember) ResolveReferences 

func (mg *SubscriptionIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetConditions 

func (mg *SubscriptionIAMMember) SetConditions(c ...xpv1.Condition)

SetConditions of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetDeletionPolicy 

func (mg *SubscriptionIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetManagementPolicies 

func (mg *SubscriptionIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetObservation 

func (tr *SubscriptionIAMMember) SetObservation(obs map[string]any) error

SetObservation for this SubscriptionIAMMember

func (*SubscriptionIAMMember) SetParameters 

func (tr *SubscriptionIAMMember) SetParameters(params map[string]any) error

SetParameters for this SubscriptionIAMMember

func (*SubscriptionIAMMember) SetProviderConfigReference 

func (mg *SubscriptionIAMMember) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetPublishConnectionDetailsTo 

func (mg *SubscriptionIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) SetWriteConnectionSecretToReference 

func (mg *SubscriptionIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this SubscriptionIAMMember.

type SubscriptionIAMMemberInitParameters 

type SubscriptionIAMMemberInitParameters struct {
	Condition *ConditionInitParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Subscription
	Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"`

	// Reference to a Subscription in pubsub to populate subscription.
	// +kubebuilder:validation:Optional
	SubscriptionRef *v1.Reference `json:"subscriptionRef,omitempty" tf:"-"`

	// Selector for a Subscription in pubsub to populate subscription.
	// +kubebuilder:validation:Optional
	SubscriptionSelector *v1.Selector `json:"subscriptionSelector,omitempty" tf:"-"`
}

func (*SubscriptionIAMMemberInitParameters) DeepCopy 

func (in *SubscriptionIAMMemberInitParameters) DeepCopy() *SubscriptionIAMMemberInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberInitParameters.

func (*SubscriptionIAMMemberInitParameters) DeepCopyInto 

func (in *SubscriptionIAMMemberInitParameters) DeepCopyInto(out *SubscriptionIAMMemberInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionIAMMemberList 

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

SubscriptionIAMMemberList contains a list of SubscriptionIAMMembers

func (*SubscriptionIAMMemberList) DeepCopy 

func (in *SubscriptionIAMMemberList) DeepCopy() *SubscriptionIAMMemberList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberList.

func (*SubscriptionIAMMemberList) DeepCopyInto 

func (in *SubscriptionIAMMemberList) DeepCopyInto(out *SubscriptionIAMMemberList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SubscriptionIAMMemberList) DeepCopyObject 

func (in *SubscriptionIAMMemberList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SubscriptionIAMMemberList) GetItems 

func (l *SubscriptionIAMMemberList) GetItems() []resource.Managed

GetItems of this SubscriptionIAMMemberList.

type SubscriptionIAMMemberObservation 

type SubscriptionIAMMemberObservation struct {
	Condition *ConditionObservation `json:"condition,omitempty" tf:"condition,omitempty"`

	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"`
}

func (*SubscriptionIAMMemberObservation) DeepCopy 

func (in *SubscriptionIAMMemberObservation) DeepCopy() *SubscriptionIAMMemberObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberObservation.

func (*SubscriptionIAMMemberObservation) DeepCopyInto 

func (in *SubscriptionIAMMemberObservation) DeepCopyInto(out *SubscriptionIAMMemberObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionIAMMemberParameters 

type SubscriptionIAMMemberParameters struct {

	// +kubebuilder:validation:Optional
	Condition *ConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Optional
	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Subscription
	// +kubebuilder:validation:Optional
	Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"`

	// Reference to a Subscription in pubsub to populate subscription.
	// +kubebuilder:validation:Optional
	SubscriptionRef *v1.Reference `json:"subscriptionRef,omitempty" tf:"-"`

	// Selector for a Subscription in pubsub to populate subscription.
	// +kubebuilder:validation:Optional
	SubscriptionSelector *v1.Selector `json:"subscriptionSelector,omitempty" tf:"-"`
}

func (*SubscriptionIAMMemberParameters) DeepCopy 

func (in *SubscriptionIAMMemberParameters) DeepCopy() *SubscriptionIAMMemberParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberParameters.

func (*SubscriptionIAMMemberParameters) DeepCopyInto 

func (in *SubscriptionIAMMemberParameters) DeepCopyInto(out *SubscriptionIAMMemberParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionIAMMemberSpec 

type SubscriptionIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SubscriptionIAMMemberParameters `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 SubscriptionIAMMemberInitParameters `json:"initProvider,omitempty"`
}

SubscriptionIAMMemberSpec defines the desired state of SubscriptionIAMMember

func (*SubscriptionIAMMemberSpec) DeepCopy 

func (in *SubscriptionIAMMemberSpec) DeepCopy() *SubscriptionIAMMemberSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberSpec.

func (*SubscriptionIAMMemberSpec) DeepCopyInto 

func (in *SubscriptionIAMMemberSpec) DeepCopyInto(out *SubscriptionIAMMemberSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionIAMMemberStatus 

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

SubscriptionIAMMemberStatus defines the observed state of SubscriptionIAMMember.

func (*SubscriptionIAMMemberStatus) DeepCopy 

func (in *SubscriptionIAMMemberStatus) DeepCopy() *SubscriptionIAMMemberStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionIAMMemberStatus.

func (*SubscriptionIAMMemberStatus) DeepCopyInto 

func (in *SubscriptionIAMMemberStatus) DeepCopyInto(out *SubscriptionIAMMemberStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionInitParameters 

type SubscriptionInitParameters struct {

	// 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.
	AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"`

	// If delivery to BigQuery is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	BigqueryConfig *BigqueryConfigInitParameters `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"`

	// If delivery to Cloud Storage is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	CloudStorageConfig *CloudStorageConfigInitParameters `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"`

	// A policy that specifies the conditions for dead lettering messages in
	// this subscription. If dead_letter_policy is not set, dead lettering
	// is disabled.
	// The Cloud Pub/Sub service account associated with this subscription's
	// parent project (i.e.,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// permission to Acknowledge() messages on this subscription.
	// Structure is documented below.
	DeadLetterPolicy *DeadLetterPolicyInitParameters `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"`

	// If true, Pub/Sub provides the following guarantees for the delivery
	// of a message with a given value of messageId on this Subscriptions':
	EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"`

	// 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.
	EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"`

	// A policy that specifies the conditions for this subscription's expiration.
	// A subscription is considered active as long as any connected subscriber
	// is successfully consuming messages from the subscription or is issuing
	// operations on the subscription. If expirationPolicy is not set, a default
	// policy with ttl of 31 days will be used.  If it is set but ttl is "", the
	// resource never expires.  The minimum allowed value for expirationPolicy.ttl
	// is 1 day.
	// Structure is documented below.
	ExpirationPolicy *ExpirationPolicyInitParameters `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"`

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

	// A set of key/value label pairs to assign to this Subscription.
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// 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 7 days ("604800s") or less than 10 minutes ("600s").
	// A duration in seconds with up to nine fractional digits, terminated
	// by 's'. Example: "600.5s".
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,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"`

	// If push delivery is used with this subscription, this field is used to
	// configure it. An empty pushConfig signifies that the subscriber will
	// pull and ack messages using API methods.
	// Structure is documented below.
	PushConfig *PushConfigInitParameters `json:"pushConfig,omitempty" tf:"push_config,omitempty"`

	// 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.
	RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"`

	// A policy that specifies how Pub/Sub retries message delivery for this subscription.
	// If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers.
	// RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message
	// Structure is documented below.
	RetryPolicy *RetryPolicyInitParameters `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"`

	// 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*SubscriptionInitParameters) DeepCopy 

func (in *SubscriptionInitParameters) DeepCopy() *SubscriptionInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionInitParameters.

func (*SubscriptionInitParameters) DeepCopyInto 

func (in *SubscriptionInitParameters) DeepCopyInto(out *SubscriptionInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionList 

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

SubscriptionList contains a list of Subscriptions

func (*SubscriptionList) DeepCopy 

func (in *SubscriptionList) DeepCopy() *SubscriptionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionList.

func (*SubscriptionList) DeepCopyInto 

func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SubscriptionList) DeepCopyObject 

func (in *SubscriptionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SubscriptionList) GetItems 

func (l *SubscriptionList) GetItems() []resource.Managed

GetItems of this SubscriptionList.

type SubscriptionObservation 

type SubscriptionObservation struct {

	// 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.
	AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"`

	// If delivery to BigQuery is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	BigqueryConfig *BigqueryConfigObservation `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"`

	// If delivery to Cloud Storage is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	CloudStorageConfig *CloudStorageConfigObservation `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"`

	// A policy that specifies the conditions for dead lettering messages in
	// this subscription. If dead_letter_policy is not set, dead lettering
	// is disabled.
	// The Cloud Pub/Sub service account associated with this subscription's
	// parent project (i.e.,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// permission to Acknowledge() messages on this subscription.
	// Structure is documented below.
	DeadLetterPolicy *DeadLetterPolicyObservation `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"`

	// for all of the labels present on the resource.
	// +mapType=granular
	EffectiveLabels map[string]*string `json:"effectiveLabels,omitempty" tf:"effective_labels,omitempty"`

	// If true, Pub/Sub provides the following guarantees for the delivery
	// of a message with a given value of messageId on this Subscriptions':
	EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"`

	// 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.
	EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"`

	// A policy that specifies the conditions for this subscription's expiration.
	// A subscription is considered active as long as any connected subscriber
	// is successfully consuming messages from the subscription or is issuing
	// operations on the subscription. If expirationPolicy is not set, a default
	// policy with ttl of 31 days will be used.  If it is set but ttl is "", the
	// resource never expires.  The minimum allowed value for expirationPolicy.ttl
	// is 1 day.
	// Structure is documented below.
	ExpirationPolicy *ExpirationPolicyObservation `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"`

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

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

	// A set of key/value label pairs to assign to this Subscription.
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// 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 7 days ("604800s") or less than 10 minutes ("600s").
	// A duration in seconds with up to nine fractional digits, terminated
	// by 's'. Example: "600.5s".
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,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"`

	// If push delivery is used with this subscription, this field is used to
	// configure it. An empty pushConfig signifies that the subscriber will
	// pull and ack messages using API methods.
	// Structure is documented below.
	PushConfig *PushConfigObservation `json:"pushConfig,omitempty" tf:"push_config,omitempty"`

	// 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.
	RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"`

	// A policy that specifies how Pub/Sub retries message delivery for this subscription.
	// If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers.
	// RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message
	// Structure is documented below.
	RetryPolicy *RetryPolicyObservation `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"`

	// The combination of labels configured directly on the resource
	// and default labels configured on the provider.
	// +mapType=granular
	TerraformLabels map[string]*string `json:"terraformLabels,omitempty" tf:"terraform_labels,omitempty"`

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

func (*SubscriptionObservation) DeepCopy 

func (in *SubscriptionObservation) DeepCopy() *SubscriptionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionObservation.

func (*SubscriptionObservation) DeepCopyInto 

func (in *SubscriptionObservation) DeepCopyInto(out *SubscriptionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionParameters 

type SubscriptionParameters struct {

	// 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.
	// +kubebuilder:validation:Optional
	AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"`

	// If delivery to BigQuery is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	BigqueryConfig *BigqueryConfigParameters `json:"bigqueryConfig,omitempty" tf:"bigquery_config,omitempty"`

	// If delivery to Cloud Storage is used with this subscription, this field is used to configure it.
	// Either pushConfig, bigQueryConfig or cloudStorageConfig can be set, but not combined.
	// If all three are empty, then the subscriber will pull and ack messages using API methods.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	CloudStorageConfig *CloudStorageConfigParameters `json:"cloudStorageConfig,omitempty" tf:"cloud_storage_config,omitempty"`

	// A policy that specifies the conditions for dead lettering messages in
	// this subscription. If dead_letter_policy is not set, dead lettering
	// is disabled.
	// The Cloud Pub/Sub service account associated with this subscription's
	// parent project (i.e.,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// permission to Acknowledge() messages on this subscription.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	DeadLetterPolicy *DeadLetterPolicyParameters `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy,omitempty"`

	// If true, Pub/Sub provides the following guarantees for the delivery
	// of a message with a given value of messageId on this Subscriptions':
	// +kubebuilder:validation:Optional
	EnableExactlyOnceDelivery *bool `json:"enableExactlyOnceDelivery,omitempty" tf:"enable_exactly_once_delivery,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering,omitempty"`

	// A policy that specifies the conditions for this subscription's expiration.
	// A subscription is considered active as long as any connected subscriber
	// is successfully consuming messages from the subscription or is issuing
	// operations on the subscription. If expirationPolicy is not set, a default
	// policy with ttl of 31 days will be used.  If it is set but ttl is "", the
	// resource never expires.  The minimum allowed value for expirationPolicy.ttl
	// is 1 day.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	ExpirationPolicy *ExpirationPolicyParameters `json:"expirationPolicy,omitempty" tf:"expiration_policy,omitempty"`

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

	// A set of key/value label pairs to assign to this Subscription.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// 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 7 days ("604800s") or less than 10 minutes ("600s").
	// A duration in seconds with up to nine fractional digits, terminated
	// by 's'. Example: "600.5s".
	// +kubebuilder:validation:Optional
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,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"`

	// If push delivery is used with this subscription, this field is used to
	// configure it. An empty pushConfig signifies that the subscriber will
	// pull and ack messages using API methods.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	PushConfig *PushConfigParameters `json:"pushConfig,omitempty" tf:"push_config,omitempty"`

	// 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.
	// +kubebuilder:validation:Optional
	RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages,omitempty"`

	// A policy that specifies how Pub/Sub retries message delivery for this subscription.
	// If not set, the default retry policy is applied. This generally implies that messages will be retried as soon as possible for healthy subscribers.
	// RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	RetryPolicy *RetryPolicyParameters `json:"retryPolicy,omitempty" tf:"retry_policy,omitempty"`

	// 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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*SubscriptionParameters) DeepCopy 

func (in *SubscriptionParameters) DeepCopy() *SubscriptionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionParameters.

func (*SubscriptionParameters) DeepCopyInto 

func (in *SubscriptionParameters) DeepCopyInto(out *SubscriptionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionSpec 

type SubscriptionSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SubscriptionParameters `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 SubscriptionInitParameters `json:"initProvider,omitempty"`
}

SubscriptionSpec defines the desired state of Subscription

func (*SubscriptionSpec) DeepCopy 

func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionSpec.

func (*SubscriptionSpec) DeepCopyInto 

func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SubscriptionStatus 

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

SubscriptionStatus defines the observed state of Subscription.

func (*SubscriptionStatus) DeepCopy 

func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionStatus.

func (*SubscriptionStatus) DeepCopyInto 

func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Topic 

type Topic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicSpec   `json:"spec"`
	Status            TopicStatus `json:"status,omitempty"`
}

Topic is the Schema for the Topics API. A named resource to which messages are sent by publishers. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topic.

func (*Topic) DeepCopyInto 

func (in *Topic) DeepCopyInto(out *Topic)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Topic) DeepCopyObject 

func (in *Topic) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Topic) GetCondition 

func (mg *Topic) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Topic.

func (*Topic) GetConnectionDetailsMapping 

func (tr *Topic) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Topic

func (*Topic) GetDeletionPolicy 

func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Topic.

func (*Topic) GetID 

func (tr *Topic) GetID() string

GetID returns ID of underlying Terraform resource of this Topic

func (*Topic) GetInitParameters 

func (tr *Topic) GetInitParameters() (map[string]any, error)

GetInitParameters of this Topic

func (*Topic) GetManagementPolicies 

func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Topic.

func (*Topic) GetMergedParameters 

func (tr *Topic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Topic

func (*Topic) GetObservation 

func (tr *Topic) GetObservation() (map[string]any, error)

GetObservation of this Topic

func (*Topic) GetParameters 

func (tr *Topic) GetParameters() (map[string]any, error)

GetParameters of this Topic

func (*Topic) GetProviderConfigReference 

func (mg *Topic) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Topic.

func (*Topic) GetPublishConnectionDetailsTo 

func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Topic.

func (*Topic) GetTerraformResourceType 

func (mg *Topic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Topic

func (*Topic) GetTerraformSchemaVersion 

func (tr *Topic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Topic) GetWriteConnectionSecretToReference 

func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Topic.

func (*Topic) Hub 

func (tr *Topic) Hub()

Hub marks this type as a conversion hub.

func (*Topic) LateInitialize 

func (tr *Topic) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Topic using its observed tfState. returns True if there are any spec changes for the resource.

func (*Topic) ResolveReferences 

func (mg *Topic) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Topic.

func (*Topic) SetConditions 

func (mg *Topic) SetConditions(c ...xpv1.Condition)

SetConditions of this Topic.

func (*Topic) SetDeletionPolicy 

func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Topic.

func (*Topic) SetManagementPolicies 

func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Topic.

func (*Topic) SetObservation 

func (tr *Topic) SetObservation(obs map[string]any) error

SetObservation for this Topic

func (*Topic) SetParameters 

func (tr *Topic) SetParameters(params map[string]any) error

SetParameters for this Topic

func (*Topic) SetProviderConfigReference 

func (mg *Topic) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Topic.

func (*Topic) SetPublishConnectionDetailsTo 

func (mg *Topic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Topic.

func (*Topic) SetWriteConnectionSecretToReference 

func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Topic.

type TopicIAMMember 

type TopicIAMMember 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.member) || (has(self.initProvider) && has(self.initProvider.member))",message="spec.forProvider.member is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.role) || (has(self.initProvider) && has(self.initProvider.role))",message="spec.forProvider.role is a required parameter"
	Spec   TopicIAMMemberSpec   `json:"spec"`
	Status TopicIAMMemberStatus `json:"status,omitempty"`
}

TopicIAMMember is the Schema for the TopicIAMMembers API. <no value> +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*TopicIAMMember) DeepCopy 

func (in *TopicIAMMember) DeepCopy() *TopicIAMMember

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMember.

func (*TopicIAMMember) DeepCopyInto 

func (in *TopicIAMMember) DeepCopyInto(out *TopicIAMMember)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicIAMMember) DeepCopyObject 

func (in *TopicIAMMember) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TopicIAMMember) GetCondition 

func (mg *TopicIAMMember) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this TopicIAMMember.

func (*TopicIAMMember) GetConnectionDetailsMapping 

func (tr *TopicIAMMember) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this TopicIAMMember

func (*TopicIAMMember) GetDeletionPolicy 

func (mg *TopicIAMMember) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this TopicIAMMember.

func (*TopicIAMMember) GetID 

func (tr *TopicIAMMember) GetID() string

GetID returns ID of underlying Terraform resource of this TopicIAMMember

func (*TopicIAMMember) GetInitParameters 

func (tr *TopicIAMMember) GetInitParameters() (map[string]any, error)

GetInitParameters of this TopicIAMMember

func (*TopicIAMMember) GetManagementPolicies 

func (mg *TopicIAMMember) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this TopicIAMMember.

func (*TopicIAMMember) GetMergedParameters 

func (tr *TopicIAMMember) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this TopicIAMMember

func (*TopicIAMMember) GetObservation 

func (tr *TopicIAMMember) GetObservation() (map[string]any, error)

GetObservation of this TopicIAMMember

func (*TopicIAMMember) GetParameters 

func (tr *TopicIAMMember) GetParameters() (map[string]any, error)

GetParameters of this TopicIAMMember

func (*TopicIAMMember) GetProviderConfigReference 

func (mg *TopicIAMMember) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this TopicIAMMember.

func (*TopicIAMMember) GetPublishConnectionDetailsTo 

func (mg *TopicIAMMember) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this TopicIAMMember.

func (*TopicIAMMember) GetTerraformResourceType 

func (mg *TopicIAMMember) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this TopicIAMMember

func (*TopicIAMMember) GetTerraformSchemaVersion 

func (tr *TopicIAMMember) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*TopicIAMMember) GetWriteConnectionSecretToReference 

func (mg *TopicIAMMember) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this TopicIAMMember.

func (*TopicIAMMember) Hub 

func (tr *TopicIAMMember) Hub()

Hub marks this type as a conversion hub.

func (*TopicIAMMember) LateInitialize 

func (tr *TopicIAMMember) LateInitialize(attrs []byte) (bool, error)

LateInitialize this TopicIAMMember using its observed tfState. returns True if there are any spec changes for the resource.

func (*TopicIAMMember) ResolveReferences 

func (mg *TopicIAMMember) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this TopicIAMMember.

func (*TopicIAMMember) SetConditions 

func (mg *TopicIAMMember) SetConditions(c ...xpv1.Condition)

SetConditions of this TopicIAMMember.

func (*TopicIAMMember) SetDeletionPolicy 

func (mg *TopicIAMMember) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this TopicIAMMember.

func (*TopicIAMMember) SetManagementPolicies 

func (mg *TopicIAMMember) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this TopicIAMMember.

func (*TopicIAMMember) SetObservation 

func (tr *TopicIAMMember) SetObservation(obs map[string]any) error

SetObservation for this TopicIAMMember

func (*TopicIAMMember) SetParameters 

func (tr *TopicIAMMember) SetParameters(params map[string]any) error

SetParameters for this TopicIAMMember

func (*TopicIAMMember) SetProviderConfigReference 

func (mg *TopicIAMMember) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this TopicIAMMember.

func (*TopicIAMMember) SetPublishConnectionDetailsTo 

func (mg *TopicIAMMember) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this TopicIAMMember.

func (*TopicIAMMember) SetWriteConnectionSecretToReference 

func (mg *TopicIAMMember) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this TopicIAMMember.

type TopicIAMMemberConditionInitParameters 

type TopicIAMMemberConditionInitParameters 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"`
}

func (*TopicIAMMemberConditionInitParameters) DeepCopy 

func (in *TopicIAMMemberConditionInitParameters) DeepCopy() *TopicIAMMemberConditionInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionInitParameters.

func (*TopicIAMMemberConditionInitParameters) DeepCopyInto 

func (in *TopicIAMMemberConditionInitParameters) DeepCopyInto(out *TopicIAMMemberConditionInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberConditionObservation 

type TopicIAMMemberConditionObservation 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"`
}

func (*TopicIAMMemberConditionObservation) DeepCopy 

func (in *TopicIAMMemberConditionObservation) DeepCopy() *TopicIAMMemberConditionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionObservation.

func (*TopicIAMMemberConditionObservation) DeepCopyInto 

func (in *TopicIAMMemberConditionObservation) DeepCopyInto(out *TopicIAMMemberConditionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberConditionParameters 

type TopicIAMMemberConditionParameters 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"`
}

func (*TopicIAMMemberConditionParameters) DeepCopy 

func (in *TopicIAMMemberConditionParameters) DeepCopy() *TopicIAMMemberConditionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberConditionParameters.

func (*TopicIAMMemberConditionParameters) DeepCopyInto 

func (in *TopicIAMMemberConditionParameters) DeepCopyInto(out *TopicIAMMemberConditionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberInitParameters 

type TopicIAMMemberInitParameters struct {
	Condition *TopicIAMMemberConditionInitParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*TopicIAMMemberInitParameters) DeepCopy 

func (in *TopicIAMMemberInitParameters) DeepCopy() *TopicIAMMemberInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberInitParameters.

func (*TopicIAMMemberInitParameters) DeepCopyInto 

func (in *TopicIAMMemberInitParameters) DeepCopyInto(out *TopicIAMMemberInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberList 

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

TopicIAMMemberList contains a list of TopicIAMMembers

func (*TopicIAMMemberList) DeepCopy 

func (in *TopicIAMMemberList) DeepCopy() *TopicIAMMemberList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberList.

func (*TopicIAMMemberList) DeepCopyInto 

func (in *TopicIAMMemberList) DeepCopyInto(out *TopicIAMMemberList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicIAMMemberList) DeepCopyObject 

func (in *TopicIAMMemberList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TopicIAMMemberList) GetItems 

func (l *TopicIAMMemberList) GetItems() []resource.Managed

GetItems of this TopicIAMMemberList.

type TopicIAMMemberObservation 

type TopicIAMMemberObservation struct {
	Condition *TopicIAMMemberConditionObservation `json:"condition,omitempty" tf:"condition,omitempty"`

	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`
}

func (*TopicIAMMemberObservation) DeepCopy 

func (in *TopicIAMMemberObservation) DeepCopy() *TopicIAMMemberObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberObservation.

func (*TopicIAMMemberObservation) DeepCopyInto 

func (in *TopicIAMMemberObservation) DeepCopyInto(out *TopicIAMMemberObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberParameters 

type TopicIAMMemberParameters struct {

	// +kubebuilder:validation:Optional
	Condition *TopicIAMMemberConditionParameters `json:"condition,omitempty" tf:"condition,omitempty"`

	// +kubebuilder:validation:Optional
	Member *string `json:"member,omitempty" tf:"member,omitempty"`

	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// +kubebuilder:validation:Optional
	Role *string `json:"role,omitempty" tf:"role,omitempty"`

	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/v1beta2.Topic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*TopicIAMMemberParameters) DeepCopy 

func (in *TopicIAMMemberParameters) DeepCopy() *TopicIAMMemberParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberParameters.

func (*TopicIAMMemberParameters) DeepCopyInto 

func (in *TopicIAMMemberParameters) DeepCopyInto(out *TopicIAMMemberParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberSpec 

type TopicIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     TopicIAMMemberParameters `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 TopicIAMMemberInitParameters `json:"initProvider,omitempty"`
}

TopicIAMMemberSpec defines the desired state of TopicIAMMember

func (*TopicIAMMemberSpec) DeepCopy 

func (in *TopicIAMMemberSpec) DeepCopy() *TopicIAMMemberSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberSpec.

func (*TopicIAMMemberSpec) DeepCopyInto 

func (in *TopicIAMMemberSpec) DeepCopyInto(out *TopicIAMMemberSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicIAMMemberStatus 

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

TopicIAMMemberStatus defines the observed state of TopicIAMMember.

func (*TopicIAMMemberStatus) DeepCopy 

func (in *TopicIAMMemberStatus) DeepCopy() *TopicIAMMemberStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicIAMMemberStatus.

func (*TopicIAMMemberStatus) DeepCopyInto 

func (in *TopicIAMMemberStatus) DeepCopyInto(out *TopicIAMMemberStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicInitParameters 

type TopicInitParameters struct {

	// Settings for ingestion from a data source into this topic.
	// Structure is documented below.
	IngestionDataSourceSettings *IngestionDataSourceSettingsInitParameters `json:"ingestionDataSourceSettings,omitempty" tf:"ingestion_data_source_settings,omitempty"`

	// The resource name of the Cloud KMS CryptoKey to be used to protect access
	// to messages published on this topic. Your project's PubSub service account
	// (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature.
	// The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/*
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/kms/v1beta2.CryptoKey
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"`

	// Reference to a CryptoKey in kms to populate kmsKeyName.
	// +kubebuilder:validation:Optional
	KMSKeyNameRef *v1.Reference `json:"kmsKeyNameRef,omitempty" tf:"-"`

	// Selector for a CryptoKey in kms to populate kmsKeyName.
	// +kubebuilder:validation:Optional
	KMSKeyNameSelector *v1.Selector `json:"kmsKeyNameSelector,omitempty" tf:"-"`

	// A set of key/value label pairs to assign to this Topic.
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// Indicates the minimum duration to retain a message after it is published
	// to the topic. If this field is set, messages published to the topic in
	// the last messageRetentionDuration are always available to subscribers.
	// For instance, it allows any attached subscription to seek to a timestamp
	// that is up to messageRetentionDuration in the past. If this field is not
	// set, message retention is controlled by settings on individual subscriptions.
	// The rotation period has the format of a decimal number, followed by the
	// letter s (seconds). Cannot be more than 31 days or less than 10 minutes.
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"`

	// Policy constraining the set of Google Cloud Platform regions where
	// messages published to the topic may be stored. If not present, then no
	// constraints are in effect.
	// Structure is documented below.
	MessageStoragePolicy *MessageStoragePolicyInitParameters `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,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"`

	// Settings for validating messages published against a schema.
	// Structure is documented below.
	SchemaSettings *SchemaSettingsInitParameters `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"`
}

func (*TopicInitParameters) DeepCopy 

func (in *TopicInitParameters) DeepCopy() *TopicInitParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicInitParameters.

func (*TopicInitParameters) DeepCopyInto 

func (in *TopicInitParameters) DeepCopyInto(out *TopicInitParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicList 

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

TopicList contains a list of Topics

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicList.

func (*TopicList) DeepCopyInto 

func (in *TopicList) DeepCopyInto(out *TopicList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TopicList) DeepCopyObject 

func (in *TopicList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TopicList) GetItems 

func (l *TopicList) GetItems() []resource.Managed

GetItems of this TopicList.

type TopicObservation 

type TopicObservation struct {

	// for all of the labels present on the resource.
	// +mapType=granular
	EffectiveLabels map[string]*string `json:"effectiveLabels,omitempty" tf:"effective_labels,omitempty"`

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

	// Settings for ingestion from a data source into this topic.
	// Structure is documented below.
	IngestionDataSourceSettings *IngestionDataSourceSettingsObservation `json:"ingestionDataSourceSettings,omitempty" tf:"ingestion_data_source_settings,omitempty"`

	// The resource name of the Cloud KMS CryptoKey to be used to protect access
	// to messages published on this topic. Your project's PubSub service account
	// (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature.
	// The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/*
	KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"`

	// A set of key/value label pairs to assign to this Topic.
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// Indicates the minimum duration to retain a message after it is published
	// to the topic. If this field is set, messages published to the topic in
	// the last messageRetentionDuration are always available to subscribers.
	// For instance, it allows any attached subscription to seek to a timestamp
	// that is up to messageRetentionDuration in the past. If this field is not
	// set, message retention is controlled by settings on individual subscriptions.
	// The rotation period has the format of a decimal number, followed by the
	// letter s (seconds). Cannot be more than 31 days or less than 10 minutes.
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"`

	// Policy constraining the set of Google Cloud Platform regions where
	// messages published to the topic may be stored. If not present, then no
	// constraints are in effect.
	// Structure is documented below.
	MessageStoragePolicy *MessageStoragePolicyObservation `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,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"`

	// Settings for validating messages published against a schema.
	// Structure is documented below.
	SchemaSettings *SchemaSettingsObservation `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"`

	// The combination of labels configured directly on the resource
	// and default labels configured on the provider.
	// +mapType=granular
	TerraformLabels map[string]*string `json:"terraformLabels,omitempty" tf:"terraform_labels,omitempty"`
}

func (*TopicObservation) DeepCopy 

func (in *TopicObservation) DeepCopy() *TopicObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicObservation.

func (*TopicObservation) DeepCopyInto 

func (in *TopicObservation) DeepCopyInto(out *TopicObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicParameters 

type TopicParameters struct {

	// Settings for ingestion from a data source into this topic.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	IngestionDataSourceSettings *IngestionDataSourceSettingsParameters `json:"ingestionDataSourceSettings,omitempty" tf:"ingestion_data_source_settings,omitempty"`

	// The resource name of the Cloud KMS CryptoKey to be used to protect access
	// to messages published on this topic. Your project's PubSub service account
	// (service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// roles/cloudkms.cryptoKeyEncrypterDecrypter to use this feature.
	// The expected format is projects/*/locations/*/keyRings/*/cryptoKeys/*
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/kms/v1beta2.CryptoKey
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	// +kubebuilder:validation:Optional
	KMSKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name,omitempty"`

	// Reference to a CryptoKey in kms to populate kmsKeyName.
	// +kubebuilder:validation:Optional
	KMSKeyNameRef *v1.Reference `json:"kmsKeyNameRef,omitempty" tf:"-"`

	// Selector for a CryptoKey in kms to populate kmsKeyName.
	// +kubebuilder:validation:Optional
	KMSKeyNameSelector *v1.Selector `json:"kmsKeyNameSelector,omitempty" tf:"-"`

	// A set of key/value label pairs to assign to this Topic.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Labels map[string]*string `json:"labels,omitempty" tf:"labels,omitempty"`

	// Indicates the minimum duration to retain a message after it is published
	// to the topic. If this field is set, messages published to the topic in
	// the last messageRetentionDuration are always available to subscribers.
	// For instance, it allows any attached subscription to seek to a timestamp
	// that is up to messageRetentionDuration in the past. If this field is not
	// set, message retention is controlled by settings on individual subscriptions.
	// The rotation period has the format of a decimal number, followed by the
	// letter s (seconds). Cannot be more than 31 days or less than 10 minutes.
	// +kubebuilder:validation:Optional
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration,omitempty"`

	// Policy constraining the set of Google Cloud Platform regions where
	// messages published to the topic may be stored. If not present, then no
	// constraints are in effect.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	MessageStoragePolicy *MessageStoragePolicyParameters `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy,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"`

	// Settings for validating messages published against a schema.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	SchemaSettings *SchemaSettingsParameters `json:"schemaSettings,omitempty" tf:"schema_settings,omitempty"`
}

func (*TopicParameters) DeepCopy 

func (in *TopicParameters) DeepCopy() *TopicParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicParameters.

func (*TopicParameters) DeepCopyInto 

func (in *TopicParameters) DeepCopyInto(out *TopicParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicSpec 

type TopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     TopicParameters `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 TopicInitParameters `json:"initProvider,omitempty"`
}

TopicSpec defines the desired state of Topic

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicSpec.

func (*TopicSpec) DeepCopyInto 

func (in *TopicSpec) DeepCopyInto(out *TopicSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TopicStatus 

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

TopicStatus defines the observed state of Topic.

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicStatus.

func (*TopicStatus) DeepCopyInto 

func (in *TopicStatus) DeepCopyInto(out *TopicStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.