v1alpha1

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

+groupName=pubsub.google.kubeform.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: pubsub.GroupName, Version: "v1alpha1"}

Functions

func GetDecoder 

func GetDecoder() map[string]jsoniter.ValDecoder

func GetEncoder 

func GetEncoder() map[string]jsoniter.ValEncoder

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type LiteReservation added in v0.4.0 

type LiteReservation struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              LiteReservationSpec   `json:"spec,omitempty"`
	Status            LiteReservationStatus `json:"status,omitempty"`
}

func (*LiteReservation) DeepCopy added in v0.4.0 

func (in *LiteReservation) DeepCopy() *LiteReservation

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

func (*LiteReservation) DeepCopyInto added in v0.4.0 

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

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

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

func (*LiteReservation) SetupWebhookWithManager added in v0.4.0 

func (r *LiteReservation) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*LiteReservation) ValidateCreate added in v0.4.0 

func (r *LiteReservation) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*LiteReservation) ValidateDelete added in v0.4.0 

func (r *LiteReservation) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*LiteReservation) ValidateUpdate added in v0.4.0 

func (r *LiteReservation) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type LiteReservationList added in v0.4.0 

type LiteReservationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of LiteReservation CRD objects
	Items []LiteReservation `json:"items,omitempty"`
}

LiteReservationList is a list of LiteReservations

func (*LiteReservationList) DeepCopy added in v0.4.0 

func (in *LiteReservationList) DeepCopy() *LiteReservationList

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

func (*LiteReservationList) DeepCopyInto added in v0.4.0 

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

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

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

type LiteReservationSpec added in v0.4.0 

type LiteReservationSpec struct {
	State *LiteReservationSpecResource `json:"state,omitempty" tf:"-"`

	Resource LiteReservationSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*LiteReservationSpec) DeepCopy added in v0.4.0 

func (in *LiteReservationSpec) DeepCopy() *LiteReservationSpec

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

func (*LiteReservationSpec) DeepCopyInto added in v0.4.0 

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

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

type LiteReservationSpecResource added in v0.4.0 

type LiteReservationSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// Name of the reservation.
	Name *string `json:"name" tf:"name"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The region of the pubsub lite reservation.
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	// The reserved throughput capacity. Every unit of throughput capacity is
	// equivalent to 1 MiB/s of published messages or 2 MiB/s of subscribed
	// messages.
	ThroughputCapacity *int64 `json:"throughputCapacity" tf:"throughput_capacity"`
}

func (*LiteReservationSpecResource) DeepCopy added in v0.4.0 

func (in *LiteReservationSpecResource) DeepCopy() *LiteReservationSpecResource

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

func (*LiteReservationSpecResource) DeepCopyInto added in v0.4.0 

func (in *LiteReservationSpecResource) DeepCopyInto(out *LiteReservationSpecResource)

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

type LiteReservationStatus added in v0.4.0 

type LiteReservationStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*LiteReservationStatus) DeepCopy added in v0.4.0 

func (in *LiteReservationStatus) DeepCopy() *LiteReservationStatus

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

func (*LiteReservationStatus) DeepCopyInto added in v0.4.0 

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              LiteSubscriptionSpec   `json:"spec,omitempty"`
	Status            LiteSubscriptionStatus `json:"status,omitempty"`
}

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

func (r *LiteSubscription) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*LiteSubscription) ValidateCreate 

func (r *LiteSubscription) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*LiteSubscription) ValidateDelete 

func (r *LiteSubscription) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*LiteSubscription) ValidateUpdate 

func (r *LiteSubscription) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type LiteSubscriptionList 

type LiteSubscriptionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of LiteSubscription CRD objects
	Items []LiteSubscription `json:"items,omitempty"`
}

LiteSubscriptionList is 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.

type LiteSubscriptionSpec 

type LiteSubscriptionSpec struct {
	State *LiteSubscriptionSpecResource `json:"state,omitempty" tf:"-"`

	Resource LiteSubscriptionSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 LiteSubscriptionSpecDeliveryConfig 

type LiteSubscriptionSpecDeliveryConfig struct {
	// When this subscription should send messages to subscribers relative to messages persistence in storage. Possible values: ["DELIVER_IMMEDIATELY", "DELIVER_AFTER_STORED", "DELIVERY_REQUIREMENT_UNSPECIFIED"]
	DeliveryRequirement *string `json:"deliveryRequirement" tf:"delivery_requirement"`
}

func (*LiteSubscriptionSpecDeliveryConfig) DeepCopy 

func (in *LiteSubscriptionSpecDeliveryConfig) DeepCopy() *LiteSubscriptionSpecDeliveryConfig

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

func (*LiteSubscriptionSpecDeliveryConfig) DeepCopyInto 

func (in *LiteSubscriptionSpecDeliveryConfig) DeepCopyInto(out *LiteSubscriptionSpecDeliveryConfig)

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

type LiteSubscriptionSpecDeliveryConfigCodec 

type LiteSubscriptionSpecDeliveryConfigCodec struct {
}

+k8s:deepcopy-gen=false

func (LiteSubscriptionSpecDeliveryConfigCodec) Decode 

func (LiteSubscriptionSpecDeliveryConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (LiteSubscriptionSpecDeliveryConfigCodec) Encode 

func (LiteSubscriptionSpecDeliveryConfigCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (LiteSubscriptionSpecDeliveryConfigCodec) IsEmpty 

func (LiteSubscriptionSpecDeliveryConfigCodec) IsEmpty(ptr unsafe.Pointer) bool

type LiteSubscriptionSpecResource 

type LiteSubscriptionSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// The settings for this subscription's message delivery.
	// +optional
	DeliveryConfig *LiteSubscriptionSpecDeliveryConfig `json:"deliveryConfig,omitempty" tf:"delivery_config"`
	// Name of the subscription.
	Name *string `json:"name" tf:"name"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The region of the pubsub lite topic.
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	// A reference to a Topic resource.
	Topic *string `json:"topic" tf:"topic"`
	// The zone of the pubsub lite topic.
	// +optional
	Zone *string `json:"zone,omitempty" tf:"zone"`
}

func (*LiteSubscriptionSpecResource) DeepCopy 

func (in *LiteSubscriptionSpecResource) DeepCopy() *LiteSubscriptionSpecResource

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

