v1beta1

package
v0.16.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

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 CapacityObservation 

type CapacityObservation struct {
}

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

type ConditionObservation struct {
}

func (*ConditionObservation) DeepCopy 

func (in *ConditionObservation) DeepCopy() *ConditionObservation

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

func (*ConditionObservation) DeepCopyInto 

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

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

type ConditionParameters 

type ConditionParameters struct {

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

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

	// +kubebuilder:validation:Required
	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 DeadLetterPolicyObservation 

type DeadLetterPolicyObservation struct {
}

func (*DeadLetterPolicyObservation) DeepCopy 

func (in *DeadLetterPolicyObservation) DeepCopy() *DeadLetterPolicyObservation

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

func (*DeadLetterPolicyObservation) DeepCopyInto 

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

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

type DeadLetterPolicyParameters 

type DeadLetterPolicyParameters struct {

	// The name of the topic to which dead letter messages should be published.
	// Format is projects/{project}/topics/{topic}.
	// The Cloud Pub/Sub service account associated with the enclosing subscription's
	// parent project (i.e.,
	// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
	// permission to Publish() to this topic.
	// The operation will fail if the topic does not exist.
	// Users should ensure that there is a subscription attached to this topic
	// since messages published to a topic with no subscriptions are lost.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/pubsub/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 

func (in *DeadLetterPolicyParameters) DeepCopy() *DeadLetterPolicyParameters

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

func (*DeadLetterPolicyParameters) DeepCopyInto 

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

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

type DeliveryConfigObservation 

type DeliveryConfigObservation struct {
}

func (*DeliveryConfigObservation) DeepCopy 

func (in *DeliveryConfigObservation) DeepCopy() *DeliveryConfigObservation

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

func (*DeliveryConfigObservation) DeepCopyInto 

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

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

type DeliveryConfigParameters 

type DeliveryConfigParameters struct {

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

func (*DeliveryConfigParameters) DeepCopy 

func (in *DeliveryConfigParameters) DeepCopy() *DeliveryConfigParameters

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

func (*DeliveryConfigParameters) DeepCopyInto 

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

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

type ExpirationPolicyObservation 

type ExpirationPolicyObservation struct {
}

func (*ExpirationPolicyObservation) DeepCopy 

func (in *ExpirationPolicyObservation) DeepCopy() *ExpirationPolicyObservation

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

func (*ExpirationPolicyObservation) DeepCopyInto 

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

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

type ExpirationPolicyParameters 

type ExpirationPolicyParameters struct {

	// Specifies the "time-to-live" duration for an associated resource. The
	// resource expires if it is not active for a period of ttl.
	// If ttl is not set, the associated resource never expires.
	// A duration in seconds with up to nine fractional digits, terminated by 's'.
	// Example - "3.5s".
	// +kubebuilder:validation:Required
	TTL *string `json:"ttl" tf:"ttl,omitempty"`
}

func (*ExpirationPolicyParameters) DeepCopy 

func (in *ExpirationPolicyParameters) DeepCopy() *ExpirationPolicyParameters

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

func (*ExpirationPolicyParameters) DeepCopyInto 

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

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

type LiteReservation 

type LiteReservation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	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) 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) GetProviderReference 

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

GetProviderReference of this LiteReservation. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this LiteReservation. Deprecated: Use SetProviderConfigReference.

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

func (*LiteReservationObservation) DeepCopy 

func (in *LiteReservationObservation) DeepCopy() *LiteReservationObservation

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

func (*LiteReservationObservation) DeepCopyInto 

func (in *LiteReservationObservation) DeepCopyInto(out *LiteReservationObservation)

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:Required
	ThroughputCapacity *float64 `json:"throughputCapacity" tf:"throughput_capacity,omitempty"`
}

func (*LiteReservationParameters) DeepCopy 

func (in *LiteReservationParameters) DeepCopy() *LiteReservationParameters

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

func (*LiteReservationParameters) DeepCopyInto 

func (in *LiteReservationParameters) DeepCopyInto(out *LiteReservationParameters)

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

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 

func (in *LiteReservationStatus) DeepCopy() *LiteReservationStatus

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

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

GetProviderReference of this LiteSubscription. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this LiteSubscription. Deprecated: Use SetProviderConfigReference.

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 LiteSubscriptionList 

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

LiteSubscriptionList contains a list of LiteSubscriptions

func (*LiteSubscriptionList) DeepCopy 

func (in *LiteSubscriptionList) DeepCopy() *LiteSubscriptionList

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

func (*LiteSubscriptionList) DeepCopyInto 

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

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

func (*LiteSubscriptionList) DeepCopyObject 

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

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

func (*LiteSubscriptionList) GetItems 

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

GetItems of this LiteSubscriptionList.

type LiteSubscriptionObservation 

type LiteSubscriptionObservation struct {

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

func (*LiteSubscriptionObservation) DeepCopy 

func (in *LiteSubscriptionObservation) DeepCopy() *LiteSubscriptionObservation

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

func (*LiteSubscriptionObservation) DeepCopyInto 

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

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

type LiteSubscriptionParameters 

type LiteSubscriptionParameters struct {

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

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

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

	// A reference to a Topic resource.
	// +crossplane:generate:reference:type=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 

func (in *LiteSubscriptionParameters) DeepCopy() *LiteSubscriptionParameters

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

func (*LiteSubscriptionParameters) DeepCopyInto 

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

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

type LiteSubscriptionSpec 

type LiteSubscriptionSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     LiteSubscriptionParameters `json:"forProvider"`
}

LiteSubscriptionSpec defines the desired state of LiteSubscription

func (*LiteSubscriptionSpec) DeepCopy 

func (in *LiteSubscriptionSpec) DeepCopy() *LiteSubscriptionSpec

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

func (*LiteSubscriptionSpec) DeepCopyInto 

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

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

type LiteSubscriptionStatus 

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

LiteSubscriptionStatus defines the observed state of LiteSubscription.

func (*LiteSubscriptionStatus) DeepCopy 

func (in *LiteSubscriptionStatus) DeepCopy() *LiteSubscriptionStatus

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

func (*LiteSubscriptionStatus) DeepCopyInto 

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

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

type LiteTopic 

type LiteTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	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) 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) GetProviderReference 

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

GetProviderReference of this LiteTopic. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this LiteTopic. Deprecated: Use SetProviderConfigReference.

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

func (*LiteTopicObservation) DeepCopy 

func (in *LiteTopicObservation) DeepCopy() *LiteTopicObservation

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

func (*LiteTopicObservation) DeepCopyInto 

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

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

type LiteTopicParameters 

type LiteTopicParameters struct {

	// The settings for this topic's partitions.
	// Structure is documented below.
	// +kubebuilder:validation:Required
	PartitionConfig []PartitionConfigParameters `json:"partitionConfig" 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:Required
	RetentionConfig []RetentionConfigParameters `json:"retentionConfig" 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"`
}

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 MessageStoragePolicyObservation 

type MessageStoragePolicyObservation struct {
}

func (*MessageStoragePolicyObservation) DeepCopy 

func (in *MessageStoragePolicyObservation) DeepCopy() *MessageStoragePolicyObservation

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

func (*MessageStoragePolicyObservation) DeepCopyInto 

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

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

type MessageStoragePolicyParameters 

type MessageStoragePolicyParameters struct {

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

func (*MessageStoragePolicyParameters) DeepCopy 

func (in *MessageStoragePolicyParameters) DeepCopy() *MessageStoragePolicyParameters

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

func (*MessageStoragePolicyParameters) DeepCopyInto 

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

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

type OidcTokenObservation 

type OidcTokenObservation struct {
}

func (*OidcTokenObservation) DeepCopy 

func (in *OidcTokenObservation) DeepCopy() *OidcTokenObservation

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

func (*OidcTokenObservation) DeepCopyInto 

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

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

type OidcTokenParameters 

type OidcTokenParameters struct {

	// Audience to be used when generating OIDC token. The audience claim
	// identifies the recipients that the JWT is intended for. The audience
	// value is a single case-sensitive string. Having multiple values (array)
	// for the audience field is not supported. More info about the OIDC JWT
	// token audience here: https://tools.ietf.org/html/rfc7519#section-4.1.3
	// Note: if not specified, the Push endpoint URL will be used.
	// +kubebuilder:validation:Optional
	Audience *string `json:"audience,omitempty" tf:"audience,omitempty"`

	// Service account email to be used for generating the OIDC token.
	// The caller (for subscriptions.create, subscriptions.patch, and
	// subscriptions.modifyPushConfig RPCs) must have the
	// iam.serviceAccounts.actAs permission for the service account.
	// +kubebuilder:validation:Required
	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 PartitionConfigObservation 

type PartitionConfigObservation struct {
}

func (*PartitionConfigObservation) DeepCopy 

func (in *PartitionConfigObservation) DeepCopy() *PartitionConfigObservation

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

func (*PartitionConfigObservation) DeepCopyInto 

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

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

type PartitionConfigParameters 

type PartitionConfigParameters struct {

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

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

func (*PartitionConfigParameters) DeepCopy 

func (in *PartitionConfigParameters) DeepCopy() *PartitionConfigParameters

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

func (*PartitionConfigParameters) DeepCopyInto 

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

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

type PushConfigObservation 

type PushConfigObservation struct {
}

func (*PushConfigObservation) DeepCopy 

func (in *PushConfigObservation) DeepCopy() *PushConfigObservation

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

func (*PushConfigObservation) DeepCopyInto 

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

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

type PushConfigParameters 

type PushConfigParameters struct {

	// Endpoint configuration attributes.
	// Every endpoint has a set of API supported attributes that can
	// be used to control different aspects of the message delivery.
	// The currently supported attribute is x-goog-version, which you
	// can use to change the format of the pushed message. This
	// attribute indicates the version of the data expected by
	// the endpoint. This controls the shape of the pushed message
	// (i.e., its fields and metadata). The endpoint version is
	// based on the version of the Pub/Sub API.
	// If not present during the subscriptions.create call,
	// it will default to the version of the API used to make
	// such call. If not present during a subscriptions.modifyPushConfig
	// call, its value will not be changed. subscriptions.get
	// calls will always return a valid version, even if the
	// subscription was created without this attribute.
	// The possible values for this attribute are:
	// +kubebuilder:validation:Optional
	Attributes map[string]*string `json:"attributes,omitempty" tf:"attributes,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:Required
	PushEndpoint *string `json:"pushEndpoint" tf:"push_endpoint,omitempty"`
}

func (*PushConfigParameters) DeepCopy 

func (in *PushConfigParameters) DeepCopy() *PushConfigParameters

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

func (*PushConfigParameters) DeepCopyInto 

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

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

type ReservationConfigObservation 

type ReservationConfigObservation struct {
}

func (*ReservationConfigObservation) DeepCopy 

func (in *ReservationConfigObservation) DeepCopy() *ReservationConfigObservation

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

func (*ReservationConfigObservation) DeepCopyInto 

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

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

type ReservationConfigParameters 

type ReservationConfigParameters struct {

	// The Reservation to use for this topic's throughput capacity.
	// +crossplane:generate:reference:type=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 

func (in *ReservationConfigParameters) DeepCopy() *ReservationConfigParameters

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

func (*ReservationConfigParameters) DeepCopyInto 

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

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

type RetentionConfigObservation 

type RetentionConfigObservation struct {
}

func (*RetentionConfigObservation) DeepCopy 

func (in *RetentionConfigObservation) DeepCopy() *RetentionConfigObservation

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

func (*RetentionConfigObservation) DeepCopyInto 

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

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

type RetentionConfigParameters 

type RetentionConfigParameters struct {

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

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

func (*RetentionConfigParameters) DeepCopy 

func (in *RetentionConfigParameters) DeepCopy() *RetentionConfigParameters

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

func (*RetentionConfigParameters) DeepCopyInto 

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

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

type RetryPolicyObservation 

type RetryPolicyObservation struct {
}

func (*RetryPolicyObservation) DeepCopy 

func (in *RetryPolicyObservation) DeepCopy() *RetryPolicyObservation

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

func (*RetryPolicyObservation) DeepCopyInto 

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

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

type RetryPolicyParameters 

type RetryPolicyParameters struct {

	// The maximum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 600 seconds.
	// A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s".
	// +kubebuilder:validation:Optional
	MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff,omitempty"`

	// The minimum delay between consecutive deliveries of a given message. Value should be between 0 and 600 seconds. Defaults to 10 seconds.
	// A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s".
	// +kubebuilder:validation:Optional
	MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff,omitempty"`
}

func (*RetryPolicyParameters) DeepCopy 

func (in *RetryPolicyParameters) DeepCopy() *RetryPolicyParameters

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

func (*RetryPolicyParameters) DeepCopyInto 

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

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

type 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) 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) GetProviderReference 

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

GetProviderReference of this Schema. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this Schema. Deprecated: Use SetProviderConfigReference.

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

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

type SchemaSettingsObservation struct {
}

func (*SchemaSettingsObservation) DeepCopy 

func (in *SchemaSettingsObservation) DeepCopy() *SchemaSettingsObservation

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

func (*SchemaSettingsObservation) DeepCopyInto 

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

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

type SchemaSettingsParameters 

type SchemaSettingsParameters struct {

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

func (*SchemaSettingsParameters) DeepCopy 

func (in *SchemaSettingsParameters) DeepCopy() *SchemaSettingsParameters

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

func (*SchemaSettingsParameters) DeepCopyInto 

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

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

type SchemaSpec 

type SchemaSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SchemaParameters `json:"forProvider"`
}

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

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

GetProviderReference of this Subscription. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this Subscription. Deprecated: Use SetProviderConfigReference.

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

func (in *SubscriptionIAMMember) DeepCopy() *SubscriptionIAMMember

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

func (*SubscriptionIAMMember) DeepCopyInto 

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

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

func (*SubscriptionIAMMember) DeepCopyObject 

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

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

func (*SubscriptionIAMMember) GetCondition 

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

GetCondition of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this SubscriptionIAMMember

func (*SubscriptionIAMMember) GetDeletionPolicy 

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

GetDeletionPolicy of this SubscriptionIAMMember.

func (*SubscriptionIAMMember) GetID 

func (tr *SubscriptionIAMMember) GetID() string

GetID returns ID of underlying Terraform resource of this SubscriptionIAMMember

func (*SubscriptionIAMMember) 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) GetProviderReference 

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

GetProviderReference of this SubscriptionIAMMember. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this SubscriptionIAMMember. Deprecated: Use SetProviderConfigReference.

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 SubscriptionIAMMemberList 

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

SubscriptionIAMMemberList contains a list of SubscriptionIAMMembers

func (*SubscriptionIAMMemberList) DeepCopy 

func (in *SubscriptionIAMMemberList) DeepCopy() *SubscriptionIAMMemberList

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

func (*SubscriptionIAMMemberList) DeepCopyInto 

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

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

func (*SubscriptionIAMMemberList) DeepCopyObject 

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

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

func (*SubscriptionIAMMemberList) GetItems 

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

GetItems of this SubscriptionIAMMemberList.

type SubscriptionIAMMemberObservation 

type SubscriptionIAMMemberObservation struct {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

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

func (*SubscriptionIAMMemberObservation) DeepCopy 

func (in *SubscriptionIAMMemberObservation) DeepCopy() *SubscriptionIAMMemberObservation

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

func (*SubscriptionIAMMemberObservation) DeepCopyInto 

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

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

type SubscriptionIAMMemberParameters 

type SubscriptionIAMMemberParameters struct {

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

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

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

	// +kubebuilder:validation:Required
	Role *string `json:"role" 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 

func (in *SubscriptionIAMMemberParameters) DeepCopy() *SubscriptionIAMMemberParameters

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

func (*SubscriptionIAMMemberParameters) DeepCopyInto 

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

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

type SubscriptionIAMMemberSpec 

type SubscriptionIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SubscriptionIAMMemberParameters `json:"forProvider"`
}

SubscriptionIAMMemberSpec defines the desired state of SubscriptionIAMMember

func (*SubscriptionIAMMemberSpec) DeepCopy 

func (in *SubscriptionIAMMemberSpec) DeepCopy() *SubscriptionIAMMemberSpec

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

func (*SubscriptionIAMMemberSpec) DeepCopyInto 

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

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

type SubscriptionIAMMemberStatus 

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

SubscriptionIAMMemberStatus defines the observed state of SubscriptionIAMMember.

func (*SubscriptionIAMMemberStatus) DeepCopy 

func (in *SubscriptionIAMMemberStatus) DeepCopy() *SubscriptionIAMMemberStatus

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

func (*SubscriptionIAMMemberStatus) DeepCopyInto 

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

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

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

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

func (*SubscriptionObservation) DeepCopy 

func (in *SubscriptionObservation) DeepCopy() *SubscriptionObservation

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

func (*SubscriptionObservation) DeepCopyInto 

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

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

type SubscriptionParameters 

type SubscriptionParameters struct {

	// This value is the maximum time after a subscriber receives a message
	// before the subscriber should acknowledge the message. After message
	// delivery but before the ack deadline expires and before the message is
	// acknowledged, it is an outstanding message and will not be delivered
	// again during that time (on a best-effort basis).
	// For pull subscriptions, this value is used as the initial value for
	// the ack deadline. To override this value for a given message, call
	// subscriptions.modifyAckDeadline with the corresponding ackId if using
	// pull. The minimum custom deadline you can specify is 10 seconds. The
	// maximum custom deadline you can specify is 600 seconds (10 minutes).
	// If this parameter is 0, a default value of 10 seconds is used.
	// For push delivery, this value is also used to set the request timeout
	// for the call to the push endpoint.
	// If the subscriber never acknowledges the message, the Pub/Sub system
	// will eventually redeliver the message.
	// +kubebuilder:validation:Optional
	AckDeadlineSeconds *float64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds,omitempty"`

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

func (in *SubscriptionParameters) DeepCopy() *SubscriptionParameters

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

func (*SubscriptionParameters) DeepCopyInto 

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

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

type SubscriptionSpec 

type SubscriptionSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SubscriptionParameters `json:"forProvider"`
}

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

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

GetProviderReference of this Topic. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this Topic. Deprecated: Use SetProviderConfigReference.

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"`
	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) 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) GetProviderReference 

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

GetProviderReference of this TopicIAMMember. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this TopicIAMMember. Deprecated: Use SetProviderConfigReference.

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 TopicIAMMemberConditionObservation 

type TopicIAMMemberConditionObservation struct {
}

func (*TopicIAMMemberConditionObservation) DeepCopy 

func (in *TopicIAMMemberConditionObservation) DeepCopy() *TopicIAMMemberConditionObservation

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

func (*TopicIAMMemberConditionObservation) DeepCopyInto 

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

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

type TopicIAMMemberConditionParameters 

type TopicIAMMemberConditionParameters struct {

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

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

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

func (*TopicIAMMemberConditionParameters) DeepCopy 

func (in *TopicIAMMemberConditionParameters) DeepCopy() *TopicIAMMemberConditionParameters

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

func (*TopicIAMMemberConditionParameters) DeepCopyInto 

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

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

type 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 {
	Etag *string `json:"etag,omitempty" tf:"etag,omitempty"`

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

func (*TopicIAMMemberObservation) DeepCopy 

func (in *TopicIAMMemberObservation) DeepCopy() *TopicIAMMemberObservation

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

func (*TopicIAMMemberObservation) DeepCopyInto 

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

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

type TopicIAMMemberParameters 

type TopicIAMMemberParameters struct {

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

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

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

	// +kubebuilder:validation:Required
	Role *string `json:"role" 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 

func (in *TopicIAMMemberParameters) DeepCopy() *TopicIAMMemberParameters

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

func (*TopicIAMMemberParameters) DeepCopyInto 

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

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

type TopicIAMMemberSpec 

type TopicIAMMemberSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     TopicIAMMemberParameters `json:"forProvider"`
}

TopicIAMMemberSpec defines the desired state of TopicIAMMember

func (*TopicIAMMemberSpec) DeepCopy 

func (in *TopicIAMMemberSpec) DeepCopy() *TopicIAMMemberSpec

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

func (*TopicIAMMemberSpec) DeepCopyInto 

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

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

type TopicIAMMemberStatus 

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

TopicIAMMemberStatus defines the observed state of TopicIAMMember.

func (*TopicIAMMemberStatus) DeepCopy 

func (in *TopicIAMMemberStatus) DeepCopy() *TopicIAMMemberStatus

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

func (*TopicIAMMemberStatus) DeepCopyInto 

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

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

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

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

TopicSpec defines the desired state of Topic

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

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

func (*TopicSpec) DeepCopyInto 

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

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

type TopicStatus 

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

TopicStatus defines the observed state of Topic.

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

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

func (*TopicStatus) DeepCopyInto 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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