Documentation ¶
Overview ¶
Package v1beta1 contains API Schema definitions for the rabbitmq.com v1beta1 API group +kubebuilder:object:generate=true +groupName=rabbitmq.com
Index ¶
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type Binding
- type BindingList
- type BindingSpec
- type BindingStatus
- type Condition
- type ConditionType
- type Exchange
- type ExchangeList
- type ExchangeSpec
- type ExchangeStatus
- type Federation
- type FederationList
- type FederationSpec
- type FederationStatus
- type Permission
- type PermissionList
- type PermissionSpec
- type PermissionStatus
- type Policy
- type PolicyList
- type PolicySpec
- type PolicyStatus
- type Queue
- type QueueList
- type QueueSpec
- type QueueStatus
- type RabbitmqClusterReference
- func (in *RabbitmqClusterReference) DeepCopy() *RabbitmqClusterReference
- func (in *RabbitmqClusterReference) DeepCopyInto(out *RabbitmqClusterReference)
- func (r *RabbitmqClusterReference) Matches(new *RabbitmqClusterReference) bool
- func (ref *RabbitmqClusterReference) ValidateOnCreate(groupResource schema.GroupResource, name string) error
- type SchemaReplication
- type SchemaReplicationList
- type SchemaReplicationSpec
- type SchemaReplicationStatus
- type Shovel
- type ShovelList
- type ShovelSpec
- type ShovelStatus
- type User
- type UserList
- type UserSpec
- type UserStatus
- type UserTag
- type Vhost
- type VhostList
- type VhostPermissions
- type VhostSpec
- type VhostStatus
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "rabbitmq.com", Version: "v1beta1"} // 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 Binding ¶
type Binding struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec BindingSpec `json:"spec,omitempty"` Status BindingStatus `json:"status,omitempty"` }
Binding is the Schema for the bindings API
func (*Binding) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Binding.
func (*Binding) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Binding) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Binding) GroupResource ¶
func (b *Binding) GroupResource() schema.GroupResource
type BindingList ¶
type BindingList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Binding `json:"items"` }
BindingList contains a list of Binding
func (*BindingList) DeepCopy ¶
func (in *BindingList) DeepCopy() *BindingList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BindingList.
func (*BindingList) DeepCopyInto ¶
func (in *BindingList) DeepCopyInto(out *BindingList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BindingList) DeepCopyObject ¶
func (in *BindingList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type BindingSpec ¶
type BindingSpec struct { // Default to vhost '/'; cannot be updated // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` // Cannot be updated // +kubebuilder:validation:Optional Source string `json:"source,omitempty"` // Cannot be updated // +kubebuilder:validation:Optional Destination string `json:"destination,omitempty"` // Cannot be updated // +kubebuilder:validation:Optional // +kubebuilder:validation:Enum=exchange;queue DestinationType string `json:"destinationType,omitempty"` // Cannot be updated // +kubebuilder:validation:Optional RoutingKey string `json:"routingKey,omitempty"` // Cannot be updated // +kubebuilder:validation:Type=object // +kubebuilder:pruning:PreserveUnknownFields Arguments *runtime.RawExtension `json:"arguments,omitempty"` // Reference to the RabbitmqCluster that the binding will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
BindingSpec defines the desired state of Binding
func (*BindingSpec) DeepCopy ¶
func (in *BindingSpec) DeepCopy() *BindingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BindingSpec.
func (*BindingSpec) DeepCopyInto ¶
func (in *BindingSpec) DeepCopyInto(out *BindingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BindingStatus ¶
type BindingStatus struct { // observedGeneration is the most recent successful generation observed for this Binding. It corresponds to the // Binding's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
BindingStatus defines the observed state of Binding
func (*BindingStatus) DeepCopy ¶
func (in *BindingStatus) DeepCopy() *BindingStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BindingStatus.
func (*BindingStatus) DeepCopyInto ¶
func (in *BindingStatus) DeepCopyInto(out *BindingStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Condition ¶
type Condition struct { // Type indicates the scope of the custom resource status addressed by the condition. Type ConditionType `json:"type"` // True, False, or Unknown Status corev1.ConditionStatus `json:"status"` // The last time this Condition status changed. LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"` // One word, camel-case reason for current status of the condition. Reason string `json:"reason,omitempty"` // Full text reason for current status of the condition. Message string `json:"message,omitempty"` }
func (*Condition) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionType ¶
type ConditionType string
type Exchange ¶
type Exchange struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ExchangeSpec `json:"spec,omitempty"` Status ExchangeStatus `json:"status,omitempty"` }
Exchange is the Schema for the exchanges API
func (*Exchange) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Exchange.
func (*Exchange) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Exchange) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Exchange) GroupResource ¶
func (e *Exchange) GroupResource() schema.GroupResource
type ExchangeList ¶
type ExchangeList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Exchange `json:"items"` }
ExchangeList contains a list of Exchange
func (*ExchangeList) DeepCopy ¶
func (in *ExchangeList) DeepCopy() *ExchangeList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExchangeList.
func (*ExchangeList) DeepCopyInto ¶
func (in *ExchangeList) DeepCopyInto(out *ExchangeList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ExchangeList) DeepCopyObject ¶
func (in *ExchangeList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ExchangeSpec ¶
type ExchangeSpec struct { // Required property; cannot be updated // +kubebuilder:validation:Required Name string `json:"name"` // Default to vhost '/'; cannot be updated // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` // Cannot be updated // +kubebuilder:default:=direct Type string `json:"type,omitempty"` // Cannot be updated Durable bool `json:"durable,omitempty"` // Cannot be updated AutoDelete bool `json:"autoDelete,omitempty"` // +kubebuilder:validation:Type=object // +kubebuilder:pruning:PreserveUnknownFields Arguments *runtime.RawExtension `json:"arguments,omitempty"` // Reference to the RabbitmqCluster that the exchange will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
ExchangeSpec defines the desired state of Exchange
func (*ExchangeSpec) DeepCopy ¶
func (in *ExchangeSpec) DeepCopy() *ExchangeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExchangeSpec.
func (*ExchangeSpec) DeepCopyInto ¶
func (in *ExchangeSpec) DeepCopyInto(out *ExchangeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExchangeStatus ¶
type ExchangeStatus struct { // observedGeneration is the most recent successful generation observed for this Exchange. It corresponds to the // Exchange's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
ExchangeStatus defines the observed state of Exchange
func (*ExchangeStatus) DeepCopy ¶
func (in *ExchangeStatus) DeepCopy() *ExchangeStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExchangeStatus.
func (*ExchangeStatus) DeepCopyInto ¶
func (in *ExchangeStatus) DeepCopyInto(out *ExchangeStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Federation ¶
type Federation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec FederationSpec `json:"spec,omitempty"` Status FederationStatus `json:"status,omitempty"` }
Federation is the Schema for the federations API
func (*Federation) DeepCopy ¶
func (in *Federation) DeepCopy() *Federation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Federation.
func (*Federation) DeepCopyInto ¶
func (in *Federation) DeepCopyInto(out *Federation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Federation) DeepCopyObject ¶
func (in *Federation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Federation) GroupResource ¶
func (f *Federation) GroupResource() schema.GroupResource
type FederationList ¶
type FederationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Federation `json:"items"` }
FederationList contains a list of Federation
func (*FederationList) DeepCopy ¶
func (in *FederationList) DeepCopy() *FederationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FederationList.
func (*FederationList) DeepCopyInto ¶
func (in *FederationList) DeepCopyInto(out *FederationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FederationList) DeepCopyObject ¶
func (in *FederationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type FederationSpec ¶
type FederationSpec struct { // Required property; cannot be updated // +kubebuilder:validation:Required Name string `json:"name"` // Default to vhost '/'; cannot be updated // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` // Reference to the RabbitmqCluster that this federation upstream will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` // Secret contains the AMQP URI(s) for the upstream. // The Secret must contain the key `uri` or operator will error. // `uri` should be one or multiple uris separated by ','. // Required property. // +kubebuilder:validation:Required UriSecret *corev1.LocalObjectReference `json:"uriSecret"` PrefetchCount int `json:"prefetch-count,omitempty"` // +kubebuilder:validation:Enum=on-confirm;on-publish;no-ack AckMode string `json:"ackMode,omitempty"` Expires int `json:"expires,omitempty"` MessageTTL int `json:"messageTTL,omitempty"` MaxHops int `json:"maxHops,omitempty"` ReconnectDelay int `json:"reconnectDelay,omitempty"` TrustUserId bool `json:"trustUserId,omitempty"` Exchange string `json:"exchange,omitempty"` Queue string `json:"queue,omitempty"` }
FederationSpec defines the desired state of Federation For how to configure federation upstreams, see: https://www.rabbitmq.com/federation-reference.html.
func (*FederationSpec) DeepCopy ¶
func (in *FederationSpec) DeepCopy() *FederationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FederationSpec.
func (*FederationSpec) DeepCopyInto ¶
func (in *FederationSpec) DeepCopyInto(out *FederationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FederationStatus ¶
type FederationStatus struct { // observedGeneration is the most recent successful generation observed for this Federation. It corresponds to the // Federation's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
FederationStatus defines the observed state of Federation
func (*FederationStatus) DeepCopy ¶
func (in *FederationStatus) DeepCopy() *FederationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FederationStatus.
func (*FederationStatus) DeepCopyInto ¶
func (in *FederationStatus) DeepCopyInto(out *FederationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Permission ¶
type Permission struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PermissionSpec `json:"spec,omitempty"` Status PermissionStatus `json:"status,omitempty"` }
Permission is the Schema for the permissions API
func (*Permission) DeepCopy ¶
func (in *Permission) DeepCopy() *Permission
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Permission.
func (*Permission) DeepCopyInto ¶
func (in *Permission) DeepCopyInto(out *Permission)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Permission) DeepCopyObject ¶
func (in *Permission) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Permission) GroupResource ¶
func (p *Permission) GroupResource() schema.GroupResource
type PermissionList ¶
type PermissionList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Permission `json:"items"` }
PermissionList contains a list of Permission
func (*PermissionList) DeepCopy ¶
func (in *PermissionList) DeepCopy() *PermissionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PermissionList.
func (*PermissionList) DeepCopyInto ¶
func (in *PermissionList) DeepCopyInto(out *PermissionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PermissionList) DeepCopyObject ¶
func (in *PermissionList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PermissionSpec ¶
type PermissionSpec struct { // Name of an existing user; must provide user or userReference, else create/update will fail; cannot be updated User string `json:"user,omitempty"` // Reference to an existing user.rabbitmq.com object; must provide user or userReference, else create/update will fail; cannot be updated UserReference *corev1.LocalObjectReference `json:"userReference,omitempty"` // Name of an existing vhost; required property; cannot be updated // +kubebuilder:validation:Required Vhost string `json:"vhost"` // Permissions to grant to the user in the specific vhost; required property. // See RabbitMQ doc for more information: https://www.rabbitmq.com/access-control.html#user-management // +kubebuilder:validation:Required Permissions VhostPermissions `json:"permissions"` // Reference to the RabbitmqCluster that both the provided user and vhost are. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
PermissionSpec defines the desired state of Permission
func (*PermissionSpec) DeepCopy ¶
func (in *PermissionSpec) DeepCopy() *PermissionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PermissionSpec.
func (*PermissionSpec) DeepCopyInto ¶
func (in *PermissionSpec) DeepCopyInto(out *PermissionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PermissionStatus ¶
type PermissionStatus struct { // observedGeneration is the most recent successful generation observed for this Permission. It corresponds to the // Permission's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
PermissionStatus defines the observed state of Permission
func (*PermissionStatus) DeepCopy ¶
func (in *PermissionStatus) DeepCopy() *PermissionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PermissionStatus.
func (*PermissionStatus) DeepCopyInto ¶
func (in *PermissionStatus) DeepCopyInto(out *PermissionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Policy ¶
type Policy struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PolicySpec `json:"spec,omitempty"` Status PolicyStatus `json:"status,omitempty"` }
Policy is the Schema for the policies API
func (*Policy) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Policy.
func (*Policy) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Policy) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Policy) GroupResource ¶
func (p *Policy) GroupResource() schema.GroupResource
type PolicyList ¶
type PolicyList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Policy `json:"items"` }
PolicyList contains a list of Policy
func (*PolicyList) DeepCopy ¶
func (in *PolicyList) DeepCopy() *PolicyList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PolicyList.
func (*PolicyList) DeepCopyInto ¶
func (in *PolicyList) DeepCopyInto(out *PolicyList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PolicyList) DeepCopyObject ¶
func (in *PolicyList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PolicySpec ¶
type PolicySpec struct { // Required property; cannot be updated // +kubebuilder:validation:Required Name string `json:"name"` // Default to vhost '/'; cannot be updated // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` // Regular expression pattern used to match queues and exchanges, e.g. "^amq.". // Required property. // +kubebuilder:validation:Required Pattern string `json:"pattern"` // What this policy applies to: 'queues', 'exchanges', or 'all'. // Default to 'all'. // +kubebuilder:validation:Enum=queues;exchanges;all // +kubebuilder:default:=all ApplyTo string `json:"applyTo,omitempty"` // Default to '0'. // In the event that more than one policy can match a given exchange or queue, the policy with the greatest priority applies. // +kubebuilder:default:=0 Priority int `json:"priority,omitempty"` // Policy definition. Required property. // +kubebuilder:validation:Type=object // +kubebuilder:pruning:PreserveUnknownFields // +kubebuilder:validation:Required Definition *runtime.RawExtension `json:"definition"` // Reference to the RabbitmqCluster that the exchange will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
PolicySpec defines the desired state of Policy https://www.rabbitmq.com/parameters.html#policies
func (*PolicySpec) DeepCopy ¶
func (in *PolicySpec) DeepCopy() *PolicySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PolicySpec.
func (*PolicySpec) DeepCopyInto ¶
func (in *PolicySpec) DeepCopyInto(out *PolicySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PolicyStatus ¶
type PolicyStatus struct { // observedGeneration is the most recent successful generation observed for this Policy. It corresponds to the // Policy's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
PolicyStatus defines the observed state of Policy
func (*PolicyStatus) DeepCopy ¶
func (in *PolicyStatus) DeepCopy() *PolicyStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PolicyStatus.
func (*PolicyStatus) DeepCopyInto ¶
func (in *PolicyStatus) DeepCopyInto(out *PolicyStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Queue ¶
type Queue struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec QueueSpec `json:"spec,omitempty"` Status QueueStatus `json:"status,omitempty"` }
Queue is the Schema for the queues API
func (*Queue) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Queue.
func (*Queue) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Queue) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Queue) GroupResource ¶
func (q *Queue) GroupResource() schema.GroupResource
type QueueList ¶
type QueueList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Queue `json:"items"` }
QueueList contains a list of Queue
func (*QueueList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueList.
func (*QueueList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*QueueList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type QueueSpec ¶
type QueueSpec struct { // Name of the queue; required property. // +kubebuilder:validation:Required Name string `json:"name"` // Default to vhost '/' // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` Type string `json:"type,omitempty"` // When set to false queues does not survive server restart. Durable bool `json:"durable,omitempty"` // when set to true, queues that have had at least one consumer before are deleted after the last consumer unsubscribes. AutoDelete bool `json:"autoDelete,omitempty"` // Queue arguments in the format of KEY: VALUE. e.g. x-delivery-limit: 10000. // Configuring queues through arguments is not recommended because they cannot be updated once set; we recommend configuring queues through policies instead. // +kubebuilder:validation:Type=object // +kubebuilder:pruning:PreserveUnknownFields Arguments *runtime.RawExtension `json:"arguments,omitempty"` // Reference to the RabbitmqCluster that the queue will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
QueueSpec defines the desired state of Queue
func (*QueueSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueSpec.
func (*QueueSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueStatus ¶
type QueueStatus struct { // observedGeneration is the most recent successful generation observed for this Queue. It corresponds to the // Queue's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
QueueStatus defines the observed state of Queue
func (*QueueStatus) DeepCopy ¶
func (in *QueueStatus) DeepCopy() *QueueStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueStatus.
func (*QueueStatus) DeepCopyInto ¶
func (in *QueueStatus) DeepCopyInto(out *QueueStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RabbitmqClusterReference ¶
type RabbitmqClusterReference struct { // The name of the RabbitMQ cluster to reference. // Have to set either name or connectionSecret, but not both. // +kubebuilder:validation:Optional Name string `json:"name,omitempty"` // The namespace of the RabbitMQ cluster to reference. // Defaults to the namespace of the requested resource if omitted. // +kubebuilder:validation:Optional Namespace string `json:"namespace,omitempty"` // Secret contains the http management uri for the RabbitMQ cluster. // The Secret must contain the key `uri`, `username` and `password` or operator will error. // Have to set either name or connectionSecret, but not both. // +kubebuilder:validation:Optional ConnectionSecret *corev1.LocalObjectReference `json:"connectionSecret,omitempty"` }
func (*RabbitmqClusterReference) DeepCopy ¶
func (in *RabbitmqClusterReference) DeepCopy() *RabbitmqClusterReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RabbitmqClusterReference.
func (*RabbitmqClusterReference) DeepCopyInto ¶
func (in *RabbitmqClusterReference) DeepCopyInto(out *RabbitmqClusterReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RabbitmqClusterReference) Matches ¶ added in v0.31.0
func (r *RabbitmqClusterReference) Matches(new *RabbitmqClusterReference) bool
func (*RabbitmqClusterReference) ValidateOnCreate ¶ added in v0.31.0
func (ref *RabbitmqClusterReference) ValidateOnCreate(groupResource schema.GroupResource, name string) error
ValidateOnCreate validates RabbitmqClusterReference on resources create either rabbitmqClusterReference.name or rabbitmqClusterReference.connectionSecret must be provided but not both; else it errors
type SchemaReplication ¶
type SchemaReplication struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec SchemaReplicationSpec `json:"spec,omitempty"` Status SchemaReplicationStatus `json:"status,omitempty"` }
SchemaReplication is the Schema for the schemareplications API This feature requires Tanzu RabbitMQ with schema replication plugin. For more information, see: https://tanzu.vmware.com/rabbitmq and https://www.rabbitmq.com/definitions-standby.html.
func (*SchemaReplication) DeepCopy ¶
func (in *SchemaReplication) DeepCopy() *SchemaReplication
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaReplication.
func (*SchemaReplication) DeepCopyInto ¶
func (in *SchemaReplication) DeepCopyInto(out *SchemaReplication)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SchemaReplication) DeepCopyObject ¶
func (in *SchemaReplication) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SchemaReplication) GroupResource ¶
func (s *SchemaReplication) GroupResource() schema.GroupResource
type SchemaReplicationList ¶
type SchemaReplicationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []SchemaReplication `json:"items"` }
SchemaReplicationList contains a list of SchemaReplication
func (*SchemaReplicationList) DeepCopy ¶
func (in *SchemaReplicationList) DeepCopy() *SchemaReplicationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaReplicationList.
func (*SchemaReplicationList) DeepCopyInto ¶
func (in *SchemaReplicationList) DeepCopyInto(out *SchemaReplicationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SchemaReplicationList) DeepCopyObject ¶
func (in *SchemaReplicationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SchemaReplicationSpec ¶
type SchemaReplicationSpec struct { // Reference to the RabbitmqCluster that schema replication would be set for. Must be an existing cluster. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` // Defines a Secret which contains credentials to be used for schema replication. // The Secret must contain the keys `username` and `password` in its Data field, or operator will error. // +kubebuilder:validation:Required UpstreamSecret *corev1.LocalObjectReference `json:"upstreamSecret,omitempty"` // endpoints should be one or multiple endpoints separated by ','. // Must provide either spec.endpoints or endpoints in spec.upstreamSecret. // When endpoints are provided in both spec.endpoints and spec.upstreamSecret, spec.endpoints takes // precedence. Endpoints string `json:"endpoints,omitempty"` }
SchemaReplicationSpec defines the desired state of SchemaReplication
func (*SchemaReplicationSpec) DeepCopy ¶
func (in *SchemaReplicationSpec) DeepCopy() *SchemaReplicationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaReplicationSpec.
func (*SchemaReplicationSpec) DeepCopyInto ¶
func (in *SchemaReplicationSpec) DeepCopyInto(out *SchemaReplicationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchemaReplicationStatus ¶
type SchemaReplicationStatus struct { // observedGeneration is the most recent successful generation observed for this Queue. It corresponds to the // Queue's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
SchemaReplicationStatus defines the observed state of SchemaReplication
func (*SchemaReplicationStatus) DeepCopy ¶
func (in *SchemaReplicationStatus) DeepCopy() *SchemaReplicationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchemaReplicationStatus.
func (*SchemaReplicationStatus) DeepCopyInto ¶
func (in *SchemaReplicationStatus) DeepCopyInto(out *SchemaReplicationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Shovel ¶
type Shovel struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ShovelSpec `json:"spec,omitempty"` Status ShovelStatus `json:"status,omitempty"` }
Shovel is the Schema for the shovels API
func (*Shovel) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Shovel.
func (*Shovel) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Shovel) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Shovel) GroupResource ¶
func (s *Shovel) GroupResource() schema.GroupResource
type ShovelList ¶
type ShovelList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Shovel `json:"items"` }
ShovelList contains a list of Shovel
func (*ShovelList) DeepCopy ¶
func (in *ShovelList) DeepCopy() *ShovelList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ShovelList.
func (*ShovelList) DeepCopyInto ¶
func (in *ShovelList) DeepCopyInto(out *ShovelList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ShovelList) DeepCopyObject ¶
func (in *ShovelList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ShovelSpec ¶
type ShovelSpec struct { // Required property; cannot be updated // +kubebuilder:validation:Required Name string `json:"name"` // Default to vhost '/'; cannot be updated // +kubebuilder:default:=/ Vhost string `json:"vhost,omitempty"` // Reference to the RabbitmqCluster that this Shovel will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` // Secret contains the AMQP URI(s) to configure Shovel destination and source. // The Secret must contain the key `destUri` and `srcUri` or operator will error. // Both fields should be one or multiple uris separated by ','. // Required property. // +kubebuilder:validation:Required UriSecret *corev1.LocalObjectReference `json:"uriSecret"` // +kubebuilder:validation:Enum=on-confirm;on-publish;no-ack AckMode string `json:"ackMode,omitempty"` AddForwardHeaders bool `json:"addForwardHeaders,omitempty"` DeleteAfter string `json:"deleteAfter,omitempty"` DestinationAddForwardHeaders bool `json:"destAddForwardHeaders,omitempty"` DestinationAddTimestampHeader bool `json:"destAddTimestampHeader,omitempty"` DestinationAddress string `json:"destAddress,omitempty"` DestinationApplicationProperties string `json:"destApplicationProperties,omitempty"` DestinationExchange string `json:"destExchange,omitempty"` DestinationExchangeKey string `json:"destExchangeKey,omitempty"` DestinationProperties string `json:"destProperties,omitempty"` DestinationProtocol string `json:"destProtocol,omitempty"` DestinationPublishProperties string `json:"destPublishProperties,omitempty"` DestinationQueue string `json:"destQueue,omitempty"` PrefetchCount int `json:"prefetchCount,omitempty"` ReconnectDelay int `json:"reconnectDelay,omitempty"` SourceAddress string `json:"srcAddress,omitempty"` SourceDeleteAfter string `json:"srcDeleteAfter,omitempty"` SourceExchange string `json:"srcExchange,omitempty"` SourceExchangeKey string `json:"srcExchangeKey,omitempty"` SourcePrefetchCount int `json:"srcPrefetchCount,omitempty"` SourceProtocol string `json:"srcProtocol,omitempty"` SourceQueue string `json:"srcQueue,omitempty"` }
ShovelSpec defines the desired state of Shovel For how to configure Shovel, see: https://www.rabbitmq.com/shovel.html.
func (*ShovelSpec) DeepCopy ¶
func (in *ShovelSpec) DeepCopy() *ShovelSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ShovelSpec.
func (*ShovelSpec) DeepCopyInto ¶
func (in *ShovelSpec) DeepCopyInto(out *ShovelSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ShovelStatus ¶
type ShovelStatus struct { // observedGeneration is the most recent successful generation observed for this Shovel. It corresponds to the // Shovel's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
ShovelStatus defines the observed state of Shovel
func (*ShovelStatus) DeepCopy ¶
func (in *ShovelStatus) DeepCopy() *ShovelStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ShovelStatus.
func (*ShovelStatus) DeepCopyInto ¶
func (in *ShovelStatus) DeepCopyInto(out *ShovelStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type User ¶
type User struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // Spec configures the desired state of the User object. Spec UserSpec `json:"spec,omitempty"` // Status exposes the observed state of the User object. Status UserStatus `json:"status,omitempty"` }
User is the Schema for the users API. +kubebuilder:subresource:status
func (*User) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new User.
func (*User) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*User) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*User) GroupResource ¶
func (u *User) GroupResource() schema.GroupResource
type UserList ¶
type UserList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []User `json:"items"` }
UserList contains a list of Users.
func (*UserList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserList.
func (*UserList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*UserList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UserSpec ¶
type UserSpec struct { // List of permissions tags to associate with the user. This determines the level of // access to the RabbitMQ management UI granted to the user. Omitting this field will // lead to a user than can still connect to the cluster through messaging protocols, // but cannot perform any management actions. // For more information, see https://www.rabbitmq.com/management.html#permissions. Tags []UserTag `json:"tags,omitempty"` // Reference to the RabbitmqCluster that the user will be created for. This cluster must // exist for the User object to be created. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` // Defines a Secret used to pre-define the username and password set for this User. User objects created // with this field set will not have randomly-generated credentials, and will instead import // the username/password values from this Secret. // The Secret must contain the keys `username` and `password` in its Data field, or the import will fail. // Note that this import only occurs at creation time, and is ignored once a password has been set // on a User. ImportCredentialsSecret *corev1.LocalObjectReference `json:"importCredentialsSecret,omitempty"` }
UserSpec defines the desired state of User.
func (*UserSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserSpec.
func (*UserSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UserStatus ¶
type UserStatus struct { // observedGeneration is the most recent successful generation observed for this User. It corresponds to the // User's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` // Provides a reference to a Secret object containing the user credentials. Credentials *corev1.LocalObjectReference `json:"credentials,omitempty"` }
UserStatus defines the observed state of User.
func (*UserStatus) DeepCopy ¶
func (in *UserStatus) DeepCopy() *UserStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserStatus.
func (*UserStatus) DeepCopyInto ¶
func (in *UserStatus) DeepCopyInto(out *UserStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UserTag ¶
type UserTag string
UserTag defines the level of access to the management UI allocated to the user. For more information, see https://www.rabbitmq.com/management.html#permissions. +kubebuilder:validation:Enum=management;policymaker;monitoring;administrator
type Vhost ¶
type Vhost struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec VhostSpec `json:"spec,omitempty"` Status VhostStatus `json:"status,omitempty"` }
Vhost is the Schema for the vhosts API
func (*Vhost) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Vhost.
func (*Vhost) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Vhost) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Vhost) GroupResource ¶
func (v *Vhost) GroupResource() schema.GroupResource
type VhostList ¶
type VhostList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Vhost `json:"items"` }
VhostList contains a list of Vhost
func (*VhostList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VhostList.
func (*VhostList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*VhostList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type VhostPermissions ¶
type VhostPermissions struct { // +kubebuilder:validation:Optional Configure string `json:"configure,omitempty"` // +kubebuilder:validation:Optional Write string `json:"write,omitempty"` // +kubebuilder:validation:Optional Read string `json:"read,omitempty"` }
Set of RabbitMQ permissions: configure, read and write. By not setting a property (configure/write/read), it result in an empty string which does not not match any permission.
func (*VhostPermissions) DeepCopy ¶
func (in *VhostPermissions) DeepCopy() *VhostPermissions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VhostPermissions.
func (*VhostPermissions) DeepCopyInto ¶
func (in *VhostPermissions) DeepCopyInto(out *VhostPermissions)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VhostSpec ¶
type VhostSpec struct { // Name of the vhost; see https://www.rabbitmq.com/vhosts.html. // +kubebuilder:validation:Required Name string `json:"name"` Tracing bool `json:"tracing,omitempty"` Tags []string `json:"tags,omitempty"` // Reference to the RabbitmqCluster that the vhost will be created in. // Required property. // +kubebuilder:validation:Required RabbitmqClusterReference RabbitmqClusterReference `json:"rabbitmqClusterReference"` }
VhostSpec defines the desired state of Vhost
func (*VhostSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VhostSpec.
func (*VhostSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VhostStatus ¶
type VhostStatus struct { // observedGeneration is the most recent successful generation observed for this Vhost. It corresponds to the // Vhost's generation, which is updated on mutation by the API Server. ObservedGeneration int64 `json:"observedGeneration,omitempty"` Conditions []Condition `json:"conditions,omitempty"` }
VhostStatus defines the observed state of Vhost
func (*VhostStatus) DeepCopy ¶
func (in *VhostStatus) DeepCopy() *VhostStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VhostStatus.
func (*VhostStatus) DeepCopyInto ¶
func (in *VhostStatus) DeepCopyInto(out *VhostStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.