func (*LiteSubscriptionSpecResource) DeepCopyInto 

func (in *LiteSubscriptionSpecResource) DeepCopyInto(out *LiteSubscriptionSpecResource)

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

type LiteSubscriptionStatus 

type LiteSubscriptionStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              LiteTopicSpec   `json:"spec,omitempty"`
	Status            LiteTopicStatus `json:"status,omitempty"`
}

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

func (r *LiteTopic) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*LiteTopic) ValidateCreate 

func (r *LiteTopic) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*LiteTopic) ValidateDelete 

func (r *LiteTopic) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*LiteTopic) ValidateUpdate 

func (r *LiteTopic) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type LiteTopicList 

type LiteTopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of LiteTopic CRD objects
	Items []LiteTopic `json:"items,omitempty"`
}

LiteTopicList is 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.

type LiteTopicSpec 

type LiteTopicSpec struct {
	State *LiteTopicSpecResource `json:"state,omitempty" tf:"-"`

	Resource LiteTopicSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 LiteTopicSpecPartitionConfig 

type LiteTopicSpecPartitionConfig struct {
	// The capacity configuration.
	// +optional
	Capacity *LiteTopicSpecPartitionConfigCapacity `json:"capacity,omitempty" tf:"capacity"`
	// The number of partitions in the topic. Must be at least 1.
	Count *int64 `json:"count" tf:"count"`
}

func (*LiteTopicSpecPartitionConfig) DeepCopy 

func (in *LiteTopicSpecPartitionConfig) DeepCopy() *LiteTopicSpecPartitionConfig

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

func (*LiteTopicSpecPartitionConfig) DeepCopyInto 

func (in *LiteTopicSpecPartitionConfig) DeepCopyInto(out *LiteTopicSpecPartitionConfig)

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

type LiteTopicSpecPartitionConfigCapacity 

type LiteTopicSpecPartitionConfigCapacity struct {
	// Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	PublishMIBPerSec *int64 `json:"publishMIBPerSec" tf:"publish_mib_per_sec"`
	// Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16.
	SubscribeMIBPerSec *int64 `json:"subscribeMIBPerSec" tf:"subscribe_mib_per_sec"`
}

func (*LiteTopicSpecPartitionConfigCapacity) DeepCopy 

func (in *LiteTopicSpecPartitionConfigCapacity) DeepCopy() *LiteTopicSpecPartitionConfigCapacity

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

func (*LiteTopicSpecPartitionConfigCapacity) DeepCopyInto 

func (in *LiteTopicSpecPartitionConfigCapacity) DeepCopyInto(out *LiteTopicSpecPartitionConfigCapacity)

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

type LiteTopicSpecPartitionConfigCapacityCodec 

type LiteTopicSpecPartitionConfigCapacityCodec struct {
}

+k8s:deepcopy-gen=false

func (LiteTopicSpecPartitionConfigCapacityCodec) Decode 

func (LiteTopicSpecPartitionConfigCapacityCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (LiteTopicSpecPartitionConfigCapacityCodec) Encode 

func (LiteTopicSpecPartitionConfigCapacityCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (LiteTopicSpecPartitionConfigCapacityCodec) IsEmpty 

func (LiteTopicSpecPartitionConfigCapacityCodec) IsEmpty(ptr unsafe.Pointer) bool

type LiteTopicSpecPartitionConfigCodec 

type LiteTopicSpecPartitionConfigCodec struct {
}

+k8s:deepcopy-gen=false

func (LiteTopicSpecPartitionConfigCodec) Decode 

func (LiteTopicSpecPartitionConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (LiteTopicSpecPartitionConfigCodec) Encode 

func (LiteTopicSpecPartitionConfigCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (LiteTopicSpecPartitionConfigCodec) IsEmpty 

func (LiteTopicSpecPartitionConfigCodec) IsEmpty(ptr unsafe.Pointer) bool

type LiteTopicSpecReservationConfig added in v0.4.0 

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

func (*LiteTopicSpecReservationConfig) DeepCopy added in v0.4.0 

func (in *LiteTopicSpecReservationConfig) DeepCopy() *LiteTopicSpecReservationConfig

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

func (*LiteTopicSpecReservationConfig) DeepCopyInto added in v0.4.0 

func (in *LiteTopicSpecReservationConfig) DeepCopyInto(out *LiteTopicSpecReservationConfig)

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

type LiteTopicSpecReservationConfigCodec added in v0.4.0 

type LiteTopicSpecReservationConfigCodec struct {
}

+k8s:deepcopy-gen=false

func (LiteTopicSpecReservationConfigCodec) Decode added in v0.4.0 

func (LiteTopicSpecReservationConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (LiteTopicSpecReservationConfigCodec) Encode added in v0.4.0 

func (LiteTopicSpecReservationConfigCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (LiteTopicSpecReservationConfigCodec) IsEmpty added in v0.4.0 

func (LiteTopicSpecReservationConfigCodec) IsEmpty(ptr unsafe.Pointer) bool

type LiteTopicSpecResource 

type LiteTopicSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// Name of the topic.
	Name *string `json:"name" tf:"name"`
	// The settings for this topic's partitions.
	// +optional
	PartitionConfig *LiteTopicSpecPartitionConfig `json:"partitionConfig,omitempty" tf:"partition_config"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The region of the pubsub lite topic.
	// +optional
	Region *string `json:"region,omitempty" tf:"region"`
	// The settings for this topic's Reservation usage.
	// +optional
	ReservationConfig *LiteTopicSpecReservationConfig `json:"reservationConfig,omitempty" tf:"reservation_config"`
	// The settings for a topic's message retention.
	// +optional
	RetentionConfig *LiteTopicSpecRetentionConfig `json:"retentionConfig,omitempty" tf:"retention_config"`
	// The zone of the pubsub lite topic.
	// +optional
	Zone *string `json:"zone,omitempty" tf:"zone"`
}

func (*LiteTopicSpecResource) DeepCopy 

func (in *LiteTopicSpecResource) DeepCopy() *LiteTopicSpecResource

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

func (*LiteTopicSpecResource) DeepCopyInto 

func (in *LiteTopicSpecResource) DeepCopyInto(out *LiteTopicSpecResource)

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

type LiteTopicSpecRetentionConfig 

type LiteTopicSpecRetentionConfig struct {
	// The provisioned storage, in bytes, per partition. If the number of bytes stored
	// in any of the topic's partitions grows beyond this value, older messages will be
	// dropped to make room for newer ones, regardless of the value of period.
	PerPartitionBytes *string `json:"perPartitionBytes" tf:"per_partition_bytes"`
	// 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".
	// +optional
	Period *string `json:"period,omitempty" tf:"period"`
}

func (*LiteTopicSpecRetentionConfig) DeepCopy 

func (in *LiteTopicSpecRetentionConfig) DeepCopy() *LiteTopicSpecRetentionConfig

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

func (*LiteTopicSpecRetentionConfig) DeepCopyInto 

func (in *LiteTopicSpecRetentionConfig) DeepCopyInto(out *LiteTopicSpecRetentionConfig)

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

type LiteTopicSpecRetentionConfigCodec 

type LiteTopicSpecRetentionConfigCodec struct {
}

+k8s:deepcopy-gen=false

func (LiteTopicSpecRetentionConfigCodec) Decode 

func (LiteTopicSpecRetentionConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (LiteTopicSpecRetentionConfigCodec) Encode 

func (LiteTopicSpecRetentionConfigCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (LiteTopicSpecRetentionConfigCodec) IsEmpty 

func (LiteTopicSpecRetentionConfigCodec) IsEmpty(ptr unsafe.Pointer) bool

type LiteTopicStatus 

type LiteTopicStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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 Schema 

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

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

func (r *Schema) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Schema) ValidateCreate 

func (r *Schema) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Schema) ValidateDelete 

func (r *Schema) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Schema) ValidateUpdate 

func (r *Schema) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SchemaList 

type SchemaList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Schema CRD objects
	Items []Schema `json:"items,omitempty"`
}

SchemaList is 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.

type SchemaSpec 

type SchemaSpec struct {
	State *SchemaSpecResource `json:"state,omitempty" tf:"-"`

	Resource SchemaSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 SchemaSpecResource 

type SchemaSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// 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.
	// +optional
	Definition *string `json:"definition,omitempty" tf:"definition"`
	// The ID to use for the schema, which will become the final component of the schema's resource name.
	Name *string `json:"name" tf:"name"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// The type of the schema definition Default value: "TYPE_UNSPECIFIED" Possible values: ["TYPE_UNSPECIFIED", "PROTOCOL_BUFFER", "AVRO"]
	// +optional
	Type *string `json:"type,omitempty" tf:"type"`
}

func (*SchemaSpecResource) DeepCopy 

func (in *SchemaSpecResource) DeepCopy() *SchemaSpecResource

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

func (*SchemaSpecResource) DeepCopyInto 

func (in *SchemaSpecResource) DeepCopyInto(out *SchemaSpecResource)

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

type SchemaStatus 

type SchemaStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionSpec   `json:"spec,omitempty"`
	Status            SubscriptionStatus `json:"status,omitempty"`
}

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

func (r *Subscription) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Subscription) ValidateCreate 

func (r *Subscription) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Subscription) ValidateDelete 

func (r *Subscription) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Subscription) ValidateUpdate 

func (r *Subscription) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SubscriptionIamBinding 

type SubscriptionIamBinding struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionIamBindingSpec   `json:"spec,omitempty"`
	Status            SubscriptionIamBindingStatus `json:"status,omitempty"`
}

func (*SubscriptionIamBinding) DeepCopy 

func (in *SubscriptionIamBinding) DeepCopy() *SubscriptionIamBinding

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

func (*SubscriptionIamBinding) DeepCopyInto 

func (in *SubscriptionIamBinding) DeepCopyInto(out *SubscriptionIamBinding)

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

func (*SubscriptionIamBinding) DeepCopyObject 

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

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

func (*SubscriptionIamBinding) SetupWebhookWithManager 

func (r *SubscriptionIamBinding) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SubscriptionIamBinding) ValidateCreate 

