var (
// SchemeGroupVersion is the group version used to register these objects.
SchemeGroupVersion = schema.GroupVersion{Group: "pubsublite.cnrm.cloud.google.com", Version: "v1beta1"}
// 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(),
}
)
PubSubLiteSubscription is the Schema for the pubsublite API +k8s:openapi-gen=true
type PubSubLiteSubscription struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec PubSubLiteSubscriptionSpec `json:"spec,omitempty"`
Status PubSubLiteSubscriptionStatus `json:"status,omitempty"`
}
func (in *PubSubLiteSubscription) DeepCopy() *PubSubLiteSubscription
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteSubscription.
func (in *PubSubLiteSubscription) DeepCopyInto(out *PubSubLiteSubscription)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PubSubLiteSubscription) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
PubSubLiteSubscriptionList contains a list of PubSubLiteSubscription
type PubSubLiteSubscriptionList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []PubSubLiteSubscription `json:"items"`
}
func (in *PubSubLiteSubscriptionList) DeepCopy() *PubSubLiteSubscriptionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteSubscriptionList.
func (in *PubSubLiteSubscriptionList) DeepCopyInto(out *PubSubLiteSubscriptionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PubSubLiteSubscriptionList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
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 (in *PubSubLiteSubscriptionSpec) DeepCopy() *PubSubLiteSubscriptionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteSubscriptionSpec.
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 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 *int `json:"observedGeneration,omitempty"`
}
func (in *PubSubLiteSubscriptionStatus) DeepCopy() *PubSubLiteSubscriptionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteSubscriptionStatus.
func (in *PubSubLiteSubscriptionStatus) DeepCopyInto(out *PubSubLiteSubscriptionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
PubSubLiteTopic is the Schema for the pubsublite API +k8s:openapi-gen=true
type PubSubLiteTopic struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec PubSubLiteTopicSpec `json:"spec,omitempty"`
Status PubSubLiteTopicStatus `json:"status,omitempty"`
}
func (in *PubSubLiteTopic) DeepCopy() *PubSubLiteTopic
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteTopic.
func (in *PubSubLiteTopic) DeepCopyInto(out *PubSubLiteTopic)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PubSubLiteTopic) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
PubSubLiteTopicList contains a list of PubSubLiteTopic
type PubSubLiteTopicList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []PubSubLiteTopic `json:"items"`
}
func (in *PubSubLiteTopicList) DeepCopy() *PubSubLiteTopicList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteTopicList.
func (in *PubSubLiteTopicList) DeepCopyInto(out *PubSubLiteTopicList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PubSubLiteTopicList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
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 (in *PubSubLiteTopicSpec) DeepCopy() *PubSubLiteTopicSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteTopicSpec.
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 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 *int `json:"observedGeneration,omitempty"`
}
func (in *PubSubLiteTopicStatus) DeepCopy() *PubSubLiteTopicStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubLiteTopicStatus.
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 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 (in *SubscriptionDeliveryConfig) DeepCopy() *SubscriptionDeliveryConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriptionDeliveryConfig.
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 struct {
/* Subscribe throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. */
PublishMibPerSec int `json:"publishMibPerSec"`
/* Publish throughput capacity per partition in MiB/s. Must be >= 4 and <= 16. */
SubscribeMibPerSec int `json:"subscribeMibPerSec"`
}
func (in *TopicCapacity) DeepCopy() *TopicCapacity
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicCapacity.
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 struct {
/* The capacity configuration. */
// +optional
Capacity *TopicCapacity `json:"capacity,omitempty"`
/* The number of partitions in the topic. Must be at least 1. */
Count int `json:"count"`
}
func (in *TopicPartitionConfig) DeepCopy() *TopicPartitionConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicPartitionConfig.
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 struct {
/* The Reservation to use for this topic's throughput capacity. */
// +optional
ThroughputReservation *string `json:"throughputReservation,omitempty"`
}
func (in *TopicReservationConfig) DeepCopy() *TopicReservationConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicReservationConfig.
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 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 (in *TopicRetentionConfig) DeepCopy() *TopicRetentionConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicRetentionConfig.
func (in *TopicRetentionConfig) DeepCopyInto(out *TopicRetentionConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.