Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the rabbitmq.com v1alpha1 API group +kubebuilder:object:generate=true +groupName=rabbitmq.com
Index ¶
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type SuperStream
- func (in *SuperStream) DeepCopy() *SuperStream
- func (in *SuperStream) DeepCopyInto(out *SuperStream)
- func (in *SuperStream) DeepCopyObject() runtime.Object
- func (q *SuperStream) GroupResource() schema.GroupResource
- func (s *SuperStream) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (s *SuperStream) ValidateCreate() (admission.Warnings, error)
- func (s *SuperStream) ValidateDelete() (admission.Warnings, error)
- func (s *SuperStream) ValidateUpdate(old runtime.Object) (admission.Warnings, error)
- type SuperStreamList
- type SuperStreamSpec
- type SuperStreamStatus
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "rabbitmq.com", Version: "v1alpha1"} // SchemeGroupVersion is group version used to register these objects // added for generated clientset SchemeGroupVersion = GroupVersion // 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 ¶
func Kind ¶
Kind takes an unqualified kind and returns back a Group qualified GroupKind added for generated clientset
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource added for generated clientset
Types ¶
type SuperStream ¶
type SuperStream struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec SuperStreamSpec `json:"spec,omitempty"`
Status SuperStreamStatus `json:"status,omitempty"`
}
SuperStream is the Schema for the queues API
func (*SuperStream) DeepCopy ¶
func (in *SuperStream) DeepCopy() *SuperStream
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuperStream.
func (*SuperStream) DeepCopyInto ¶
func (in *SuperStream) DeepCopyInto(out *SuperStream)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SuperStream) DeepCopyObject ¶
func (in *SuperStream) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SuperStream) GroupResource ¶
func (q *SuperStream) GroupResource() schema.GroupResource
func (*SuperStream) SetupWebhookWithManager ¶
func (s *SuperStream) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*SuperStream) ValidateCreate ¶
func (s *SuperStream) ValidateCreate() (admission.Warnings, error)
ValidateCreate implements webhook.Validator so a webhook will be registered for the type either rabbitmqClusterReference.name or rabbitmqClusterReference.connectionSecret must be provided but not both
func (*SuperStream) ValidateDelete ¶
func (s *SuperStream) ValidateDelete() (admission.Warnings, error)
ValidateDelete no validation on delete
func (*SuperStream) ValidateUpdate ¶
ValidateUpdate returns error type 'forbidden' for updates on superstream name, vhost and rabbitmqClusterReference
type SuperStreamList ¶
type SuperStreamList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []SuperStream `json:"items"`
}
SuperStreamList contains a list of SuperStreams
func (*SuperStreamList) DeepCopy ¶
func (in *SuperStreamList) DeepCopy() *SuperStreamList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuperStreamList.
func (*SuperStreamList) DeepCopyInto ¶
func (in *SuperStreamList) DeepCopyInto(out *SuperStreamList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SuperStreamList) DeepCopyObject ¶
func (in *SuperStreamList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SuperStreamSpec ¶
type SuperStreamSpec struct {
// Name of the queue; required property.
// +kubebuilder:validation:Required
Name string `json:"name"`
// Default to vhost '/'; cannot be updated
// +kubebuilder:default:=/
Vhost string `json:"vhost,omitempty"`
// Number of partitions to create within this super stream.
// Defaults to '3'.
// +kubebuilder:default:=3
Partitions int `json:"partitions,omitempty"`
// Routing keys to use for each of the partitions in the SuperStream
// If unset, the routing keys for the partitions will be set to the index of the partitions
// +kubebuilder:validation:Optional
RoutingKeys []string `json:"routingKeys,omitempty"`
// Reference to the RabbitmqCluster that the SuperStream will be created in.
// Required property.
// +kubebuilder:validation:Required
RabbitmqClusterReference topologyv1beta1.RabbitmqClusterReference `json:"rabbitmqClusterReference"`
}
SuperStreamSpec defines the desired state of SuperStream
func (*SuperStreamSpec) DeepCopy ¶
func (in *SuperStreamSpec) DeepCopy() *SuperStreamSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuperStreamSpec.
func (*SuperStreamSpec) DeepCopyInto ¶
func (in *SuperStreamSpec) DeepCopyInto(out *SuperStreamSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SuperStreamStatus ¶
type SuperStreamStatus struct {
// observedGeneration is the most recent successful generation observed for this SuperStream. It corresponds to the
// SuperStream's generation, which is updated on mutation by the API Server.
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
Conditions []topologyv1beta1.Condition `json:"conditions,omitempty"`
// Partitions are a list of the stream queue names which form the partitions of this SuperStream.
Partitions []string `json:"partitions,omitempty"`
}
SuperStreamStatus defines the observed state of SuperStream
func (*SuperStreamStatus) DeepCopy ¶
func (in *SuperStreamStatus) DeepCopy() *SuperStreamStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SuperStreamStatus.
func (*SuperStreamStatus) DeepCopyInto ¶
func (in *SuperStreamStatus) DeepCopyInto(out *SuperStreamStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files