func (r *SubscriptionIamBinding) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamBinding) ValidateDelete 

func (r *SubscriptionIamBinding) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamBinding) ValidateUpdate 

func (r *SubscriptionIamBinding) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SubscriptionIamBindingList 

type SubscriptionIamBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of SubscriptionIamBinding CRD objects
	Items []SubscriptionIamBinding `json:"items,omitempty"`
}

SubscriptionIamBindingList is a list of SubscriptionIamBindings

func (*SubscriptionIamBindingList) DeepCopy 

func (in *SubscriptionIamBindingList) DeepCopy() *SubscriptionIamBindingList

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

func (*SubscriptionIamBindingList) DeepCopyInto 

func (in *SubscriptionIamBindingList) DeepCopyInto(out *SubscriptionIamBindingList)

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

func (*SubscriptionIamBindingList) DeepCopyObject 

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

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

type SubscriptionIamBindingSpec 

type SubscriptionIamBindingSpec struct {
	State *SubscriptionIamBindingSpecResource `json:"state,omitempty" tf:"-"`

	Resource SubscriptionIamBindingSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*SubscriptionIamBindingSpec) DeepCopy 

func (in *SubscriptionIamBindingSpec) DeepCopy() *SubscriptionIamBindingSpec

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

func (*SubscriptionIamBindingSpec) DeepCopyInto 

func (in *SubscriptionIamBindingSpec) DeepCopyInto(out *SubscriptionIamBindingSpec)

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

type SubscriptionIamBindingSpecCondition 

type SubscriptionIamBindingSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

func (*SubscriptionIamBindingSpecCondition) DeepCopy 

func (in *SubscriptionIamBindingSpecCondition) DeepCopy() *SubscriptionIamBindingSpecCondition

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

func (*SubscriptionIamBindingSpecCondition) DeepCopyInto 

func (in *SubscriptionIamBindingSpecCondition) DeepCopyInto(out *SubscriptionIamBindingSpecCondition)

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

type SubscriptionIamBindingSpecConditionCodec 

type SubscriptionIamBindingSpecConditionCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionIamBindingSpecConditionCodec) Decode 

func (SubscriptionIamBindingSpecConditionCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionIamBindingSpecConditionCodec) Encode 

func (SubscriptionIamBindingSpecConditionCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionIamBindingSpecConditionCodec) IsEmpty 

func (SubscriptionIamBindingSpecConditionCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionIamBindingSpecResource 

type SubscriptionIamBindingSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *SubscriptionIamBindingSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag    *string  `json:"etag,omitempty" tf:"etag"`
	Members []string `json:"members" tf:"members"`
	// +optional
	Project      *string `json:"project,omitempty" tf:"project"`
	Role         *string `json:"role" tf:"role"`
	Subscription *string `json:"subscription" tf:"subscription"`
}

func (*SubscriptionIamBindingSpecResource) DeepCopy 

func (in *SubscriptionIamBindingSpecResource) DeepCopy() *SubscriptionIamBindingSpecResource

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

func (*SubscriptionIamBindingSpecResource) DeepCopyInto 

func (in *SubscriptionIamBindingSpecResource) DeepCopyInto(out *SubscriptionIamBindingSpecResource)

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

type SubscriptionIamBindingStatus 

type SubscriptionIamBindingStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*SubscriptionIamBindingStatus) DeepCopy 

func (in *SubscriptionIamBindingStatus) DeepCopy() *SubscriptionIamBindingStatus

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

func (*SubscriptionIamBindingStatus) DeepCopyInto 

func (in *SubscriptionIamBindingStatus) DeepCopyInto(out *SubscriptionIamBindingStatus)

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

type SubscriptionIamMember 

type SubscriptionIamMember struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionIamMemberSpec   `json:"spec,omitempty"`
	Status            SubscriptionIamMemberStatus `json:"status,omitempty"`
}

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

func (r *SubscriptionIamMember) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SubscriptionIamMember) ValidateCreate 

func (r *SubscriptionIamMember) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamMember) ValidateDelete 

func (r *SubscriptionIamMember) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamMember) ValidateUpdate 

func (r *SubscriptionIamMember) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SubscriptionIamMemberList 

type SubscriptionIamMemberList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of SubscriptionIamMember CRD objects
	Items []SubscriptionIamMember `json:"items,omitempty"`
}

SubscriptionIamMemberList is 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.

type SubscriptionIamMemberSpec 

type SubscriptionIamMemberSpec struct {
	State *SubscriptionIamMemberSpecResource `json:"state,omitempty" tf:"-"`

	Resource SubscriptionIamMemberSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 SubscriptionIamMemberSpecCondition 

type SubscriptionIamMemberSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

func (*SubscriptionIamMemberSpecCondition) DeepCopy 

func (in *SubscriptionIamMemberSpecCondition) DeepCopy() *SubscriptionIamMemberSpecCondition

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

func (*SubscriptionIamMemberSpecCondition) DeepCopyInto 

func (in *SubscriptionIamMemberSpecCondition) DeepCopyInto(out *SubscriptionIamMemberSpecCondition)

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

type SubscriptionIamMemberSpecConditionCodec 

type SubscriptionIamMemberSpecConditionCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionIamMemberSpecConditionCodec) Decode 

func (SubscriptionIamMemberSpecConditionCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionIamMemberSpecConditionCodec) Encode 

func (SubscriptionIamMemberSpecConditionCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionIamMemberSpecConditionCodec) IsEmpty 

func (SubscriptionIamMemberSpecConditionCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionIamMemberSpecResource 

type SubscriptionIamMemberSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *SubscriptionIamMemberSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag   *string `json:"etag,omitempty" tf:"etag"`
	Member *string `json:"member" tf:"member"`
	// +optional
	Project      *string `json:"project,omitempty" tf:"project"`
	Role         *string `json:"role" tf:"role"`
	Subscription *string `json:"subscription" tf:"subscription"`
}

func (*SubscriptionIamMemberSpecResource) DeepCopy 

func (in *SubscriptionIamMemberSpecResource) DeepCopy() *SubscriptionIamMemberSpecResource

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

func (*SubscriptionIamMemberSpecResource) DeepCopyInto 

func (in *SubscriptionIamMemberSpecResource) DeepCopyInto(out *SubscriptionIamMemberSpecResource)

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

type SubscriptionIamMemberStatus 

type SubscriptionIamMemberStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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 SubscriptionIamPolicy 

type SubscriptionIamPolicy struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionIamPolicySpec   `json:"spec,omitempty"`
	Status            SubscriptionIamPolicyStatus `json:"status,omitempty"`
}

func (*SubscriptionIamPolicy) DeepCopy 

func (in *SubscriptionIamPolicy) DeepCopy() *SubscriptionIamPolicy

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

func (*SubscriptionIamPolicy) DeepCopyInto 

func (in *SubscriptionIamPolicy) DeepCopyInto(out *SubscriptionIamPolicy)

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

func (*SubscriptionIamPolicy) DeepCopyObject 

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

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

func (*SubscriptionIamPolicy) SetupWebhookWithManager 

func (r *SubscriptionIamPolicy) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SubscriptionIamPolicy) ValidateCreate 

func (r *SubscriptionIamPolicy) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamPolicy) ValidateDelete 

func (r *SubscriptionIamPolicy) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SubscriptionIamPolicy) ValidateUpdate 

func (r *SubscriptionIamPolicy) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SubscriptionIamPolicyList 

type SubscriptionIamPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of SubscriptionIamPolicy CRD objects
	Items []SubscriptionIamPolicy `json:"items,omitempty"`
}

SubscriptionIamPolicyList is a list of SubscriptionIamPolicys

func (*SubscriptionIamPolicyList) DeepCopy 

func (in *SubscriptionIamPolicyList) DeepCopy() *SubscriptionIamPolicyList

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

func (*SubscriptionIamPolicyList) DeepCopyInto 

func (in *SubscriptionIamPolicyList) DeepCopyInto(out *SubscriptionIamPolicyList)

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

func (*SubscriptionIamPolicyList) DeepCopyObject 

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

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

type SubscriptionIamPolicySpec 

type SubscriptionIamPolicySpec struct {
	State *SubscriptionIamPolicySpecResource `json:"state,omitempty" tf:"-"`

	Resource SubscriptionIamPolicySpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*SubscriptionIamPolicySpec) DeepCopy 

func (in *SubscriptionIamPolicySpec) DeepCopy() *SubscriptionIamPolicySpec

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

