v1beta1

package
v0.38.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Sep 28, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Overview

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

Index

Constants

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

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 (
	LiteReservation_Kind             = "LiteReservation"
	LiteReservation_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: LiteReservation_Kind}.String()
	LiteReservation_KindAPIVersion   = LiteReservation_Kind + "." + CRDGroupVersion.String()
	LiteReservation_GroupVersionKind = CRDGroupVersion.WithKind(LiteReservation_Kind)
)

Repository type metadata.

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 (
	Schema_Kind             = "Schema"
	Schema_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Schema_Kind}.String()
	Schema_KindAPIVersion   = Schema_Kind + "." + CRDGroupVersion.String()
	Schema_GroupVersionKind = CRDGroupVersion.WithKind(Schema_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 BigqueryConfigInitParameters added in v0.35.0

type BigqueryConfigInitParameters struct {

	// When true and useTopicSchema is true, any fields that are a part of the topic 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 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 topic's schema as the columns to write to in BigQuery, if it exists.
	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 added in v0.35.0

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

func (*BigqueryConfigInitParameters) DeepCopyInto added in v0.35.0

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

type BigqueryConfigObservation added in v0.26.0

type BigqueryConfigObservation struct {

	// When true and useTopicSchema is true, any fields that are a part of the topic 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 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 topic's schema as the columns to write to in BigQuery, if it exists.
	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 added in v0.26.0

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

func (*BigqueryConfigObservation) DeepCopyInto added in v0.26.0

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

type BigqueryConfigParameters added in v0.26.0

type BigqueryConfigParameters struct {

	// When true and useTopicSchema is true, any fields that are a part of the topic 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 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 topic's schema as the columns to write to in BigQuery, if it exists.
	// +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 added in v0.26.0

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

func (*BigqueryConfigParameters) DeepCopyInto added in v0.26.0

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 added in v0.35.0

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 added in v0.35.0

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

func (*CapacityInitParameters) DeepCopyInto added in v0.35.0

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 ConditionInitParameters added in v0.35.0

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 added in v0.35.0

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

func (*ConditionInitParameters) DeepCopyInto added in v0.35.0

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

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 added in v0.35.0

type DeadLetterPolicyInitParameters struct {

	// 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 added in v0.35.0

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

func (*DeadLetterPolicyInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*DeadLetterPolicyObservation) DeepCopyInto

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/v1beta1.Topic
	// +crossplane:generate:reference:extractor=github.com/upbound/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

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

func (*DeadLetterPolicyParameters) DeepCopyInto

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

type DeliveryConfigInitParameters added in v0.35.0

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 added in v0.35.0

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

func (*DeliveryConfigInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*DeliveryConfigObservation) DeepCopyInto

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

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 added in v0.35.0

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 added in v0.35.0

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

func (*ExpirationPolicyInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*ExpirationPolicyObservation) DeepCopyInto

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

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

func (*ExpirationPolicyParameters) DeepCopyInto

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

type LiteReservation

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

LiteReservation is the Schema for the LiteReservations API. A named resource representing a shared pool of capacity. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*LiteReservation) DeepCopy

func (in *LiteReservation) DeepCopy() *LiteReservation

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

func (*LiteReservation) DeepCopyInto

func (in *LiteReservation) DeepCopyInto(out *LiteReservation)

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

func (*LiteReservation) DeepCopyObject

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

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

func (*LiteReservation) GetCondition

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

GetCondition of this LiteReservation.

func (*LiteReservation) GetConnectionDetailsMapping

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

GetConnectionDetailsMapping for this LiteReservation

func (*LiteReservation) GetDeletionPolicy

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

GetDeletionPolicy of this LiteReservation.

func (*LiteReservation) GetID

func (tr *LiteReservation) GetID() string

GetID returns ID of underlying Terraform resource of this LiteReservation

func (*LiteReservation) GetInitParameters added in v0.35.0

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

GetInitParameters of this LiteReservation

func (*LiteReservation) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies of this LiteReservation.

func (*LiteReservation) GetObservation

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

GetObservation of this LiteReservation

func (*LiteReservation) GetParameters

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

GetParameters of this LiteReservation

func (*LiteReservation) GetProviderConfigReference

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

GetProviderConfigReference of this LiteReservation.

func (*LiteReservation) GetPublishConnectionDetailsTo

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

GetPublishConnectionDetailsTo of this LiteReservation.

func (*LiteReservation) GetTerraformResourceType

func (mg *LiteReservation) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this LiteReservation

func (*LiteReservation) GetTerraformSchemaVersion

func (tr *LiteReservation) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*LiteReservation) GetWriteConnectionSecretToReference

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

GetWriteConnectionSecretToReference of this LiteReservation.

func (*LiteReservation) LateInitialize

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

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

func (*LiteReservation) SetConditions

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

SetConditions of this LiteReservation.

func (*LiteReservation) SetDeletionPolicy

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

SetDeletionPolicy of this LiteReservation.

func (*LiteReservation) SetManagementPolicies added in v0.35.0

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

SetManagementPolicies of this LiteReservation.

func (*LiteReservation) SetObservation

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

SetObservation for this LiteReservation

func (*LiteReservation) SetParameters

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

SetParameters for this LiteReservation

func (*LiteReservation) SetProviderConfigReference

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

SetProviderConfigReference of this LiteReservation.

func (*LiteReservation) SetPublishConnectionDetailsTo

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

SetPublishConnectionDetailsTo of this LiteReservation.

func (*LiteReservation) SetWriteConnectionSecretToReference

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

SetWriteConnectionSecretToReference of this LiteReservation.

type LiteReservationInitParameters added in v0.35.0

type LiteReservationInitParameters struct {

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

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

func (*LiteReservationInitParameters) DeepCopy added in v0.35.0

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

func (*LiteReservationInitParameters) DeepCopyInto added in v0.35.0

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

type LiteReservationList

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

LiteReservationList contains a list of LiteReservations

func (*LiteReservationList) DeepCopy

func (in *LiteReservationList) DeepCopy() *LiteReservationList

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

func (*LiteReservationList) DeepCopyInto

func (in *LiteReservationList) DeepCopyInto(out *LiteReservationList)

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

func (*LiteReservationList) DeepCopyObject

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

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

func (*LiteReservationList) GetItems

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

GetItems of this LiteReservationList.

type LiteReservationObservation

type LiteReservationObservation struct {

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

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

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

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

func (*LiteReservationObservation) DeepCopy

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

func (*LiteReservationObservation) DeepCopyInto

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

type LiteReservationParameters

type LiteReservationParameters struct {

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

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

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

func (*LiteReservationParameters) DeepCopy

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

func (*LiteReservationParameters) DeepCopyInto

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

type LiteReservationSpec

type LiteReservationSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     LiteReservationParameters `json:"forProvider"`
	// THIS IS AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider LiteReservationInitParameters `json:"initProvider,omitempty"`
}

LiteReservationSpec defines the desired state of LiteReservation

func (*LiteReservationSpec) DeepCopy

func (in *LiteReservationSpec) DeepCopy() *LiteReservationSpec

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

func (*LiteReservationSpec) DeepCopyInto

func (in *LiteReservationSpec) DeepCopyInto(out *LiteReservationSpec)

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

type LiteReservationStatus

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

LiteReservationStatus defines the observed state of LiteReservation.

func (*LiteReservationStatus) DeepCopy

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

func (*LiteReservationStatus) DeepCopyInto

func (in *LiteReservationStatus) DeepCopyInto(out *LiteReservationStatus)

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +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 added in v0.35.0

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

GetInitParameters of this LiteSubscription

func (*LiteSubscription) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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

ResolveReferences of this LiteSubscription.

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 added in v0.35.0

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 added in v0.35.0

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

func (*LiteSubscriptionInitParameters) DeepCopy added in v0.35.0

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

func (*LiteSubscriptionInitParameters) DeepCopyInto added in v0.35.0

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

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

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

func (*LiteSubscriptionObservation) DeepCopyInto

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=LiteTopic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

	// Selector for a LiteTopic 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

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

func (*LiteSubscriptionParameters) DeepCopyInto

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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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

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

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +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 added in v0.35.0

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

GetInitParameters of this LiteTopic

func (*LiteTopic) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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 added in v0.35.0

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 added in v0.35.0

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 added in v0.35.0

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

func (*LiteTopicInitParameters) DeepCopyInto added in v0.35.0

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

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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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 added in v0.35.0

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 added in v0.35.0

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

func (*MessageStoragePolicyInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*MessageStoragePolicyObservation) DeepCopyInto

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

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

func (*MessageStoragePolicyParameters) DeepCopyInto

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

type NoWrapperInitParameters added in v0.37.0

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 added in v0.37.0

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

func (*NoWrapperInitParameters) DeepCopyInto added in v0.37.0

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 added in v0.37.0

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 added in v0.37.0

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

func (*NoWrapperObservation) DeepCopyInto added in v0.37.0

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 added in v0.37.0

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 added in v0.37.0

func (in *NoWrapperParameters) DeepCopy() *NoWrapperParameters

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

func (*NoWrapperParameters) DeepCopyInto added in v0.37.0

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 added in v0.35.0

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 added in v0.35.0

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

func (*OidcTokenInitParameters) DeepCopyInto added in v0.35.0

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

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 added in v0.35.0

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 added in v0.35.0

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

func (*PartitionConfigInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*PartitionConfigObservation) DeepCopyInto

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

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

func (*PartitionConfigParameters) DeepCopyInto

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

type PushConfigInitParameters added in v0.35.0

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:
	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 added in v0.35.0

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

func (*PushConfigInitParameters) DeepCopyInto added in v0.35.0

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:
	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

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
	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

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 added in v0.35.0

type ReservationConfigInitParameters struct {
}

func (*ReservationConfigInitParameters) DeepCopy added in v0.35.0

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

func (*ReservationConfigInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*ReservationConfigObservation) DeepCopyInto

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=LiteReservation
	// +kubebuilder:validation:Optional
	ThroughputReservation *string `json:"throughputReservation,omitempty" tf:"throughput_reservation,omitempty"`

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

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

func (*ReservationConfigParameters) DeepCopy

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

func (*ReservationConfigParameters) DeepCopyInto

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

type RetentionConfigInitParameters added in v0.35.0

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 added in v0.35.0

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

func (*RetentionConfigInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*RetentionConfigObservation) DeepCopyInto

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

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

func (*RetentionConfigParameters) DeepCopyInto

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

type RetryPolicyInitParameters added in v0.35.0

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 added in v0.35.0

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

func (*RetryPolicyInitParameters) DeepCopyInto added in v0.35.0

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

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

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 Schema

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

Schema is the Schema for the Schemas API. A schema is a format that messages must follow, creating a contract between publisher and subscriber that Pub/Sub will enforce. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*Schema) DeepCopy

func (in *Schema) DeepCopy() *Schema

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

func (*Schema) DeepCopyInto

func (in *Schema) DeepCopyInto(out *Schema)

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

func (*Schema) DeepCopyObject

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

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

func (*Schema) GetCondition

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

GetCondition of this Schema.

func (*Schema) GetConnectionDetailsMapping

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

GetConnectionDetailsMapping for this Schema

func (*Schema) GetDeletionPolicy

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

GetDeletionPolicy of this Schema.

func (*Schema) GetID

func (tr *Schema) GetID() string

GetID returns ID of underlying Terraform resource of this Schema

func (*Schema) GetInitParameters added in v0.35.0

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

GetInitParameters of this Schema

func (*Schema) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies of this Schema.

func (*Schema) GetObservation

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

GetObservation of this Schema

func (*Schema) GetParameters

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

GetParameters of this Schema

func (*Schema) GetProviderConfigReference

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

GetProviderConfigReference of this Schema.

func (*Schema) GetPublishConnectionDetailsTo

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

GetPublishConnectionDetailsTo of this Schema.

func (*Schema) GetTerraformResourceType

func (mg *Schema) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Schema

func (*Schema) GetTerraformSchemaVersion

func (tr *Schema) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Schema) GetWriteConnectionSecretToReference

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

GetWriteConnectionSecretToReference of this Schema.

func (*Schema) LateInitialize

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

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

func (*Schema) SetConditions

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

SetConditions of this Schema.

func (*Schema) SetDeletionPolicy

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

SetDeletionPolicy of this Schema.

func (*Schema) SetManagementPolicies added in v0.35.0

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

SetManagementPolicies of this Schema.

func (*Schema) SetObservation

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

SetObservation for this Schema

func (*Schema) SetParameters

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

SetParameters for this Schema

func (*Schema) SetProviderConfigReference

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

SetProviderConfigReference of this Schema.

func (*Schema) SetPublishConnectionDetailsTo

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

SetPublishConnectionDetailsTo of this Schema.

func (*Schema) SetWriteConnectionSecretToReference

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

SetWriteConnectionSecretToReference of this Schema.

type SchemaInitParameters added in v0.35.0

type SchemaInitParameters struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type.
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

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

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

func (*SchemaInitParameters) DeepCopy added in v0.35.0

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

func (*SchemaInitParameters) DeepCopyInto added in v0.35.0

func (in *SchemaInitParameters) DeepCopyInto(out *SchemaInitParameters)

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

type SchemaList

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

SchemaList contains a list of Schemas

func (*SchemaList) DeepCopy

func (in *SchemaList) DeepCopy() *SchemaList

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

func (*SchemaList) DeepCopyInto

func (in *SchemaList) DeepCopyInto(out *SchemaList)

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

func (*SchemaList) DeepCopyObject

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

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

func (*SchemaList) GetItems

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

GetItems of this SchemaList.

type SchemaObservation

type SchemaObservation struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type.
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

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

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

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

func (*SchemaObservation) DeepCopy

func (in *SchemaObservation) DeepCopy() *SchemaObservation

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

func (*SchemaObservation) DeepCopyInto

func (in *SchemaObservation) DeepCopyInto(out *SchemaObservation)

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

type SchemaParameters

type SchemaParameters struct {

	// The definition of the schema.
	// This should contain a string representing the full definition of the schema
	// that is a valid schema definition of the type specified in type.
	// +kubebuilder:validation:Optional
	Definition *string `json:"definition,omitempty" tf:"definition,omitempty"`

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

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

func (*SchemaParameters) DeepCopy

func (in *SchemaParameters) DeepCopy() *SchemaParameters

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

func (*SchemaParameters) DeepCopyInto

func (in *SchemaParameters) DeepCopyInto(out *SchemaParameters)

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

type SchemaSettingsInitParameters added in v0.35.0

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 added in v0.35.0

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

func (*SchemaSettingsInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*SchemaSettingsObservation) DeepCopyInto

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

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 SchemaSpec

type SchemaSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SchemaParameters `json:"forProvider"`
	// THIS IS AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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 SchemaInitParameters `json:"initProvider,omitempty"`
}

SchemaSpec defines the desired state of Schema

func (*SchemaSpec) DeepCopy

func (in *SchemaSpec) DeepCopy() *SchemaSpec

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

func (*SchemaSpec) DeepCopyInto

func (in *SchemaSpec) DeepCopyInto(out *SchemaSpec)

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

type SchemaStatus

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

SchemaStatus defines the observed state of Schema.

func (*SchemaStatus) DeepCopy

func (in *SchemaStatus) DeepCopy() *SchemaStatus

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

func (*SchemaStatus) DeepCopyInto

func (in *SchemaStatus) DeepCopyInto(out *SchemaStatus)

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +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 added in v0.35.0

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

GetInitParameters of this Subscription

func (*Subscription) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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 added in v0.35.0

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*SubscriptionIAMMember) DeepCopy

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 added in v0.35.0

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

GetInitParameters of this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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 added in v0.35.0

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 added in v0.35.0

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

func (*SubscriptionIAMMemberInitParameters) DeepCopy added in v0.35.0

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

func (*SubscriptionIAMMemberInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*SubscriptionIAMMemberList) DeepCopyInto

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

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

func (*SubscriptionIAMMemberObservation) DeepCopyInto

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=Subscription
	// +kubebuilder:validation:Optional
	Subscription *string `json:"subscription,omitempty" tf:"subscription,omitempty"`

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

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

func (*SubscriptionIAMMemberParameters) DeepCopy

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

func (*SubscriptionIAMMemberParameters) DeepCopyInto

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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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

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

func (*SubscriptionIAMMemberSpec) DeepCopyInto

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

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

func (*SubscriptionIAMMemberStatus) DeepCopyInto

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

type SubscriptionInitParameters added in v0.35.0

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 or bigQueryConfig can be set, but not both.
	// If both 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"`

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

func (*SubscriptionInitParameters) DeepCopy added in v0.35.0

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

func (*SubscriptionInitParameters) DeepCopyInto added in v0.35.0

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 or bigQueryConfig can be set, but not both.
	// If both 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"`

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

	// 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.
	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"`

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

func (*SubscriptionObservation) DeepCopy

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 or bigQueryConfig can be set, but not both.
	// If both 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"`

	// 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
	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.
	// +crossplane:generate:reference:type=Topic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*SubscriptionParameters) DeepCopy

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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +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 added in v0.35.0

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

GetInitParameters of this Topic

func (*Topic) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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 added in v0.35.0

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].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:subresource:status +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 added in v0.35.0

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

GetInitParameters of this TopicIAMMember

func (*TopicIAMMember) GetManagementPolicies added in v0.35.0

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

GetManagementPolicies 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) 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 added in v0.35.0

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 added in v0.35.0

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 added in v0.35.0

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

func (*TopicIAMMemberConditionInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*TopicIAMMemberConditionObservation) DeepCopyInto

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

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

func (*TopicIAMMemberConditionParameters) DeepCopyInto

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

type TopicIAMMemberInitParameters added in v0.35.0

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

func (*TopicIAMMemberInitParameters) DeepCopy added in v0.35.0

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

func (*TopicIAMMemberInitParameters) DeepCopyInto added in v0.35.0

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

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

func (*TopicIAMMemberObservation) DeepCopyInto

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=Topic
	// +kubebuilder:validation:Optional
	Topic *string `json:"topic,omitempty" tf:"topic,omitempty"`

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

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

func (*TopicIAMMemberParameters) DeepCopy

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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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

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 added in v0.35.0

type TopicInitParameters struct {

	// A set of key/value label pairs to assign to this Topic.
	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.
	// 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 added in v0.35.0

func (in *TopicInitParameters) DeepCopy() *TopicInitParameters

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

func (*TopicInitParameters) DeepCopyInto added in v0.35.0

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 {

	// an identifier for the resource with format projects/{{project}}/topics/{{name}}
	ID *string `json:"id,omitempty" tf:"id,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.
	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.
	// 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"`
}

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 {

	// 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/v1beta1.CryptoKey
	// +crossplane:generate:reference:extractor=github.com/upbound/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
	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.
	// 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 AN ALPHA FIELD. Do not use it in production. It is not honored
	// unless the relevant Crossplane feature flag is enabled, and may be
	// changed or removed without notice.
	// 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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL