v1alpha1

package
v1.125.0 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the pubsublite v1alpha1 API group. +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/pkg/apis/pubsublite +k8s:defaulter-gen=TypeMeta +groupName=pubsublite.cnrm.cloud.google.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is the group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "pubsublite.cnrm.cloud.google.com", Version: "v1alpha1"}

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

	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme

	PubSubLiteSubscriptionGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(PubSubLiteSubscription{}).Name(),
	}

	PubSubLiteTopicGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(PubSubLiteTopic{}).Name(),
	}
)

Functions

This section is empty.

Types

type PubSubLiteSubscription 

type PubSubLiteSubscription struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PubSubLiteSubscriptionSpec   `json:"spec,omitempty"`
	Status PubSubLiteSubscriptionStatus `json:"status,omitempty"`
}

PubSubLiteSubscription is the Schema for the pubsublite API +k8s:openapi-gen=true

func (*PubSubLiteSubscription) DeepCopy 

func (in *PubSubLiteSubscription) DeepCopy() *PubSubLiteSubscription

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

func (*PubSubLiteSubscription) DeepCopyInto 

func (in *PubSubLiteSubscription) DeepCopyInto(out *PubSubLiteSubscription)

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

func (*PubSubLiteSubscription) DeepCopyObject 

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

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

type PubSubLiteSubscriptionList 

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

PubSubLiteSubscriptionList contains a list of PubSubLiteSubscription

func (*PubSubLiteSubscriptionList) DeepCopy 

func (in *PubSubLiteSubscriptionList) DeepCopy() *PubSubLiteSubscriptionList

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

func (*PubSubLiteSubscriptionList) DeepCopyInto 

func (in *PubSubLiteSubscriptionList) DeepCopyInto(out *PubSubLiteSubscriptionList)

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

func (*PubSubLiteSubscriptionList) DeepCopyObject 

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

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

type PubSubLiteSubscriptionSpec 