func (*SubscriptionIamPolicySpec) DeepCopyInto 

func (in *SubscriptionIamPolicySpec) DeepCopyInto(out *SubscriptionIamPolicySpec)

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

type SubscriptionIamPolicySpecResource 

type SubscriptionIamPolicySpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Etag       *string `json:"etag,omitempty" tf:"etag"`
	PolicyData *string `json:"policyData" tf:"policy_data"`
	// +optional
	Project      *string `json:"project,omitempty" tf:"project"`
	Subscription *string `json:"subscription" tf:"subscription"`
}

func (*SubscriptionIamPolicySpecResource) DeepCopy 

func (in *SubscriptionIamPolicySpecResource) DeepCopy() *SubscriptionIamPolicySpecResource

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

func (*SubscriptionIamPolicySpecResource) DeepCopyInto 

func (in *SubscriptionIamPolicySpecResource) DeepCopyInto(out *SubscriptionIamPolicySpecResource)

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

type SubscriptionIamPolicyStatus 

type SubscriptionIamPolicyStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*SubscriptionIamPolicyStatus) DeepCopy 

func (in *SubscriptionIamPolicyStatus) DeepCopy() *SubscriptionIamPolicyStatus

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

func (*SubscriptionIamPolicyStatus) DeepCopyInto 

func (in *SubscriptionIamPolicyStatus) DeepCopyInto(out *SubscriptionIamPolicyStatus)

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 is a list of Subscription CRD objects
	Items []Subscription `json:"items,omitempty"`
}

SubscriptionList is 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.

type SubscriptionSpec 

type SubscriptionSpec struct {
	State *SubscriptionSpecResource `json:"state,omitempty" tf:"-"`

	Resource SubscriptionSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 SubscriptionSpecDeadLetterPolicy 

type SubscriptionSpecDeadLetterPolicy 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.
	// +optional
	DeadLetterTopic *string `json:"deadLetterTopic,omitempty" tf:"dead_letter_topic"`
	// 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.
	// +optional
	MaxDeliveryAttempts *int64 `json:"maxDeliveryAttempts,omitempty" tf:"max_delivery_attempts"`
}

func (*SubscriptionSpecDeadLetterPolicy) DeepCopy 

func (in *SubscriptionSpecDeadLetterPolicy) DeepCopy() *SubscriptionSpecDeadLetterPolicy

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

func (*SubscriptionSpecDeadLetterPolicy) DeepCopyInto 

func (in *SubscriptionSpecDeadLetterPolicy) DeepCopyInto(out *SubscriptionSpecDeadLetterPolicy)

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

type SubscriptionSpecDeadLetterPolicyCodec 

type SubscriptionSpecDeadLetterPolicyCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionSpecDeadLetterPolicyCodec) Decode 

func (SubscriptionSpecDeadLetterPolicyCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionSpecDeadLetterPolicyCodec) Encode 

func (SubscriptionSpecDeadLetterPolicyCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionSpecDeadLetterPolicyCodec) IsEmpty 

func (SubscriptionSpecDeadLetterPolicyCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionSpecExpirationPolicy 

type SubscriptionSpecExpirationPolicy 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".
	Ttl *string `json:"ttl" tf:"ttl"`
}

func (*SubscriptionSpecExpirationPolicy) DeepCopy 

func (in *SubscriptionSpecExpirationPolicy) DeepCopy() *SubscriptionSpecExpirationPolicy

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

func (*SubscriptionSpecExpirationPolicy) DeepCopyInto 

func (in *SubscriptionSpecExpirationPolicy) DeepCopyInto(out *SubscriptionSpecExpirationPolicy)

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

type SubscriptionSpecExpirationPolicyCodec 

type SubscriptionSpecExpirationPolicyCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionSpecExpirationPolicyCodec) Decode 

func (SubscriptionSpecExpirationPolicyCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionSpecExpirationPolicyCodec) Encode 

func (SubscriptionSpecExpirationPolicyCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionSpecExpirationPolicyCodec) IsEmpty 

func (SubscriptionSpecExpirationPolicyCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionSpecPushConfig 

type SubscriptionSpecPushConfig 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:
	//
	// - v1beta1: uses the push format defined in the v1beta1 Pub/Sub API.
	// - v1 or v1beta2: uses the push format defined in the v1 Pub/Sub API.
	// +optional
	Attributes *map[string]string `json:"attributes,omitempty" tf:"attributes"`
	// If specified, Pub/Sub will generate and attach an OIDC JWT token as
	// an Authorization header in the HTTP request for every pushed message.
	// +optional
	OidcToken *SubscriptionSpecPushConfigOidcToken `json:"oidcToken,omitempty" tf:"oidc_token"`
	// A URL locating the endpoint to which messages should be pushed.
	// For example, a Webhook endpoint might use
	// "https://example.com/push".
	PushEndpoint *string `json:"pushEndpoint" tf:"push_endpoint"`
}

func (*SubscriptionSpecPushConfig) DeepCopy 

func (in *SubscriptionSpecPushConfig) DeepCopy() *SubscriptionSpecPushConfig

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

func (*SubscriptionSpecPushConfig) DeepCopyInto 

func (in *SubscriptionSpecPushConfig) DeepCopyInto(out *SubscriptionSpecPushConfig)

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

type SubscriptionSpecPushConfigCodec 

type SubscriptionSpecPushConfigCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionSpecPushConfigCodec) Decode 

func (SubscriptionSpecPushConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionSpecPushConfigCodec) Encode 

func (SubscriptionSpecPushConfigCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionSpecPushConfigCodec) IsEmpty 

func (SubscriptionSpecPushConfigCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionSpecPushConfigOidcToken 

type SubscriptionSpecPushConfigOidcToken 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.
	// +optional
	Audience *string `json:"audience,omitempty" tf:"audience"`
	// Service account email to be used for generating the OIDC token.
	// The caller (for subscriptions.create, subscriptions.patch, and
	// subscriptions.modifyPushConfig RPCs) must have the
	// iam.serviceAccounts.actAs permission for the service account.
	ServiceAccountEmail *string `json:"serviceAccountEmail" tf:"service_account_email"`
}

func (*SubscriptionSpecPushConfigOidcToken) DeepCopy 

