v1alpha1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the rabbitmq.com v1alpha1 API group +kubebuilder:object:generate=true +groupName=rabbitmq.com

Index

• Variables
• type SuperStreamConsumer
  • func (in *SuperStreamConsumer) DeepCopy() *SuperStreamConsumer
  • func (in *SuperStreamConsumer) DeepCopyInto(out *SuperStreamConsumer)
  • func (in *SuperStreamConsumer) DeepCopyObject() runtime.Object
  • func (q *SuperStreamConsumer) GroupResource() schema.GroupResource
  • func (r *SuperStreamConsumer) SetupWebhookWithManager(mgr ctrl.Manager) error
  • func (r *SuperStreamConsumer) ValidateCreate() error
  • func (r *SuperStreamConsumer) ValidateDelete() error
  • func (r *SuperStreamConsumer) ValidateUpdate(old runtime.Object) error
• type SuperStreamConsumerList
  • func (in *SuperStreamConsumerList) DeepCopy() *SuperStreamConsumerList
  • func (in *SuperStreamConsumerList) DeepCopyInto(out *SuperStreamConsumerList)
  • func (in *SuperStreamConsumerList) DeepCopyObject() runtime.Object
• type SuperStreamConsumerPodSpec
  • func (in *SuperStreamConsumerPodSpec) DeepCopy() *SuperStreamConsumerPodSpec
  • func (in *SuperStreamConsumerPodSpec) DeepCopyInto(out *SuperStreamConsumerPodSpec)
• type SuperStreamConsumerSpec
  • func (in *SuperStreamConsumerSpec) DeepCopy() *SuperStreamConsumerSpec
  • func (in *SuperStreamConsumerSpec) DeepCopyInto(out *SuperStreamConsumerSpec)
• type SuperStreamConsumerStatus
  • func (in *SuperStreamConsumerStatus) DeepCopy() *SuperStreamConsumerStatus
  • func (in *SuperStreamConsumerStatus) DeepCopyInto(out *SuperStreamConsumerStatus)
• type SuperStreamReference
  • func (in *SuperStreamReference) DeepCopy() *SuperStreamReference
  • func (in *SuperStreamReference) DeepCopyInto(out *SuperStreamReference)

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "rabbitmq.com", Version: "v1alpha1"}

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Types

type SuperStreamConsumer

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

	Spec   SuperStreamConsumerSpec   `json:"spec,omitempty"`
	Status SuperStreamConsumerStatus `json:"status,omitempty"`
}

SuperStreamConsumer is the Schema for the superstreamconsumers API

func (*SuperStreamConsumer) DeepCopy

func (in *SuperStreamConsumer) DeepCopy() *SuperStreamConsumer

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

func (*SuperStreamConsumer) DeepCopyInto

func (in *SuperStreamConsumer) DeepCopyInto(out *SuperStreamConsumer)

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

func (*SuperStreamConsumer) DeepCopyObject

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

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

func (*SuperStreamConsumer) GroupResource

func (q *SuperStreamConsumer) GroupResource() schema.GroupResource

func (*SuperStreamConsumer) SetupWebhookWithManager

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

func (*SuperStreamConsumer) ValidateCreate

func (r *SuperStreamConsumer) ValidateCreate() error

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

func (*SuperStreamConsumer) ValidateDelete

func (r *SuperStreamConsumer) ValidateDelete() error

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

func (*SuperStreamConsumer) ValidateUpdate

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

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

type SuperStreamConsumerList

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

SuperStreamConsumerList contains a list of SuperStreamConsumer

func (*SuperStreamConsumerList) DeepCopy

func (in *SuperStreamConsumerList) DeepCopy() *SuperStreamConsumerList

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

func (*SuperStreamConsumerList) DeepCopyInto

func (in *SuperStreamConsumerList) DeepCopyInto(out *SuperStreamConsumerList)

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

func (*SuperStreamConsumerList) DeepCopyObject

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

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

type SuperStreamConsumerPodSpec

type SuperStreamConsumerPodSpec struct {
	// Default defines the PodSpec to use for all consumer Pods, if no routing key-specific PodSpec is provided.
	// +kubebuilder:validation:Optional
	Default *corev1.PodSpec `json:"default,omitempty"`
	// PerRoutingKey maps PodsSpecs to specific routing keys. If a consumer is spun up for a SuperStream partition,
	// and the routing key for that partition matches an entry in PerRoutingKey, that PodSpec will be used for the
	// consumer Pod; otherwise the default PodSpec is used.
	// +kubebuilder:validation:Optional
	PerRoutingKey map[string]*corev1.PodSpec `json:"perRoutingKey,omitempty"`
}

func (*SuperStreamConsumerPodSpec) DeepCopy

func (in *SuperStreamConsumerPodSpec) DeepCopy() *SuperStreamConsumerPodSpec

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

func (*SuperStreamConsumerPodSpec) DeepCopyInto

func (in *SuperStreamConsumerPodSpec) DeepCopyInto(out *SuperStreamConsumerPodSpec)

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

type SuperStreamConsumerSpec

type SuperStreamConsumerSpec struct {
	// Reference to the SuperStream that the SuperStreamConsumer will consume from, in the same namespace.
	// Required property.
	// +kubebuilder:validation:Required
	SuperStreamReference SuperStreamReference `json:"superStreamReference"`
	// ConsumerPodSpec defines the PodSpecs to use for any consumer Pods that are created for the SuperStream.
	// +kubebuilder:validation:Required
	ConsumerPodSpec SuperStreamConsumerPodSpec `json:"consumerPodSpec"`
}

SuperStreamConsumerSpec defines the desired state of SuperStreamConsumer

func (*SuperStreamConsumerSpec) DeepCopy

func (in *SuperStreamConsumerSpec) DeepCopy() *SuperStreamConsumerSpec

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

func (*SuperStreamConsumerSpec) DeepCopyInto

func (in *SuperStreamConsumerSpec) DeepCopyInto(out *SuperStreamConsumerSpec)

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

type SuperStreamConsumerStatus

type SuperStreamConsumerStatus struct {
	// observedGeneration is the most recent successful generation observed for this SuperStreamConsumer. It corresponds to the
	// SuperStreamConsumer's generation, which is updated on mutation by the API Server.
	ObservedGeneration int64                `json:"observedGeneration,omitempty"`
	Conditions         []topology.Condition `json:"conditions,omitempty"`
}

SuperStreamConsumerStatus defines the observed state of SuperStreamConsumer

func (*SuperStreamConsumerStatus) DeepCopy

func (in *SuperStreamConsumerStatus) DeepCopy() *SuperStreamConsumerStatus

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

func (*SuperStreamConsumerStatus) DeepCopyInto

func (in *SuperStreamConsumerStatus) DeepCopyInto(out *SuperStreamConsumerStatus)

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

type SuperStreamReference

type SuperStreamReference struct {
	// The name of the SuperStream to reference.
	// +kubebuilder:validation:Required
	Name string `json:"name"`
	// The namespace of the SuperStream to reference.
	Namespace string `json:"namespace,omitempty"`
}

func (*SuperStreamReference) DeepCopy

func (in *SuperStreamReference) DeepCopy() *SuperStreamReference

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

func (*SuperStreamReference) DeepCopyInto

func (in *SuperStreamReference) DeepCopyInto(out *SuperStreamReference)

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