type PubSubLiteSubscriptionSpec struct {
	/* The settings for this subscription's message delivery. */
	// +optional
	DeliveryConfig *SubscriptionDeliveryConfig `json:"deliveryConfig,omitempty"`

	/* The project that this resource belongs to. */
	ProjectRef v1alpha1.ResourceRef `json:"projectRef"`

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

	/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* Immutable. A reference to a Topic resource. */
	Topic string `json:"topic"`

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

func (*PubSubLiteSubscriptionSpec) DeepCopy 

func (in *PubSubLiteSubscriptionSpec) DeepCopy() *PubSubLiteSubscriptionSpec

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

func (*PubSubLiteSubscriptionSpec) DeepCopyInto 

func (in *PubSubLiteSubscriptionSpec) DeepCopyInto(out *PubSubLiteSubscriptionSpec)

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

type PubSubLiteSubscriptionStatus 

type PubSubLiteSubscriptionStatus struct {
	/* Conditions represent the latest available observations of the
	   PubSubLiteSubscription's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`
}

func (*PubSubLiteSubscriptionStatus) DeepCopy 

func (in *PubSubLiteSubscriptionStatus) DeepCopy() *PubSubLiteSubscriptionStatus

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

func (*PubSubLiteSubscriptionStatus) DeepCopyInto 

func (in *PubSubLiteSubscriptionStatus) DeepCopyInto(out *PubSubLiteSubscriptionStatus)

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

type PubSubLiteTopic 

type PubSubLiteTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PubSubLiteTopicSpec   `json:"spec,omitempty"`
	Status PubSubLiteTopicStatus `json:"status,omitempty"`
}

PubSubLiteTopic is the Schema for the pubsublite API +k8s:openapi-gen=true

func (*PubSubLiteTopic) DeepCopy 

func (in *PubSubLiteTopic) DeepCopy() *PubSubLiteTopic

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

func (*PubSubLiteTopic) DeepCopyInto 

func (in *PubSubLiteTopic) DeepCopyInto(out *PubSubLiteTopic)

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

func (*PubSubLiteTopic) DeepCopyObject 

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

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

type PubSubLiteTopicList 

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

PubSubLiteTopicList contains a list of PubSubLiteTopic

func (*PubSubLiteTopicList) DeepCopy 

func (in *PubSubLiteTopicList) DeepCopy() *PubSubLiteTopicList

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

func (*PubSubLiteTopicList) DeepCopyInto 

func (in *PubSubLiteTopicList) DeepCopyInto(out *PubSubLiteTopicList)

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

func (*PubSubLiteTopicList) DeepCopyObject 

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

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

type PubSubLiteTopicSpec 

type PubSubLiteTopicSpec struct {
	/* The settings for this topic's partitions. */
	// +optional
	PartitionConfig *TopicPartitionConfig `json:"partitionConfig,omitempty"`

	/* The project that this resource belongs to. */
	ProjectRef v1alpha1.ResourceRef `json:"projectRef"`

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

	/* The settings for this topic's Reservation usage. */
	// +optional
	ReservationConfig *TopicReservationConfig `json:"reservationConfig,omitempty"`

	/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* The settings for a topic's message retention. */
	// +optional
	RetentionConfig *TopicRetentionConfig `json:"retentionConfig,omitempty"`

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

func (*PubSubLiteTopicSpec) DeepCopy 

func (in *PubSubLiteTopicSpec) DeepCopy() *PubSubLiteTopicSpec

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

func (*PubSubLiteTopicSpec) DeepCopyInto 

func (in *PubSubLiteTopicSpec) DeepCopyInto(out *PubSubLiteTopicSpec)

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

type PubSubLiteTopicStatus 

type PubSubLiteTopicStatus struct {
	/* Conditions represent the latest available observations of the
	   PubSubLiteTopic's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`
}

func (*PubSubLiteTopicStatus) DeepCopy 

func (in *PubSubLiteTopicStatus) DeepCopy() *PubSubLiteTopicStatus

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

func (*PubSubLiteTopicStatus) DeepCopyInto 

func (in *PubSubLiteTopicStatus) DeepCopyInto(out *PubSubLiteTopicStatus)

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

type SubscriptionDeliveryConfig 

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

func (*SubscriptionDeliveryConfig) DeepCopy 

func (in *SubscriptionDeliveryConfig) DeepCopy() *SubscriptionDeliveryConfig

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

func (*SubscriptionDeliveryConfig) DeepCopyInto 

func (in *SubscriptionDeliveryConfig) DeepCopyInto(out *SubscriptionDeliveryConfig)

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

type TopicCapacity 

type TopicCapacity struct {
	/* Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. */
	PublishMibPerSec int64 `json:"publishMibPerSec"`

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

func (*TopicCapacity) DeepCopy 

func (in *TopicCapacity) DeepCopy() *TopicCapacity

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

func (*TopicCapacity) DeepCopyInto 

func (in *TopicCapacity) DeepCopyInto(out *TopicCapacity)

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

type TopicPartitionConfig 

type TopicPartitionConfig struct {
	/* The capacity configuration. */
	// +optional
	Capacity *TopicCapacity `json:"capacity,omitempty"`

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

func (*TopicPartitionConfig) DeepCopy 

func (in *TopicPartitionConfig) DeepCopy() *TopicPartitionConfig

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

func (*TopicPartitionConfig) DeepCopyInto 

func (in *TopicPartitionConfig) DeepCopyInto(out *TopicPartitionConfig)

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

type TopicReservationConfig 

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

func (*TopicReservationConfig) DeepCopy 

func (in *TopicReservationConfig) DeepCopy() *TopicReservationConfig

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

func (*TopicReservationConfig) DeepCopyInto 

func (in *TopicReservationConfig) DeepCopyInto(out *TopicReservationConfig)

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

type TopicRetentionConfig 

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

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

func (*TopicRetentionConfig) DeepCopy 

func (in *TopicRetentionConfig) DeepCopy() *TopicRetentionConfig

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

func (*TopicRetentionConfig) DeepCopyInto 

func (in *TopicRetentionConfig) DeepCopyInto(out *TopicRetentionConfig)

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.