func (in *SubscriptionSpecPushConfigOidcToken) DeepCopy() *SubscriptionSpecPushConfigOidcToken

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

func (*SubscriptionSpecPushConfigOidcToken) DeepCopyInto 

func (in *SubscriptionSpecPushConfigOidcToken) DeepCopyInto(out *SubscriptionSpecPushConfigOidcToken)

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

type SubscriptionSpecPushConfigOidcTokenCodec 

type SubscriptionSpecPushConfigOidcTokenCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionSpecPushConfigOidcTokenCodec) Decode 

func (SubscriptionSpecPushConfigOidcTokenCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionSpecPushConfigOidcTokenCodec) Encode 

func (SubscriptionSpecPushConfigOidcTokenCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionSpecPushConfigOidcTokenCodec) IsEmpty 

func (SubscriptionSpecPushConfigOidcTokenCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionSpecResource 

type SubscriptionSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// 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.
	// +optional
	AckDeadlineSeconds *int64 `json:"ackDeadlineSeconds,omitempty" tf:"ack_deadline_seconds"`
	// 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.
	// +optional
	DeadLetterPolicy *SubscriptionSpecDeadLetterPolicy `json:"deadLetterPolicy,omitempty" tf:"dead_letter_policy"`
	// 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.
	// +optional
	EnableMessageOrdering *bool `json:"enableMessageOrdering,omitempty" tf:"enable_message_ordering"`
	// 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.
	// +optional
	ExpirationPolicy *SubscriptionSpecExpirationPolicy `json:"expirationPolicy,omitempty" tf:"expiration_policy"`
	// 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.
	// +optional
	Filter *string `json:"filter,omitempty" tf:"filter"`
	// A set of key/value label pairs to assign to this Subscription.
	// +optional
	Labels *map[string]string `json:"labels,omitempty" tf:"labels"`
	// How long to retain unacknowledged messages in the subscription's
	// backlog, from the moment a message is published. If
	// retainAckedMessages 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"'.
	// +optional
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration"`
	// Name of the subscription.
	Name *string `json:"name" tf:"name"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// 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.
	// +optional
	PushConfig *SubscriptionSpecPushConfig `json:"pushConfig,omitempty" tf:"push_config"`
	// 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.
	// +optional
	RetainAckedMessages *bool `json:"retainAckedMessages,omitempty" tf:"retain_acked_messages"`
	// 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
	// +optional
	RetryPolicy *SubscriptionSpecRetryPolicy `json:"retryPolicy,omitempty" tf:"retry_policy"`
	// A reference to a Topic resource.
	Topic *string `json:"topic" tf:"topic"`
}

func (*SubscriptionSpecResource) DeepCopy 

func (in *SubscriptionSpecResource) DeepCopy() *SubscriptionSpecResource

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

func (*SubscriptionSpecResource) DeepCopyInto 

func (in *SubscriptionSpecResource) DeepCopyInto(out *SubscriptionSpecResource)

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

type SubscriptionSpecRetryPolicy 

type SubscriptionSpecRetryPolicy 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".
	// +optional
	MaximumBackoff *string `json:"maximumBackoff,omitempty" tf:"maximum_backoff"`
	// 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".
	// +optional
	MinimumBackoff *string `json:"minimumBackoff,omitempty" tf:"minimum_backoff"`
}

func (*SubscriptionSpecRetryPolicy) DeepCopy 

func (in *SubscriptionSpecRetryPolicy) DeepCopy() *SubscriptionSpecRetryPolicy

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

func (*SubscriptionSpecRetryPolicy) DeepCopyInto 

func (in *SubscriptionSpecRetryPolicy) DeepCopyInto(out *SubscriptionSpecRetryPolicy)

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

type SubscriptionSpecRetryPolicyCodec 

type SubscriptionSpecRetryPolicyCodec struct {
}

+k8s:deepcopy-gen=false

func (SubscriptionSpecRetryPolicyCodec) Decode 

func (SubscriptionSpecRetryPolicyCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (SubscriptionSpecRetryPolicyCodec) Encode 

func (SubscriptionSpecRetryPolicyCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (SubscriptionSpecRetryPolicyCodec) IsEmpty 

func (SubscriptionSpecRetryPolicyCodec) IsEmpty(ptr unsafe.Pointer) bool

type SubscriptionStatus 

type SubscriptionStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicSpec   `json:"spec,omitempty"`
	Status            TopicStatus `json:"status,omitempty"`
}

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

func (r *Topic) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Topic) ValidateCreate 

func (r *Topic) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Topic) ValidateDelete 

func (r *Topic) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Topic) ValidateUpdate 

func (r *Topic) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type TopicIamBinding 

type TopicIamBinding struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicIamBindingSpec   `json:"spec,omitempty"`
	Status            TopicIamBindingStatus `json:"status,omitempty"`
}

func (*TopicIamBinding) DeepCopy 

func (in *TopicIamBinding) DeepCopy() *TopicIamBinding

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

func (*TopicIamBinding) DeepCopyInto 

func (in *TopicIamBinding) DeepCopyInto(out *TopicIamBinding)

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

func (*TopicIamBinding) DeepCopyObject 

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

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

func (*TopicIamBinding) SetupWebhookWithManager 

func (r *TopicIamBinding) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*TopicIamBinding) ValidateCreate 

func (r *TopicIamBinding) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamBinding) ValidateDelete 

func (r *TopicIamBinding) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamBinding) ValidateUpdate 

func (r *TopicIamBinding) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type TopicIamBindingList 

type TopicIamBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of TopicIamBinding CRD objects
	Items []TopicIamBinding `json:"items,omitempty"`
}

TopicIamBindingList is a list of TopicIamBindings

func (*TopicIamBindingList) DeepCopy 

func (in *TopicIamBindingList) DeepCopy() *TopicIamBindingList

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

func (*TopicIamBindingList) DeepCopyInto 

func (in *TopicIamBindingList) DeepCopyInto(out *TopicIamBindingList)

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

func (*TopicIamBindingList) DeepCopyObject 

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

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

type TopicIamBindingSpec 

type TopicIamBindingSpec struct {
	State *TopicIamBindingSpecResource `json:"state,omitempty" tf:"-"`

	Resource TopicIamBindingSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*TopicIamBindingSpec) DeepCopy 

func (in *TopicIamBindingSpec) DeepCopy() *TopicIamBindingSpec

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

func (*TopicIamBindingSpec) DeepCopyInto 

func (in *TopicIamBindingSpec) DeepCopyInto(out *TopicIamBindingSpec)

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

type TopicIamBindingSpecCondition 

type TopicIamBindingSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

func (*TopicIamBindingSpecCondition) DeepCopy 

func (in *TopicIamBindingSpecCondition) DeepCopy() *TopicIamBindingSpecCondition

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

func (*TopicIamBindingSpecCondition) DeepCopyInto 

func (in *TopicIamBindingSpecCondition) DeepCopyInto(out *TopicIamBindingSpecCondition)

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

type TopicIamBindingSpecConditionCodec 

type TopicIamBindingSpecConditionCodec struct {
}

+k8s:deepcopy-gen=false

func (TopicIamBindingSpecConditionCodec) Decode 

func (TopicIamBindingSpecConditionCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (TopicIamBindingSpecConditionCodec) Encode 

func (TopicIamBindingSpecConditionCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (TopicIamBindingSpecConditionCodec) IsEmpty 

func (TopicIamBindingSpecConditionCodec) IsEmpty(ptr unsafe.Pointer) bool

type TopicIamBindingSpecResource 

type TopicIamBindingSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *TopicIamBindingSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag    *string  `json:"etag,omitempty" tf:"etag"`
	Members []string `json:"members" tf:"members"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	Role    *string `json:"role" tf:"role"`
	Topic   *string `json:"topic" tf:"topic"`
}

