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 (s *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
- type SuperStreamConsumerPodSpec
- type SuperStreamConsumerSpec
- type SuperStreamConsumerStatus
- type SuperStreamReference
Constants ¶
This section is empty.
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 )
Functions ¶
This section is empty.
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 (s *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.
Source Files