Documentation ¶
Overview ¶
Package v1beta3 contains API Schema definitions for the apps v1beta3 API group +kubebuilder:object:generate=true +groupName=apps.emqx.io
Index ¶
- Constants
- Variables
- type Condition
- type ConditionType
- type Emqx
- type EmqxBroker
- func (dst *EmqxBroker) ConvertFrom(srcRaw conversion.Hub) error
- func (src *EmqxBroker) ConvertTo(dstRaw conversion.Hub) error
- func (in *EmqxBroker) DeepCopy() *EmqxBroker
- func (in *EmqxBroker) DeepCopyInto(out *EmqxBroker)
- func (in *EmqxBroker) DeepCopyObject() runtime.Object
- func (emqx *EmqxBroker) GetACL() []string
- func (emqx *EmqxBroker) GetAPIVersion() string
- func (emqx *EmqxBroker) GetAffinity() *corev1.Affinity
- func (emqx *EmqxBroker) GetArgs() []string
- func (emqx *EmqxBroker) GetEmqxConfig() EmqxConfig
- func (emqx *EmqxBroker) GetEnv() []corev1.EnvVar
- func (emqx *EmqxBroker) GetExtraContainers() []corev1.Container
- func (emqx *EmqxBroker) GetExtraVolumeMounts() []corev1.VolumeMount
- func (emqx *EmqxBroker) GetExtraVolumes() []corev1.Volume
- func (emqx *EmqxBroker) GetImage() string
- func (emqx *EmqxBroker) GetImagePullPolicy() corev1.PullPolicy
- func (emqx *EmqxBroker) GetImagePullSecrets() []corev1.LocalObjectReference
- func (emqx *EmqxBroker) GetInitContainers() []corev1.Container
- func (emqx *EmqxBroker) GetKind() string
- func (emqx *EmqxBroker) GetLivenessProbe() *corev1.Probe
- func (emqx *EmqxBroker) GetModules() []EmqxBrokerModule
- func (emqx *EmqxBroker) GetNodeName() string
- func (emqx *EmqxBroker) GetNodeSelector() map[string]string
- func (emqx *EmqxBroker) GetPassword() string
- func (emqx *EmqxBroker) GetPersistent() corev1.PersistentVolumeClaimSpec
- func (emqx *EmqxBroker) GetReadinessProbe() *corev1.Probe
- func (emqx *EmqxBroker) GetRegistry() string
- func (emqx *EmqxBroker) GetReplicas() *int32
- func (emqx *EmqxBroker) GetResource() corev1.ResourceRequirements
- func (emqx *EmqxBroker) GetSecurityContext() *corev1.PodSecurityContext
- func (emqx *EmqxBroker) GetServiceTemplate() ServiceTemplate
- func (emqx *EmqxBroker) GetStartupProbe() *corev1.Probe
- func (emqx *EmqxBroker) GetStatus() Status
- func (emqx *EmqxBroker) GetToleRations() []corev1.Toleration
- func (emqx *EmqxBroker) GetUsername() string
- func (emqx *EmqxBroker) SetACL(acl []string)
- func (emqx *EmqxBroker) SetAPIVersion(version string)
- func (emqx *EmqxBroker) SetAffinity(affinity *corev1.Affinity)
- func (emqx *EmqxBroker) SetArgs(args []string)
- func (emqx *EmqxBroker) SetEmqxConfig(config EmqxConfig)
- func (emqx *EmqxBroker) SetEnv(env []corev1.EnvVar)
- func (emqx *EmqxBroker) SetExtraContainers(containers []corev1.Container)
- func (emqx *EmqxBroker) SetImage(image string)
- func (emqx *EmqxBroker) SetImagePullPolicy(pullPolicy corev1.PullPolicy)
- func (emqx *EmqxBroker) SetImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference)
- func (emqx *EmqxBroker) SetInitContainers(containers []corev1.Container)
- func (emqx *EmqxBroker) SetKind(kind string)
- func (emqx *EmqxBroker) SetLivenessProbe(probe *corev1.Probe)
- func (emqx *EmqxBroker) SetModules(modules []EmqxBrokerModule)
- func (emqx *EmqxBroker) SetNodeName(nodeName string)
- func (emqx *EmqxBroker) SetNodeSelector(nodeSelector map[string]string)
- func (emqx *EmqxBroker) SetPassword(password string)
- func (emqx *EmqxBroker) SetPersistent(persistent corev1.PersistentVolumeClaimSpec)
- func (emqx *EmqxBroker) SetReadinessProbe(probe *corev1.Probe)
- func (emqx *EmqxBroker) SetRegistry(registry string)
- func (emqx *EmqxBroker) SetReplicas(replicas *int32)
- func (emqx *EmqxBroker) SetResource(resource corev1.ResourceRequirements)
- func (emqx *EmqxBroker) SetSecurityContext(securityContext *corev1.PodSecurityContext)
- func (emqx *EmqxBroker) SetServiceTemplate(serviceTemplate ServiceTemplate)
- func (emqx *EmqxBroker) SetStartupProbe(probe *corev1.Probe)
- func (emqx *EmqxBroker) SetStatus(status Status)
- func (emqx *EmqxBroker) SetToleRations(tolerations []corev1.Toleration)
- func (emqx *EmqxBroker) SetUsername(username string)
- type EmqxBrokerList
- type EmqxBrokerModule
- type EmqxBrokerModuleList
- type EmqxBrokerSpec
- type EmqxBrokerTemplate
- type EmqxConfig
- type EmqxEnterprise
- func (dst *EmqxEnterprise) ConvertFrom(srcRaw conversion.Hub) error
- func (src *EmqxEnterprise) ConvertTo(dstRaw conversion.Hub) error
- func (in *EmqxEnterprise) DeepCopy() *EmqxEnterprise
- func (in *EmqxEnterprise) DeepCopyInto(out *EmqxEnterprise)
- func (in *EmqxEnterprise) DeepCopyObject() runtime.Object
- func (emqx *EmqxEnterprise) GetACL() []string
- func (emqx *EmqxEnterprise) GetAPIVersion() string
- func (emqx *EmqxEnterprise) GetAffinity() *corev1.Affinity
- func (emqx *EmqxEnterprise) GetArgs() []string
- func (emqx *EmqxEnterprise) GetEmqxConfig() EmqxConfig
- func (emqx *EmqxEnterprise) GetEnv() []corev1.EnvVar
- func (emqx *EmqxEnterprise) GetExtraContainers() []corev1.Container
- func (emqx *EmqxEnterprise) GetExtraVolumeMounts() []corev1.VolumeMount
- func (emqx *EmqxEnterprise) GetExtraVolumes() []corev1.Volume
- func (emqx *EmqxEnterprise) GetImage() string
- func (emqx *EmqxEnterprise) GetImagePullPolicy() corev1.PullPolicy
- func (emqx *EmqxEnterprise) GetImagePullSecrets() []corev1.LocalObjectReference
- func (emqx *EmqxEnterprise) GetInitContainers() []corev1.Container
- func (emqx *EmqxEnterprise) GetKind() string
- func (emqx *EmqxEnterprise) GetLicense() License
- func (emqx *EmqxEnterprise) GetLivenessProbe() *corev1.Probe
- func (emqx *EmqxEnterprise) GetModules() []EmqxEnterpriseModule
- func (emqx *EmqxEnterprise) GetNodeName() string
- func (emqx *EmqxEnterprise) GetNodeSelector() map[string]string
- func (emqx *EmqxEnterprise) GetPassword() string
- func (emqx *EmqxEnterprise) GetPersistent() corev1.PersistentVolumeClaimSpec
- func (emqx *EmqxEnterprise) GetReadinessProbe() *corev1.Probe
- func (emqx *EmqxEnterprise) GetRegistry() string
- func (emqx *EmqxEnterprise) GetReplicas() *int32
- func (emqx *EmqxEnterprise) GetResource() corev1.ResourceRequirements
- func (emqx *EmqxEnterprise) GetSecurityContext() *corev1.PodSecurityContext
- func (emqx *EmqxEnterprise) GetServiceTemplate() ServiceTemplate
- func (emqx *EmqxEnterprise) GetStartupProbe() *corev1.Probe
- func (emqx *EmqxEnterprise) GetStatus() Status
- func (emqx *EmqxEnterprise) GetToleRations() []corev1.Toleration
- func (emqx *EmqxEnterprise) GetUsername() string
- func (emqx *EmqxEnterprise) SetACL(acl []string)
- func (emqx *EmqxEnterprise) SetAPIVersion(version string)
- func (emqx *EmqxEnterprise) SetAffinity(affinity *corev1.Affinity)
- func (emqx *EmqxEnterprise) SetArgs(args []string)
- func (emqx *EmqxEnterprise) SetEmqxConfig(config EmqxConfig)
- func (emqx *EmqxEnterprise) SetEnv(env []corev1.EnvVar)
- func (emqx *EmqxEnterprise) SetExtraContainers(containers []corev1.Container)
- func (emqx *EmqxEnterprise) SetImage(image string)
- func (emqx *EmqxEnterprise) SetImagePullPolicy(pullPolicy corev1.PullPolicy)
- func (emqx *EmqxEnterprise) SetImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference)
- func (emqx *EmqxEnterprise) SetInitContainers(containers []corev1.Container)
- func (emqx *EmqxEnterprise) SetKind(kind string)
- func (emqx *EmqxEnterprise) SetLicense(license License)
- func (emqx *EmqxEnterprise) SetLivenessProbe(probe *corev1.Probe)
- func (emqx *EmqxEnterprise) SetModules(modules []EmqxEnterpriseModule)
- func (emqx *EmqxEnterprise) SetNodeName(nodeName string)
- func (emqx *EmqxEnterprise) SetNodeSelector(nodeSelector map[string]string)
- func (emqx *EmqxEnterprise) SetPassword(password string)
- func (emqx *EmqxEnterprise) SetPersistent(persistent corev1.PersistentVolumeClaimSpec)
- func (emqx *EmqxEnterprise) SetReadinessProbe(probe *corev1.Probe)
- func (emqx *EmqxEnterprise) SetRegistry(registry string)
- func (emqx *EmqxEnterprise) SetReplicas(replicas *int32)
- func (emqx *EmqxEnterprise) SetResource(resource corev1.ResourceRequirements)
- func (emqx *EmqxEnterprise) SetSecurityContext(securityContext *corev1.PodSecurityContext)
- func (emqx *EmqxEnterprise) SetServiceTemplate(serviceTemplate ServiceTemplate)
- func (emqx *EmqxEnterprise) SetStartupProbe(probe *corev1.Probe)
- func (emqx *EmqxEnterprise) SetStatus(status Status)
- func (emqx *EmqxEnterprise) SetToleRations(tolerations []corev1.Toleration)
- func (emqx *EmqxEnterprise) SetUsername(username string)
- type EmqxEnterpriseList
- type EmqxEnterpriseModule
- type EmqxEnterpriseModuleList
- type EmqxEnterpriseSpec
- type EmqxEnterpriseTemplate
- type EmqxNode
- type EmqxPlugin
- type EmqxPluginList
- type EmqxPluginSpec
- type EmqxPluginStatus
- type EmqxSpec
- type EmqxStatus
- type License
- type Names
- type Phase
- type ServiceTemplate
- type Status
Constants ¶
const (
EmqxPluginStatusLoaded phase = "loaded"
)
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "apps.emqx.io", Version: "v1beta3"} // 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 Condition ¶
type Condition struct { // Status of cluster condition. Type ConditionType `json:"type"` // Status of the condition, one of True, False, Unknown. Status corev1.ConditionStatus `json:"status"` // The last time this condition was updated. LastUpdateTime string `json:"lastUpdateTime,omitempty"` LastUpdateAt metav1.Time `json:"-"` // Last time the condition transitioned from one status to another. LastTransitionTime string `json:"lastTransitionTime,omitempty"` // The reason for the condition's last transition. Reason string `json:"reason,omitempty"` // A human readable message indicating details about the transition. Message string `json:"message,omitempty"` }
Condition saves the state information of the EMQX cluster
func NewCondition ¶
func NewCondition(condType ConditionType, status corev1.ConditionStatus, reason, message string) *Condition
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
ConditionType defines the condition that the RF can have
const ( ConditionPluginInitialized ConditionType = "PluginInitialized" ConditionRunning ConditionType = "Running" )
type EmqxBroker ¶
type EmqxBroker struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EmqxBrokerSpec `json:"spec,omitempty"` Status `json:"status,omitempty"` }
EmqxBroker is the Schema for the emqxbrokers API
func (*EmqxBroker) ConvertFrom ¶
func (dst *EmqxBroker) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the Hub version (v1) to this version.
func (*EmqxBroker) ConvertTo ¶
func (src *EmqxBroker) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this version to the Hub version (v1).
func (*EmqxBroker) DeepCopy ¶
func (in *EmqxBroker) DeepCopy() *EmqxBroker
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxBroker.
func (*EmqxBroker) DeepCopyInto ¶
func (in *EmqxBroker) DeepCopyInto(out *EmqxBroker)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxBroker) DeepCopyObject ¶
func (in *EmqxBroker) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*EmqxBroker) GetACL ¶
func (emqx *EmqxBroker) GetACL() []string
func (*EmqxBroker) GetAPIVersion ¶
func (emqx *EmqxBroker) GetAPIVersion() string
func (*EmqxBroker) GetAffinity ¶
func (emqx *EmqxBroker) GetAffinity() *corev1.Affinity
func (*EmqxBroker) GetArgs ¶
func (emqx *EmqxBroker) GetArgs() []string
func (*EmqxBroker) GetEmqxConfig ¶
func (emqx *EmqxBroker) GetEmqxConfig() EmqxConfig
func (*EmqxBroker) GetEnv ¶
func (emqx *EmqxBroker) GetEnv() []corev1.EnvVar
func (*EmqxBroker) GetExtraContainers ¶
func (emqx *EmqxBroker) GetExtraContainers() []corev1.Container
func (*EmqxBroker) GetExtraVolumeMounts ¶
func (emqx *EmqxBroker) GetExtraVolumeMounts() []corev1.VolumeMount
func (*EmqxBroker) GetExtraVolumes ¶
func (emqx *EmqxBroker) GetExtraVolumes() []corev1.Volume
func (*EmqxBroker) GetImage ¶
func (emqx *EmqxBroker) GetImage() string
func (*EmqxBroker) GetImagePullPolicy ¶
func (emqx *EmqxBroker) GetImagePullPolicy() corev1.PullPolicy
func (*EmqxBroker) GetImagePullSecrets ¶
func (emqx *EmqxBroker) GetImagePullSecrets() []corev1.LocalObjectReference
func (*EmqxBroker) GetInitContainers ¶
func (emqx *EmqxBroker) GetInitContainers() []corev1.Container
func (*EmqxBroker) GetKind ¶
func (emqx *EmqxBroker) GetKind() string
func (*EmqxBroker) GetLivenessProbe ¶
func (emqx *EmqxBroker) GetLivenessProbe() *corev1.Probe
func (*EmqxBroker) GetModules ¶
func (emqx *EmqxBroker) GetModules() []EmqxBrokerModule
func (*EmqxBroker) GetNodeName ¶
func (emqx *EmqxBroker) GetNodeName() string
func (*EmqxBroker) GetNodeSelector ¶
func (emqx *EmqxBroker) GetNodeSelector() map[string]string
func (*EmqxBroker) GetPassword ¶
func (emqx *EmqxBroker) GetPassword() string
func (*EmqxBroker) GetPersistent ¶
func (emqx *EmqxBroker) GetPersistent() corev1.PersistentVolumeClaimSpec
func (*EmqxBroker) GetReadinessProbe ¶
func (emqx *EmqxBroker) GetReadinessProbe() *corev1.Probe
func (*EmqxBroker) GetRegistry ¶
func (emqx *EmqxBroker) GetRegistry() string
func (*EmqxBroker) GetReplicas ¶
func (emqx *EmqxBroker) GetReplicas() *int32
func (*EmqxBroker) GetResource ¶
func (emqx *EmqxBroker) GetResource() corev1.ResourceRequirements
func (*EmqxBroker) GetSecurityContext ¶
func (emqx *EmqxBroker) GetSecurityContext() *corev1.PodSecurityContext
func (*EmqxBroker) GetServiceTemplate ¶
func (emqx *EmqxBroker) GetServiceTemplate() ServiceTemplate
func (*EmqxBroker) GetStartupProbe ¶
func (emqx *EmqxBroker) GetStartupProbe() *corev1.Probe
func (*EmqxBroker) GetStatus ¶
func (emqx *EmqxBroker) GetStatus() Status
func (*EmqxBroker) GetToleRations ¶
func (emqx *EmqxBroker) GetToleRations() []corev1.Toleration
func (*EmqxBroker) GetUsername ¶
func (emqx *EmqxBroker) GetUsername() string
func (*EmqxBroker) SetACL ¶
func (emqx *EmqxBroker) SetACL(acl []string)
func (*EmqxBroker) SetAPIVersion ¶
func (emqx *EmqxBroker) SetAPIVersion(version string)
func (*EmqxBroker) SetAffinity ¶
func (emqx *EmqxBroker) SetAffinity(affinity *corev1.Affinity)
func (*EmqxBroker) SetArgs ¶
func (emqx *EmqxBroker) SetArgs(args []string)
func (*EmqxBroker) SetEmqxConfig ¶
func (emqx *EmqxBroker) SetEmqxConfig(config EmqxConfig)
func (*EmqxBroker) SetEnv ¶
func (emqx *EmqxBroker) SetEnv(env []corev1.EnvVar)
func (*EmqxBroker) SetExtraContainers ¶
func (emqx *EmqxBroker) SetExtraContainers(containers []corev1.Container)
func (*EmqxBroker) SetImage ¶
func (emqx *EmqxBroker) SetImage(image string)
func (*EmqxBroker) SetImagePullPolicy ¶
func (emqx *EmqxBroker) SetImagePullPolicy(pullPolicy corev1.PullPolicy)
func (*EmqxBroker) SetImagePullSecrets ¶
func (emqx *EmqxBroker) SetImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference)
func (*EmqxBroker) SetInitContainers ¶
func (emqx *EmqxBroker) SetInitContainers(containers []corev1.Container)
func (*EmqxBroker) SetKind ¶
func (emqx *EmqxBroker) SetKind(kind string)
func (*EmqxBroker) SetLivenessProbe ¶
func (emqx *EmqxBroker) SetLivenessProbe(probe *corev1.Probe)
func (*EmqxBroker) SetModules ¶
func (emqx *EmqxBroker) SetModules(modules []EmqxBrokerModule)
func (*EmqxBroker) SetNodeName ¶
func (emqx *EmqxBroker) SetNodeName(nodeName string)
func (*EmqxBroker) SetNodeSelector ¶
func (emqx *EmqxBroker) SetNodeSelector(nodeSelector map[string]string)
func (*EmqxBroker) SetPassword ¶
func (emqx *EmqxBroker) SetPassword(password string)
func (*EmqxBroker) SetPersistent ¶
func (emqx *EmqxBroker) SetPersistent(persistent corev1.PersistentVolumeClaimSpec)
func (*EmqxBroker) SetReadinessProbe ¶
func (emqx *EmqxBroker) SetReadinessProbe(probe *corev1.Probe)
func (*EmqxBroker) SetRegistry ¶
func (emqx *EmqxBroker) SetRegistry(registry string)
func (*EmqxBroker) SetReplicas ¶
func (emqx *EmqxBroker) SetReplicas(replicas *int32)
func (*EmqxBroker) SetResource ¶
func (emqx *EmqxBroker) SetResource(resource corev1.ResourceRequirements)
func (*EmqxBroker) SetSecurityContext ¶
func (emqx *EmqxBroker) SetSecurityContext(securityContext *corev1.PodSecurityContext)
func (*EmqxBroker) SetServiceTemplate ¶
func (emqx *EmqxBroker) SetServiceTemplate(serviceTemplate ServiceTemplate)
func (*EmqxBroker) SetStartupProbe ¶
func (emqx *EmqxBroker) SetStartupProbe(probe *corev1.Probe)
func (*EmqxBroker) SetStatus ¶
func (emqx *EmqxBroker) SetStatus(status Status)
func (*EmqxBroker) SetToleRations ¶
func (emqx *EmqxBroker) SetToleRations(tolerations []corev1.Toleration)
func (*EmqxBroker) SetUsername ¶
func (emqx *EmqxBroker) SetUsername(username string)
type EmqxBrokerList ¶
type EmqxBrokerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []EmqxBroker `json:"items"` }
EmqxBrokerList contains a list of EmqxBroker
func (*EmqxBrokerList) DeepCopy ¶
func (in *EmqxBrokerList) DeepCopy() *EmqxBrokerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxBrokerList.
func (*EmqxBrokerList) DeepCopyInto ¶
func (in *EmqxBrokerList) DeepCopyInto(out *EmqxBrokerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxBrokerList) DeepCopyObject ¶
func (in *EmqxBrokerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EmqxBrokerModule ¶
type EmqxBrokerModule struct { Name string `json:"name,omitempty"` Enable bool `json:"enable,omitempty"` }
+kubebuilder:object:generate=true
func (*EmqxBrokerModule) DeepCopy ¶
func (in *EmqxBrokerModule) DeepCopy() *EmqxBrokerModule
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxBrokerModule.
func (*EmqxBrokerModule) DeepCopyInto ¶
func (in *EmqxBrokerModule) DeepCopyInto(out *EmqxBrokerModule)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxBrokerModuleList ¶
type EmqxBrokerModuleList struct {
Items []EmqxBrokerModule
}
+kubebuilder:object:generate=false
func (*EmqxBrokerModuleList) Default ¶
func (list *EmqxBrokerModuleList) Default()
func (*EmqxBrokerModuleList) Lookup ¶
func (list *EmqxBrokerModuleList) Lookup(name string) (*EmqxBrokerModule, int)
func (*EmqxBrokerModuleList) String ¶
func (list *EmqxBrokerModuleList) String() string
type EmqxBrokerSpec ¶
type EmqxBrokerSpec struct { //+kubebuilder:default:=3 Replicas *int32 `json:"replicas,omitempty"` // ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec. // If specified, these secrets will be passed to individual puller implementations for them to use. // More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"` // Persistent describes the common attributes of storage devices Persistent corev1.PersistentVolumeClaimSpec `json:"persistent,omitempty"` // List of environment variables to set in the container. Env []corev1.EnvVar `json:"env,omitempty"` // If specified, the pod's scheduling constraints Affinity *corev1.Affinity `json:"affinity,omitempty"` // If specified, the pod's tolerations. ToleRations []corev1.Toleration `json:"toleRations,omitempty"` NodeName string `json:"nodeName,omitempty"` // NodeSelector is a selector which must be true for the pod to fit on a node. // Selector which must match a node's labels for the pod to be scheduled on that node. // More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/ NodeSelector map[string]string `json:"nodeSelector,omitempty"` // List of initialization containers belonging to the pod. // Init containers are executed in order prior to containers being started. If any // init container fails, the pod is considered to have failed and is handled according // to its restartPolicy. The name for an init container or normal container must be // unique among all containers. // Init containers may not have Lifecycle actions, Readiness probes, Liveness probes, or Startup probes. // The resourceRequirements of an init container are taken into account during scheduling // by finding the highest request/limit for each resource type, and then using the max of // of that value or the sum of the normal containers. Limits are applied to init containers // in a similar fashion. // Init containers cannot currently be added or removed. // More info: https://kubernetes.io/docs/concepts/workloads/pods/init-containers/ InitContainers []corev1.Container `json:"initContainers,omitempty"` // ExtraContainers represents extra containers to be added to the pod. // See https://github.com/emqx/emqx-operator/issues/252 ExtraContainers []corev1.Container `json:"extraContainers,omitempty"` EmqxTemplate EmqxBrokerTemplate `json:"emqxTemplate,omitempty"` }
EmqxBrokerSpec defines the desired state of EmqxBroker
func (*EmqxBrokerSpec) DeepCopy ¶
func (in *EmqxBrokerSpec) DeepCopy() *EmqxBrokerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxBrokerSpec.
func (*EmqxBrokerSpec) DeepCopyInto ¶
func (in *EmqxBrokerSpec) DeepCopyInto(out *EmqxBrokerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxBrokerTemplate ¶
type EmqxBrokerTemplate struct { // Registry will used for EMQX owner image, // like ${registry}/emqx/emqx and ${registry}/emqx/emqx-operator-reloader, // but it will not be used by other images, like sidecar container or else. Registry string `json:"registry,omitempty"` //+kubebuilder:validation:Required Image string `json:"image,omitempty"` // Image pull policy. // One of Always, Never, IfNotPresent. // Defaults to Always if :latest tag is specified, or IfNotPresent otherwise. // Cannot be updated. // More info: https://kubernetes.io/docs/concepts/containers/images#updating-images ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"` // Username for EMQX Dashboard and API //+kubebuilder:default:="admin" Username string `json:"username,omitempty"` // Password for EMQX Dashboard and API //+kubebuilder:default:="public" Password string `json:"password,omitempty"` // See https://github.com/emqx/emqx-operator/pull/72 ExtraVolumes []corev1.Volume `json:"extraVolumes,omitempty"` // See https://github.com/emqx/emqx-operator/pull/72 ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"` // Config represents the configurations of EMQX // More info: https://www.emqx.io/docs/en/v4.4/configuration/configuration.html EmqxConfig EmqxConfig `json:"config,omitempty"` // Arguments to the entrypoint. The container image's CMD is used if this is not provided. // More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell Args []string `json:"args,omitempty"` // SecurityContext defines the security options the container should be run with. // If set, the fields of SecurityContext override the equivalent fields of PodSecurityContext. // More info: https://kubernetes.io/docs/tasks/configure-pod-container/security-context/ SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"` // Compute Resources required by EMQX container. // More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/ Resources corev1.ResourceRequirements `json:"resources,omitempty"` // Periodic probe of container service readiness. // Container will be removed from service endpoints if the probe fails. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty"` // Periodic probe of container liveness. // Container will be restarted if the probe fails. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty"` // StartupProbe indicates that the Pod has successfully initialized. // If specified, no other probes are executed until this completes successfully. // If this probe fails, the Pod will be restarted, just as if the livenessProbe failed. // This can be used to provide different probe parameters at the beginning of a Pod's lifecycle, // when it might take a long time to load data or warm a cache, than during steady-state operation. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes StartupProbe *corev1.Probe `json:"startupProbe,omitempty"` // ServiceTemplate defines a logical set of ports and a policy by which to access them ServiceTemplate ServiceTemplate `json:"serviceTemplate,omitempty"` // ACL defines ACL rules // More info: https://www.emqx.io/docs/en/v4.4/advanced/acl.html ACL []string `json:"acl,omitempty"` // Modules define functional modules for EMQX broker Modules []EmqxBrokerModule `json:"modules,omitempty"` }
func (*EmqxBrokerTemplate) DeepCopy ¶
func (in *EmqxBrokerTemplate) DeepCopy() *EmqxBrokerTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxBrokerTemplate.
func (*EmqxBrokerTemplate) DeepCopyInto ¶
func (in *EmqxBrokerTemplate) DeepCopyInto(out *EmqxBrokerTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxConfig ¶
func (EmqxConfig) DeepCopy ¶
func (in EmqxConfig) DeepCopy() EmqxConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxConfig.
func (EmqxConfig) DeepCopyInto ¶
func (in EmqxConfig) DeepCopyInto(out *EmqxConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (EmqxConfig) Default ¶
func (config EmqxConfig) Default(emqx client.Object)
type EmqxEnterprise ¶
type EmqxEnterprise struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EmqxEnterpriseSpec `json:"spec,omitempty"` Status `json:"status,omitempty"` }
EmqxEnterprise is the Schema for the emqxEnterprises API
func (*EmqxEnterprise) ConvertFrom ¶
func (dst *EmqxEnterprise) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the Hub version (v1) to this version.
func (*EmqxEnterprise) ConvertTo ¶
func (src *EmqxEnterprise) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this version to the Hub version (v1).
func (*EmqxEnterprise) DeepCopy ¶
func (in *EmqxEnterprise) DeepCopy() *EmqxEnterprise
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxEnterprise.
func (*EmqxEnterprise) DeepCopyInto ¶
func (in *EmqxEnterprise) DeepCopyInto(out *EmqxEnterprise)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxEnterprise) DeepCopyObject ¶
func (in *EmqxEnterprise) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*EmqxEnterprise) GetACL ¶
func (emqx *EmqxEnterprise) GetACL() []string
func (*EmqxEnterprise) GetAPIVersion ¶
func (emqx *EmqxEnterprise) GetAPIVersion() string
func (*EmqxEnterprise) GetAffinity ¶
func (emqx *EmqxEnterprise) GetAffinity() *corev1.Affinity
func (*EmqxEnterprise) GetArgs ¶
func (emqx *EmqxEnterprise) GetArgs() []string
func (*EmqxEnterprise) GetEmqxConfig ¶
func (emqx *EmqxEnterprise) GetEmqxConfig() EmqxConfig
func (*EmqxEnterprise) GetEnv ¶
func (emqx *EmqxEnterprise) GetEnv() []corev1.EnvVar
func (*EmqxEnterprise) GetExtraContainers ¶
func (emqx *EmqxEnterprise) GetExtraContainers() []corev1.Container
func (*EmqxEnterprise) GetExtraVolumeMounts ¶
func (emqx *EmqxEnterprise) GetExtraVolumeMounts() []corev1.VolumeMount
func (*EmqxEnterprise) GetExtraVolumes ¶
func (emqx *EmqxEnterprise) GetExtraVolumes() []corev1.Volume
func (*EmqxEnterprise) GetImage ¶
func (emqx *EmqxEnterprise) GetImage() string
func (*EmqxEnterprise) GetImagePullPolicy ¶
func (emqx *EmqxEnterprise) GetImagePullPolicy() corev1.PullPolicy
func (*EmqxEnterprise) GetImagePullSecrets ¶
func (emqx *EmqxEnterprise) GetImagePullSecrets() []corev1.LocalObjectReference
func (*EmqxEnterprise) GetInitContainers ¶
func (emqx *EmqxEnterprise) GetInitContainers() []corev1.Container
func (*EmqxEnterprise) GetKind ¶
func (emqx *EmqxEnterprise) GetKind() string
func (*EmqxEnterprise) GetLicense ¶
func (emqx *EmqxEnterprise) GetLicense() License
func (*EmqxEnterprise) GetLivenessProbe ¶
func (emqx *EmqxEnterprise) GetLivenessProbe() *corev1.Probe
func (*EmqxEnterprise) GetModules ¶
func (emqx *EmqxEnterprise) GetModules() []EmqxEnterpriseModule
func (*EmqxEnterprise) GetNodeName ¶
func (emqx *EmqxEnterprise) GetNodeName() string
func (*EmqxEnterprise) GetNodeSelector ¶
func (emqx *EmqxEnterprise) GetNodeSelector() map[string]string
func (*EmqxEnterprise) GetPassword ¶
func (emqx *EmqxEnterprise) GetPassword() string
func (*EmqxEnterprise) GetPersistent ¶
func (emqx *EmqxEnterprise) GetPersistent() corev1.PersistentVolumeClaimSpec
func (*EmqxEnterprise) GetReadinessProbe ¶
func (emqx *EmqxEnterprise) GetReadinessProbe() *corev1.Probe
func (*EmqxEnterprise) GetRegistry ¶
func (emqx *EmqxEnterprise) GetRegistry() string
func (*EmqxEnterprise) GetReplicas ¶
func (emqx *EmqxEnterprise) GetReplicas() *int32
func (*EmqxEnterprise) GetResource ¶
func (emqx *EmqxEnterprise) GetResource() corev1.ResourceRequirements
func (*EmqxEnterprise) GetSecurityContext ¶
func (emqx *EmqxEnterprise) GetSecurityContext() *corev1.PodSecurityContext
func (*EmqxEnterprise) GetServiceTemplate ¶
func (emqx *EmqxEnterprise) GetServiceTemplate() ServiceTemplate
func (*EmqxEnterprise) GetStartupProbe ¶
func (emqx *EmqxEnterprise) GetStartupProbe() *corev1.Probe
func (*EmqxEnterprise) GetStatus ¶
func (emqx *EmqxEnterprise) GetStatus() Status
func (*EmqxEnterprise) GetToleRations ¶
func (emqx *EmqxEnterprise) GetToleRations() []corev1.Toleration
func (*EmqxEnterprise) GetUsername ¶
func (emqx *EmqxEnterprise) GetUsername() string
func (*EmqxEnterprise) SetACL ¶
func (emqx *EmqxEnterprise) SetACL(acl []string)
func (*EmqxEnterprise) SetAPIVersion ¶
func (emqx *EmqxEnterprise) SetAPIVersion(version string)
func (*EmqxEnterprise) SetAffinity ¶
func (emqx *EmqxEnterprise) SetAffinity(affinity *corev1.Affinity)
func (*EmqxEnterprise) SetArgs ¶
func (emqx *EmqxEnterprise) SetArgs(args []string)
func (*EmqxEnterprise) SetEmqxConfig ¶
func (emqx *EmqxEnterprise) SetEmqxConfig(config EmqxConfig)
func (*EmqxEnterprise) SetEnv ¶
func (emqx *EmqxEnterprise) SetEnv(env []corev1.EnvVar)
func (*EmqxEnterprise) SetExtraContainers ¶
func (emqx *EmqxEnterprise) SetExtraContainers(containers []corev1.Container)
func (*EmqxEnterprise) SetImage ¶
func (emqx *EmqxEnterprise) SetImage(image string)
func (*EmqxEnterprise) SetImagePullPolicy ¶
func (emqx *EmqxEnterprise) SetImagePullPolicy(pullPolicy corev1.PullPolicy)
func (*EmqxEnterprise) SetImagePullSecrets ¶
func (emqx *EmqxEnterprise) SetImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference)
func (*EmqxEnterprise) SetInitContainers ¶
func (emqx *EmqxEnterprise) SetInitContainers(containers []corev1.Container)
func (*EmqxEnterprise) SetKind ¶
func (emqx *EmqxEnterprise) SetKind(kind string)
func (*EmqxEnterprise) SetLicense ¶
func (emqx *EmqxEnterprise) SetLicense(license License)
func (*EmqxEnterprise) SetLivenessProbe ¶
func (emqx *EmqxEnterprise) SetLivenessProbe(probe *corev1.Probe)
func (*EmqxEnterprise) SetModules ¶
func (emqx *EmqxEnterprise) SetModules(modules []EmqxEnterpriseModule)
func (*EmqxEnterprise) SetNodeName ¶
func (emqx *EmqxEnterprise) SetNodeName(nodeName string)
func (*EmqxEnterprise) SetNodeSelector ¶
func (emqx *EmqxEnterprise) SetNodeSelector(nodeSelector map[string]string)
func (*EmqxEnterprise) SetPassword ¶
func (emqx *EmqxEnterprise) SetPassword(password string)
func (*EmqxEnterprise) SetPersistent ¶
func (emqx *EmqxEnterprise) SetPersistent(persistent corev1.PersistentVolumeClaimSpec)
func (*EmqxEnterprise) SetReadinessProbe ¶
func (emqx *EmqxEnterprise) SetReadinessProbe(probe *corev1.Probe)
func (*EmqxEnterprise) SetRegistry ¶
func (emqx *EmqxEnterprise) SetRegistry(registry string)
func (*EmqxEnterprise) SetReplicas ¶
func (emqx *EmqxEnterprise) SetReplicas(replicas *int32)
func (*EmqxEnterprise) SetResource ¶
func (emqx *EmqxEnterprise) SetResource(resource corev1.ResourceRequirements)
func (*EmqxEnterprise) SetSecurityContext ¶
func (emqx *EmqxEnterprise) SetSecurityContext(securityContext *corev1.PodSecurityContext)
func (*EmqxEnterprise) SetServiceTemplate ¶
func (emqx *EmqxEnterprise) SetServiceTemplate(serviceTemplate ServiceTemplate)
func (*EmqxEnterprise) SetStartupProbe ¶
func (emqx *EmqxEnterprise) SetStartupProbe(probe *corev1.Probe)
func (*EmqxEnterprise) SetStatus ¶
func (emqx *EmqxEnterprise) SetStatus(status Status)
func (*EmqxEnterprise) SetToleRations ¶
func (emqx *EmqxEnterprise) SetToleRations(tolerations []corev1.Toleration)
func (*EmqxEnterprise) SetUsername ¶
func (emqx *EmqxEnterprise) SetUsername(username string)
type EmqxEnterpriseList ¶
type EmqxEnterpriseList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []EmqxEnterprise `json:"items"` }
EmqxEnterpriseList contains a list of EmqxEnterprise
func (*EmqxEnterpriseList) DeepCopy ¶
func (in *EmqxEnterpriseList) DeepCopy() *EmqxEnterpriseList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxEnterpriseList.
func (*EmqxEnterpriseList) DeepCopyInto ¶
func (in *EmqxEnterpriseList) DeepCopyInto(out *EmqxEnterpriseList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxEnterpriseList) DeepCopyObject ¶
func (in *EmqxEnterpriseList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EmqxEnterpriseModule ¶
type EmqxEnterpriseModule struct { Name string `json:"name,omitempty"` Enable bool `json:"enable,omitempty"` // +kubebuilder:pruning:PreserveUnknownFields Configs runtime.RawExtension `json:"configs,omitempty"` }
+kubebuilder:object:generate=true
func (*EmqxEnterpriseModule) DeepCopy ¶
func (in *EmqxEnterpriseModule) DeepCopy() *EmqxEnterpriseModule
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxEnterpriseModule.
func (*EmqxEnterpriseModule) DeepCopyInto ¶
func (in *EmqxEnterpriseModule) DeepCopyInto(out *EmqxEnterpriseModule)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxEnterpriseModuleList ¶
type EmqxEnterpriseModuleList struct {
Items []EmqxEnterpriseModule
}
+kubebuilder:object:generate=false
func (*EmqxEnterpriseModuleList) String ¶
func (list *EmqxEnterpriseModuleList) String() string
type EmqxEnterpriseSpec ¶
type EmqxEnterpriseSpec struct { //+kubebuilder:default:=3 Replicas *int32 `json:"replicas,omitempty"` // ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec. // If specified, these secrets will be passed to individual puller implementations for them to use. // More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"` // Persistent describes the common attributes of storage devices Persistent corev1.PersistentVolumeClaimSpec `json:"persistent,omitempty"` // List of environment variables to set in the container. Env []corev1.EnvVar `json:"env,omitempty"` // If specified, the pod's scheduling constraints Affinity *corev1.Affinity `json:"affinity,omitempty"` // If specified, the pod's tolerations. ToleRations []corev1.Toleration `json:"toleRations,omitempty"` NodeName string `json:"nodeName,omitempty"` // NodeSelector is a selector which must be true for the pod to fit on a node. // Selector which must match a node's labels for the pod to be scheduled on that node. // More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/ NodeSelector map[string]string `json:"nodeSelector,omitempty"` // List of initialization containers belonging to the pod. // Init containers are executed in order prior to containers being started. If any // init container fails, the pod is considered to have failed and is handled according // to its restartPolicy. The name for an init container or normal container must be // unique among all containers. // Init containers may not have Lifecycle actions, Readiness probes, Liveness probes, or Startup probes. // The resourceRequirements of an init container are taken into account during scheduling // by finding the highest request/limit for each resource type, and then using the max of // of that value or the sum of the normal containers. Limits are applied to init containers // in a similar fashion. // Init containers cannot currently be added or removed. // More info: https://kubernetes.io/docs/concepts/workloads/pods/init-containers/ InitContainers []corev1.Container `json:"initContainers,omitempty"` // ExtraContainers represents extra containers to be added to the pod. // See https://github.com/emqx/emqx-operator/issues/252 ExtraContainers []corev1.Container `json:"extraContainers,omitempty"` EmqxTemplate EmqxEnterpriseTemplate `json:"emqxTemplate,omitempty"` }
EmqxEnterpriseSpec defines the desired state of EmqxEnterprise
func (*EmqxEnterpriseSpec) DeepCopy ¶
func (in *EmqxEnterpriseSpec) DeepCopy() *EmqxEnterpriseSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxEnterpriseSpec.
func (*EmqxEnterpriseSpec) DeepCopyInto ¶
func (in *EmqxEnterpriseSpec) DeepCopyInto(out *EmqxEnterpriseSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxEnterpriseTemplate ¶
type EmqxEnterpriseTemplate struct { // Registry will used for EMQX owner image, // like ${registry}/emqx/emqx-ee and ${registry}/emqx/emqx-operator-reloader, // but it will not be used by other images, like sidecar container or else. Registry string `json:"registry,omitempty"` //+kubebuilder:validation:Required Image string `json:"image,omitempty"` // Image pull policy. // One of Always, Never, IfNotPresent. // Defaults to Always if :latest tag is specified, or IfNotPresent otherwise. // Cannot be updated. // More info: https://kubernetes.io/docs/concepts/containers/images#updating-images ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"` // Username for EMQX Dashboard and API //+kubebuilder:default:="admin" Username string `json:"username,omitempty"` // Password for EMQX Dashboard and API //+kubebuilder:default:="public" Password string `json:"password,omitempty"` // See https://github.com/emqx/emqx-operator/pull/72 ExtraVolumes []corev1.Volume `json:"extraVolumes,omitempty"` // See https://github.com/emqx/emqx-operator/pull/72 ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"` // Config represents the configurations of EMQX // More info: https://docs.emqx.com/en/enterprise/v4.4/configuration/configuration.html EmqxConfig EmqxConfig `json:"config,omitempty"` // Arguments to the entrypoint. The container image's CMD is used if this is not provided. // More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell Args []string `json:"args,omitempty"` // SecurityContext defines the security options the container should be run with. // If set, the fields of SecurityContext override the equivalent fields of PodSecurityContext. // More info: https://kubernetes.io/docs/tasks/configure-pod-container/security-context/ SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"` // Compute Resources required by EMQX container. // More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/ Resources corev1.ResourceRequirements `json:"resources,omitempty"` // Periodic probe of container service readiness. // Container will be removed from service endpoints if the probe fails. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty"` // Periodic probe of container liveness. // Container will be restarted if the probe fails. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty"` // StartupProbe indicates that the Pod has successfully initialized. // If specified, no other probes are executed until this completes successfully. // If this probe fails, the Pod will be restarted, just as if the livenessProbe failed. // This can be used to provide different probe parameters at the beginning of a Pod's lifecycle, // when it might take a long time to load data or warm a cache, than during steady-state operation. // More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes StartupProbe *corev1.Probe `json:"startupProbe,omitempty"` // ServiceTemplate defines a logical set of ports and a policy by which to access them ServiceTemplate ServiceTemplate `json:"serviceTemplate,omitempty"` // ACL defines ACL rules // More info: https://docs.emqx.com/en/enterprise/v4.4/modules/internal_acl.html#builtin-acl-file-2 ACL []string `json:"acl,omitempty"` // Modules define functional modules for EMQX Enterprise broker // More info: https://docs.emqx.com/en/enterprise/v4.4/modules/modules.html Modules []EmqxEnterpriseModule `json:"modules,omitempty"` // License for EMQX Enterprise broker License License `json:"license,omitempty"` }
func (*EmqxEnterpriseTemplate) DeepCopy ¶
func (in *EmqxEnterpriseTemplate) DeepCopy() *EmqxEnterpriseTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxEnterpriseTemplate.
func (*EmqxEnterpriseTemplate) DeepCopyInto ¶
func (in *EmqxEnterpriseTemplate) DeepCopyInto(out *EmqxEnterpriseTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxNode ¶
type EmqxNode struct { // EMQX node name Node string `json:"node,omitempty"` // EMQX node status NodeStatus string `json:"node_status,omitempty"` // Erlang/OTP version used by EMQX OTPRelease string `json:"otp_release,omitempty"` // EMQX version Version string `json:"version,omitempty"` }
func (*EmqxNode) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxNode.
func (*EmqxNode) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxPlugin ¶
type EmqxPlugin struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EmqxPluginSpec `json:"spec,omitempty"` Status EmqxPluginStatus `json:"status,omitempty"` }
EmqxPlugin is the Schema for the emqxplugins API
func (*EmqxPlugin) ConvertFrom ¶
func (dst *EmqxPlugin) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the Hub version (v1) to this version.
func (*EmqxPlugin) ConvertTo ¶
func (src *EmqxPlugin) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this version to the Hub version (v1).
func (*EmqxPlugin) DeepCopy ¶
func (in *EmqxPlugin) DeepCopy() *EmqxPlugin
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxPlugin.
func (*EmqxPlugin) DeepCopyInto ¶
func (in *EmqxPlugin) DeepCopyInto(out *EmqxPlugin)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxPlugin) DeepCopyObject ¶
func (in *EmqxPlugin) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EmqxPluginList ¶
type EmqxPluginList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []EmqxPlugin `json:"items"` }
EmqxPluginList contains a list of EmqxPlugin
func (*EmqxPluginList) DeepCopy ¶
func (in *EmqxPluginList) DeepCopy() *EmqxPluginList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxPluginList.
func (*EmqxPluginList) DeepCopyInto ¶
func (in *EmqxPluginList) DeepCopyInto(out *EmqxPluginList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmqxPluginList) DeepCopyObject ¶
func (in *EmqxPluginList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EmqxPluginSpec ¶
type EmqxPluginSpec struct { // More info: https://www.emqx.io/docs/en/v4.4/advanced/plugins.html#list-of-plugins //+kubebuilder:validation:Required PluginName string `json:"pluginName,omitempty"` // Selector matches the labels of the EMQX //+kubebuilder:validation:Required Selector map[string]string `json:"selector,omitempty"` // Config defines the configurations of the EMQX plugins Config map[string]string `json:"config,omitempty"` }
EmqxPluginSpec defines the desired state of EmqxPlugin
func (*EmqxPluginSpec) DeepCopy ¶
func (in *EmqxPluginSpec) DeepCopy() *EmqxPluginSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxPluginSpec.
func (*EmqxPluginSpec) DeepCopyInto ¶
func (in *EmqxPluginSpec) DeepCopyInto(out *EmqxPluginSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxPluginStatus ¶
type EmqxPluginStatus struct {
Phase phase `json:"phase,omitempty"`
}
EmqxPluginStatus defines the observed state of EmqxPlugin
func (*EmqxPluginStatus) DeepCopy ¶
func (in *EmqxPluginStatus) DeepCopy() *EmqxPluginStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmqxPluginStatus.
func (*EmqxPluginStatus) DeepCopyInto ¶
func (in *EmqxPluginStatus) DeepCopyInto(out *EmqxPluginStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmqxSpec ¶
type EmqxSpec interface { Default() ValidateCreate() error ValidateUpdate(runtime.Object) error ValidateDelete() error GetReplicas() *int32 SetReplicas(replicas *int32) GetPersistent() corev1.PersistentVolumeClaimSpec SetPersistent(persistent corev1.PersistentVolumeClaimSpec) GetNodeName() string SetNodeName(nodeName string) GetNodeSelector() map[string]string SetNodeSelector(nodeSelector map[string]string) GetAnnotations() map[string]string SetAnnotations(annotations map[string]string) GetAffinity() *corev1.Affinity SetAffinity(affinity *corev1.Affinity) GetToleRations() []corev1.Toleration SetToleRations(tolerations []corev1.Toleration) GetInitContainers() []corev1.Container SetInitContainers(containers []corev1.Container) GetExtraContainers() []corev1.Container SetExtraContainers(containers []corev1.Container) GetImage() string SetImage(image string) GetImagePullPolicy() corev1.PullPolicy SetImagePullPolicy(pullPolicy corev1.PullPolicy) GetImagePullSecrets() []corev1.LocalObjectReference SetImagePullSecrets([]corev1.LocalObjectReference) GetSecurityContext() *corev1.PodSecurityContext SetSecurityContext(securityContext *corev1.PodSecurityContext) GetResource() corev1.ResourceRequirements SetResource(resource corev1.ResourceRequirements) GetExtraVolumes() []corev1.Volume GetExtraVolumeMounts() []corev1.VolumeMount GetReadinessProbe() *corev1.Probe SetReadinessProbe(probe *corev1.Probe) GetLivenessProbe() *corev1.Probe SetLivenessProbe(probe *corev1.Probe) GetStartupProbe() *corev1.Probe SetStartupProbe(probe *corev1.Probe) GetEmqxConfig() EmqxConfig SetEmqxConfig(config EmqxConfig) GetEnv() []corev1.EnvVar SetEnv(env []corev1.EnvVar) GetArgs() []string SetArgs(args []string) GetACL() []string SetACL(acl []string) GetServiceTemplate() ServiceTemplate SetServiceTemplate(ServiceTemplate) GetUsername() string SetUsername(username string) GetPassword() string SetPassword(password string) GetStatus() Status SetStatus(status Status) GetRegistry() string SetRegistry(registry string) }
+kubebuilder:object:generate=false
type EmqxStatus ¶
type EmqxStatus interface { IsRunning() bool IsPluginInitialized() bool GetConditions() []Condition SetCondition(c Condition) }
+kubebuilder:object:generate=false
type License ¶
type License struct { // Data contains the secret data. Each key must consist of alphanumeric // characters, '-', '_' or '.'. The serialized form of the secret data is a // base64 encoded string, representing the arbitrary (possibly non-string) // data value here. Described in https://tools.ietf.org/html/rfc4648#section-4 Data []byte `json:"data,omitempty"` // StringData allows specifying non-binary secret data in string form. // It is provided as a write-only input field for convenience. // All keys and values are merged into the data field on write, overwriting any existing values. StringData string `json:"stringData,omitempty"` // SecretName is the name of the secret in the pod's namespace to use. // More info: https://kubernetes.io/docs/concepts/storage/volumes#secret SecretName string `json:"secretName,omitempty"` }
func (*License) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new License.
func (*License) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Names ¶
+kubebuilder:object:generate=false
func (Names) HeadlessSvc ¶
func (Names) LoadedModules ¶
func (Names) PluginsConfig ¶
type ServiceTemplate ¶
type ServiceTemplate struct { metav1.ObjectMeta `json:"metadata,omitempty"` Spec corev1.ServiceSpec `json:"spec,omitempty"` }
func (*ServiceTemplate) DeepCopy ¶
func (in *ServiceTemplate) DeepCopy() *ServiceTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceTemplate.
func (*ServiceTemplate) DeepCopyInto ¶
func (in *ServiceTemplate) DeepCopyInto(out *ServiceTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceTemplate) Default ¶
func (s *ServiceTemplate) Default(emqx Emqx)
func (*ServiceTemplate) MergePorts ¶
func (s *ServiceTemplate) MergePorts(ports []corev1.ServicePort)
type Status ¶
type Status struct { // Represents the latest available observations of a EMQX current state. Conditions []Condition `json:"conditions,omitempty"` // Nodes of the EMQX cluster EmqxNodes []EmqxNode `json:"emqxNodes,omitempty"` // replicas is the number of Pods created by the EMQX Custom Resource controller. Replicas int32 `json:"replicas,omitempty"` // readyReplicas is the number of pods created for this EMQX Custom Resource with a EMQX Ready. ReadyReplicas int32 `json:"readyReplicas,omitempty"` }
Emqx Status defines the observed state of EMQX
func (*Status) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
func (*Status) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.