func (*TopicIamBindingSpecResource) DeepCopy 

func (in *TopicIamBindingSpecResource) DeepCopy() *TopicIamBindingSpecResource

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

func (*TopicIamBindingSpecResource) DeepCopyInto 

func (in *TopicIamBindingSpecResource) DeepCopyInto(out *TopicIamBindingSpecResource)

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

type TopicIamBindingStatus 

type TopicIamBindingStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*TopicIamBindingStatus) DeepCopy 

func (in *TopicIamBindingStatus) DeepCopy() *TopicIamBindingStatus

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

func (*TopicIamBindingStatus) DeepCopyInto 

func (in *TopicIamBindingStatus) DeepCopyInto(out *TopicIamBindingStatus)

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

type TopicIamMember 

type TopicIamMember struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicIamMemberSpec   `json:"spec,omitempty"`
	Status            TopicIamMemberStatus `json:"status,omitempty"`
}

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

func (r *TopicIamMember) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*TopicIamMember) ValidateCreate 

func (r *TopicIamMember) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamMember) ValidateDelete 

func (r *TopicIamMember) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamMember) ValidateUpdate 

func (r *TopicIamMember) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type TopicIamMemberList 

type TopicIamMemberList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of TopicIamMember CRD objects
	Items []TopicIamMember `json:"items,omitempty"`
}

TopicIamMemberList is 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.

type TopicIamMemberSpec 

type TopicIamMemberSpec struct {
	State *TopicIamMemberSpecResource `json:"state,omitempty" tf:"-"`

	Resource TopicIamMemberSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 TopicIamMemberSpecCondition 

type TopicIamMemberSpecCondition struct {
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	Expression  *string `json:"expression" tf:"expression"`
	Title       *string `json:"title" tf:"title"`
}

func (*TopicIamMemberSpecCondition) DeepCopy 

func (in *TopicIamMemberSpecCondition) DeepCopy() *TopicIamMemberSpecCondition

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

func (*TopicIamMemberSpecCondition) DeepCopyInto 

func (in *TopicIamMemberSpecCondition) DeepCopyInto(out *TopicIamMemberSpecCondition)

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

type TopicIamMemberSpecConditionCodec 

type TopicIamMemberSpecConditionCodec struct {
}

+k8s:deepcopy-gen=false

func (TopicIamMemberSpecConditionCodec) Decode 

func (TopicIamMemberSpecConditionCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (TopicIamMemberSpecConditionCodec) Encode 

func (TopicIamMemberSpecConditionCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (TopicIamMemberSpecConditionCodec) IsEmpty 

func (TopicIamMemberSpecConditionCodec) IsEmpty(ptr unsafe.Pointer) bool

type TopicIamMemberSpecResource 

type TopicIamMemberSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Condition *TopicIamMemberSpecCondition `json:"condition,omitempty" tf:"condition"`
	// +optional
	Etag   *string `json:"etag,omitempty" tf:"etag"`
	Member *string `json:"member" tf:"member"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	Role    *string `json:"role" tf:"role"`
	Topic   *string `json:"topic" tf:"topic"`
}

func (*TopicIamMemberSpecResource) DeepCopy 

func (in *TopicIamMemberSpecResource) DeepCopy() *TopicIamMemberSpecResource

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

func (*TopicIamMemberSpecResource) DeepCopyInto 

func (in *TopicIamMemberSpecResource) DeepCopyInto(out *TopicIamMemberSpecResource)

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

type TopicIamMemberStatus 

type TopicIamMemberStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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 TopicIamPolicy 

type TopicIamPolicy struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicIamPolicySpec   `json:"spec,omitempty"`
	Status            TopicIamPolicyStatus `json:"status,omitempty"`
}

func (*TopicIamPolicy) DeepCopy 

func (in *TopicIamPolicy) DeepCopy() *TopicIamPolicy

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

func (*TopicIamPolicy) DeepCopyInto 

func (in *TopicIamPolicy) DeepCopyInto(out *TopicIamPolicy)

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

func (*TopicIamPolicy) DeepCopyObject 

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

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

func (*TopicIamPolicy) SetupWebhookWithManager 

func (r *TopicIamPolicy) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*TopicIamPolicy) ValidateCreate 

func (r *TopicIamPolicy) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamPolicy) ValidateDelete 

func (r *TopicIamPolicy) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*TopicIamPolicy) ValidateUpdate 

func (r *TopicIamPolicy) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type TopicIamPolicyList 

type TopicIamPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of TopicIamPolicy CRD objects
	Items []TopicIamPolicy `json:"items,omitempty"`
}

TopicIamPolicyList is a list of TopicIamPolicys

func (*TopicIamPolicyList) DeepCopy 

func (in *TopicIamPolicyList) DeepCopy() *TopicIamPolicyList

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

func (*TopicIamPolicyList) DeepCopyInto 

func (in *TopicIamPolicyList) DeepCopyInto(out *TopicIamPolicyList)

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

func (*TopicIamPolicyList) DeepCopyObject 

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

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

type TopicIamPolicySpec 

type TopicIamPolicySpec struct {
	State *TopicIamPolicySpecResource `json:"state,omitempty" tf:"-"`

	Resource TopicIamPolicySpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*TopicIamPolicySpec) DeepCopy 

func (in *TopicIamPolicySpec) DeepCopy() *TopicIamPolicySpec

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

func (*TopicIamPolicySpec) DeepCopyInto 

func (in *TopicIamPolicySpec) DeepCopyInto(out *TopicIamPolicySpec)

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

type TopicIamPolicySpecResource 

type TopicIamPolicySpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Etag       *string `json:"etag,omitempty" tf:"etag"`
	PolicyData *string `json:"policyData" tf:"policy_data"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	Topic   *string `json:"topic" tf:"topic"`
}

func (*TopicIamPolicySpecResource) DeepCopy 

func (in *TopicIamPolicySpecResource) DeepCopy() *TopicIamPolicySpecResource

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

func (*TopicIamPolicySpecResource) DeepCopyInto 

func (in *TopicIamPolicySpecResource) DeepCopyInto(out *TopicIamPolicySpecResource)

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

type TopicIamPolicyStatus 

type TopicIamPolicyStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*TopicIamPolicyStatus) DeepCopy 

func (in *TopicIamPolicyStatus) DeepCopy() *TopicIamPolicyStatus

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

func (*TopicIamPolicyStatus) DeepCopyInto 

func (in *TopicIamPolicyStatus) DeepCopyInto(out *TopicIamPolicyStatus)

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 is a list of Topic CRD objects
	Items []Topic `json:"items,omitempty"`
}

