v1alpha1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the middleware v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=middleware.io

Package v1alpha1 contains API Schema definitions for the middleware v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=middleware.io

Index

• Constants
• Variables
• type Broker
  • func (in *Broker) DeepCopy() *Broker
  • func (in *Broker) DeepCopyInto(out *Broker)
• type NameSrv
  • func (in *NameSrv) DeepCopy() *NameSrv
  • func (in *NameSrv) DeepCopyInto(out *NameSrv)
• type RocketMQ
  • func (in *RocketMQ) DeepCopy() *RocketMQ
  • func (in *RocketMQ) DeepCopyInto(out *RocketMQ)
  • func (in *RocketMQ) DeepCopyObject() runtime.Object
• type RocketMQList
  • func (in *RocketMQList) DeepCopy() *RocketMQList
  • func (in *RocketMQList) DeepCopyInto(out *RocketMQList)
  • func (in *RocketMQList) DeepCopyObject() runtime.Object
• type RocketMQSpec
  • func (in *RocketMQSpec) DeepCopy() *RocketMQSpec
  • func (in *RocketMQSpec) DeepCopyInto(out *RocketMQSpec)
• type RocketMQStatus
  • func (in *RocketMQStatus) DeepCopy() *RocketMQStatus
  • func (in *RocketMQStatus) DeepCopyInto(out *RocketMQStatus)
• type RoleName

Constants

const (
	MasterRole      RoleName = "master"
	SlaveRole       RoleName = "slave"
	NamesrvRole     RoleName = "namesrv"
	ConsoleRole     RoleName = "console"
	ConsoleImage    string   = "riet/rocketmq-console-ng:v1.0.0"
	BrokerBaseImage string   = "riet/rocketmq:4.4.0-broker"
	NameSrvImage    string   = "riet/rocketmq:4.4.0-namesrv"
	ConsolePort     int32    = 8080
	NamesrvPort     int32    = 9876
	BrokerPort      int32    = 10911
)

Variables

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

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

Types

type Broker

type Broker struct {
	Num                 int32                       `json:"num"`
	Resources           corev1.ResourceRequirements `json:"resources,omitempty"`
	Xmx                 string                      `json:"xmx"`
	Xmn                 string                      `json:"xmn"`
	MaxDirectMemorySize string                      `json:"maxDirectMemorySize"`
	StorageClass        string                      `json:"storageClass,omitempty"`
	StorageSize         string                      `json:"storageSize,omitempty"`
	Mode                string                      `json:"mode"`
}

func (*Broker) DeepCopy

func (in *Broker) DeepCopy() *Broker

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

func (*Broker) DeepCopyInto

func (in *Broker) DeepCopyInto(out *Broker)

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

type NameSrv

type NameSrv struct {
	Num       int32                       `json:"num"`
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
	Xmx       string                      `json:"xmx"`
	Xmn       string                      `json:"xmn"`
}

func (*NameSrv) DeepCopy

func (in *NameSrv) DeepCopy() *NameSrv

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

func (*NameSrv) DeepCopyInto

func (in *NameSrv) DeepCopyInto(out *NameSrv)

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

type RocketMQ

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

	Spec   RocketMQSpec   `json:"spec,omitempty"`
	Status RocketMQStatus `json:"status,omitempty"`
}

RocketMQ is the Schema for the rocketmqs API +kubebuilder:subresource:status +kubebuilder:resource:path=rocketmqs,scope=Namespaced

func (*RocketMQ) DeepCopy

func (in *RocketMQ) DeepCopy() *RocketMQ

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

func (*RocketMQ) DeepCopyInto

func (in *RocketMQ) DeepCopyInto(out *RocketMQ)

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

func (*RocketMQ) DeepCopyObject

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

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

type RocketMQList

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

RocketMQList contains a list of RocketMQ

func (*RocketMQList) DeepCopy

func (in *RocketMQList) DeepCopy() *RocketMQList

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

func (*RocketMQList) DeepCopyInto

func (in *RocketMQList) DeepCopyInto(out *RocketMQList)

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

func (*RocketMQList) DeepCopyObject

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

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

type RocketMQSpec

type RocketMQSpec struct {
	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
	// Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file
	// Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html
	NameSrv     NameSrv `json:"nameSrv"`
	MasterSlave Broker  `json:"masterSlave"`
	Console     bool    `json:"console,omitempty"`
}

RocketMQSpec defines the desired state of RocketMQ

func (*RocketMQSpec) DeepCopy

func (in *RocketMQSpec) DeepCopy() *RocketMQSpec

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

func (*RocketMQSpec) DeepCopyInto

func (in *RocketMQSpec) DeepCopyInto(out *RocketMQSpec)

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

type RocketMQStatus

type RocketMQStatus struct {
}

RocketMQStatus defines the observed state of RocketMQ

func (*RocketMQStatus) DeepCopy

func (in *RocketMQStatus) DeepCopy() *RocketMQStatus

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

func (*RocketMQStatus) DeepCopyInto

func (in *RocketMQStatus) DeepCopyInto(out *RocketMQStatus)

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

type RoleName

type RoleName string