TopicList is 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.

type TopicSpec 

type TopicSpec struct {
	State *TopicSpecResource `json:"state,omitempty" tf:"-"`

	Resource TopicSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 TopicSpecMessageStoragePolicy 

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

func (*TopicSpecMessageStoragePolicy) DeepCopy 

func (in *TopicSpecMessageStoragePolicy) DeepCopy() *TopicSpecMessageStoragePolicy

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

func (*TopicSpecMessageStoragePolicy) DeepCopyInto 

func (in *TopicSpecMessageStoragePolicy) DeepCopyInto(out *TopicSpecMessageStoragePolicy)

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

type TopicSpecMessageStoragePolicyCodec 

type TopicSpecMessageStoragePolicyCodec struct {
}

+k8s:deepcopy-gen=false

func (TopicSpecMessageStoragePolicyCodec) Decode 

func (TopicSpecMessageStoragePolicyCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (TopicSpecMessageStoragePolicyCodec) Encode 

func (TopicSpecMessageStoragePolicyCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (TopicSpecMessageStoragePolicyCodec) IsEmpty 

func (TopicSpecMessageStoragePolicyCodec) IsEmpty(ptr unsafe.Pointer) bool

type TopicSpecResource 

type TopicSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// The resource name of the Cloud KMS CryptoKey to be used to protect access
	// to messages published on this topic. Your project's PubSub service account
	// ('service-{{PROJECT_NUMBER}}@gcp-sa-pubsub.iam.gserviceaccount.com') must have
	// 'roles/cloudkms.cryptoKeyEncrypterDecrypter' to use this feature.
	// The expected format is 'projects/*/locations/*/keyRings/*/cryptoKeys/*'
	// +optional
	KmsKeyName *string `json:"kmsKeyName,omitempty" tf:"kms_key_name"`
	// A set of key/value label pairs to assign to this Topic.
	// +optional
	Labels *map[string]string `json:"labels,omitempty" tf:"labels"`
	// 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.
	// +optional
	MessageRetentionDuration *string `json:"messageRetentionDuration,omitempty" tf:"message_retention_duration"`
	// 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.
	// +optional
	MessageStoragePolicy *TopicSpecMessageStoragePolicy `json:"messageStoragePolicy,omitempty" tf:"message_storage_policy"`
	// Name of the topic.
	Name *string `json:"name" tf:"name"`
	// +optional
	Project *string `json:"project,omitempty" tf:"project"`
	// Settings for validating messages published against a schema.
	// +optional
	SchemaSettings *TopicSpecSchemaSettings `json:"schemaSettings,omitempty" tf:"schema_settings"`
}

func (*TopicSpecResource) DeepCopy 

func (in *TopicSpecResource) DeepCopy() *TopicSpecResource

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

func (*TopicSpecResource) DeepCopyInto 

func (in *TopicSpecResource) DeepCopyInto(out *TopicSpecResource)

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

type TopicSpecSchemaSettings 

type TopicSpecSchemaSettings struct {
	// The encoding of messages validated against schema. Default value: "ENCODING_UNSPECIFIED" Possible values: ["ENCODING_UNSPECIFIED", "JSON", "BINARY"]
	// +optional
	Encoding *string `json:"encoding,omitempty" tf:"encoding"`
	// The name of the schema that messages published should be
	// validated against. Format is projects/{project}/schemas/{schema}.
	// The value of this field will be _deleted-schema_
	// if the schema has been deleted.
	Schema *string `json:"schema" tf:"schema"`
}

func (*TopicSpecSchemaSettings) DeepCopy 

func (in *TopicSpecSchemaSettings) DeepCopy() *TopicSpecSchemaSettings

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

func (*TopicSpecSchemaSettings) DeepCopyInto 

func (in *TopicSpecSchemaSettings) DeepCopyInto(out *TopicSpecSchemaSettings)

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

type TopicSpecSchemaSettingsCodec 

type TopicSpecSchemaSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (TopicSpecSchemaSettingsCodec) Decode 

func (TopicSpecSchemaSettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

func (TopicSpecSchemaSettingsCodec) Encode 

func (TopicSpecSchemaSettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (TopicSpecSchemaSettingsCodec) IsEmpty 

func (TopicSpecSchemaSettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

type TopicStatus 

type TopicStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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.