v1beta2

package
v0.0.0-...-c7d99ed Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 15, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package v1beta2 contains API Schema definitions for the apps v1beta2 API group +kubebuilder:object:generate=true +groupName=apps.emqx.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "apps.emqx.io", Version: "v1beta2"}

	// 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 ACL 

type ACL struct {
	//+kubebuilder:validation:Enum=allow;deny
	//+kubebuilder:validation:Required
	Permission string `json:"permission"`
	Username   string `json:"username,omitempty"`
	ClientID   string `json:"clientid,omitempty"`
	IPAddress  string `json:"ipaddress,omitempty"`
	//+kubebuilder:validation:Enum=publish;subscribe
	Action string `json:"action,omitempty"`
	Topics Topics `json:"topics,omitempty"`
}

+kubebuilder:object:generate=true

func (*ACL) DeepCopy 

func (in *ACL) DeepCopy() *ACL

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

func (*ACL) DeepCopyInto 

func (in *ACL) DeepCopyInto(out *ACL)

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

type ACLs 

type ACLs struct {
	Items []ACL
}

+kubebuilder:object:generate=false

func (*ACLs) Default 

func (a *ACLs) Default()

func (*ACLs) String 

func (a *ACLs) String() string

type Certificate 

type Certificate struct {
	WSS   CertificateConf `json:"wss,omitempty"`
	MQTTS CertificateConf `json:"mqtts,omitempty"`
}

+kubebuilder:object:generate=true

func (*Certificate) DeepCopy 

func (in *Certificate) DeepCopy() *Certificate

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

func (*Certificate) DeepCopyInto 

func (in *Certificate) DeepCopyInto(out *Certificate)

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

type CertificateConf 

type CertificateConf struct {
	Data       CertificateData       `json:"data,omitempty"`
	StringData CertificateStringData `json:"stringData,omitempty"`
}

func (*CertificateConf) DeepCopy 

func (in *CertificateConf) DeepCopy() *CertificateConf

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

func (*CertificateConf) DeepCopyInto 

func (in *CertificateConf) DeepCopyInto(out *CertificateConf)

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

type CertificateData 

type CertificateData struct {
	CaCert  []byte `json:"ca.crt,omitempty"`
	TLSCert []byte `json:"tls.crt,omitempty"`
	TLSKey  []byte `json:"tls.key,omitempty"`
}

func (*CertificateData) DeepCopy 

func (in *CertificateData) DeepCopy() *CertificateData

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

func (*CertificateData) DeepCopyInto 

func (in *CertificateData) DeepCopyInto(out *CertificateData)

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

type CertificateStringData 

type CertificateStringData struct {
	CaCert  string `json:"ca.crt,omitempty"`
	TLSCert string `json:"tls.crt,omitempty"`
	TLSKey  string `json:"tls.key,omitempty"`
}

func (*CertificateStringData) DeepCopy 

func (in *CertificateStringData) DeepCopy() *CertificateStringData

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

func (*CertificateStringData) DeepCopyInto 

func (in *CertificateStringData) DeepCopyInto(out *CertificateStringData)

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

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 (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

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 (
	ClusterConditionAvailable   ConditionType = "Available"
	ClusterConditionHealthy     ConditionType = "Healthy"
	ClusterConditionRunning     ConditionType = "Running"
	ClusterConditionCreating    ConditionType = "Creating"
	ClusterConditionRecovering  ConditionType = "Recovering"
	ClusterConditionScaling     ConditionType = "Scaling"
	ClusterConditionScalingDown ConditionType = "ScalingDown"
	ClusterConditionUpgrading   ConditionType = "Upgrading"
	ClusterConditionUpdating    ConditionType = "Updating"
	ClusterConditionFailed      ConditionType = "Failed"
)

type Emqx 

type Emqx interface {
	v1.Type
	v1.Object

	EmqxSpec
	EmqxStatus

	client.Object
}

+kubebuilder:object:generate=false

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) 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) Default 

func (r *EmqxBroker) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*EmqxBroker) GetACL 

func (emqx *EmqxBroker) GetACL() []ACL

func (*EmqxBroker) GetAPIVersion 

func (emqx *EmqxBroker) GetAPIVersion() string

func (*EmqxBroker) GetAffinity 

func (emqx *EmqxBroker) GetAffinity() *corev1.Affinity

func (*EmqxBroker) GetAnnotations 

func (emqx *EmqxBroker) GetAnnotations() map[string]string

func (*EmqxBroker) GetEnv 

func (emqx *EmqxBroker) GetEnv() []corev1.EnvVar

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) GetKind 

func (emqx *EmqxBroker) GetKind() string

func (*EmqxBroker) GetListener 

func (emqx *EmqxBroker) GetListener() Listener

func (*EmqxBroker) GetModules 

func (emqx *EmqxBroker) GetModules() []EmqxBrokerModules

func (*EmqxBroker) GetNodeName 

func (emqx *EmqxBroker) GetNodeName() string

func (*EmqxBroker) GetNodeSelector 

func (emqx *EmqxBroker) GetNodeSelector() map[string]string

func (*EmqxBroker) GetPlugins 

func (emqx *EmqxBroker) GetPlugins() []Plugin

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) GetServiceAccountName 

func (emqx *EmqxBroker) GetServiceAccountName() string

func (*EmqxBroker) GetStorage 

func (emqx *EmqxBroker) GetStorage() corev1.PersistentVolumeClaimSpec

func (*EmqxBroker) GetTelegrafTemplate 

func (emqx *EmqxBroker) GetTelegrafTemplate() *TelegrafTemplate

func (*EmqxBroker) GetToleRations 

func (emqx *EmqxBroker) GetToleRations() []corev1.Toleration

func (*EmqxBroker) Hub 

func (*EmqxBroker) Hub()

func (*EmqxBroker) SetACL 

func (emqx *EmqxBroker) SetACL(acl []ACL)

func (*EmqxBroker) SetAPIVersion 

func (emqx *EmqxBroker) SetAPIVersion(version string)

func (*EmqxBroker) SetAffinity 

func (emqx *EmqxBroker) SetAffinity(affinity *corev1.Affinity)

func (*EmqxBroker) SetAnnotations 

func (emqx *EmqxBroker) SetAnnotations(annotations map[string]string)

func (*EmqxBroker) SetEnv 

func (emqx *EmqxBroker) SetEnv(env []corev1.EnvVar)

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) SetKind 

func (emqx *EmqxBroker) SetKind(kind string)

func (*EmqxBroker) SetListener 

func (emqx *EmqxBroker) SetListener(listener Listener)

func (*EmqxBroker) SetModules 

func (emqx *EmqxBroker) SetModules(modules []EmqxBrokerModules)

func (*EmqxBroker) SetNodeName 

func (emqx *EmqxBroker) SetNodeName(nodeName string)

func (*EmqxBroker) SetNodeSelector 

func (emqx *EmqxBroker) SetNodeSelector(nodeSelector map[string]string)

func (*EmqxBroker) SetPlugins 

func (emqx *EmqxBroker) SetPlugins(plugins []Plugin)

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) SetServiceAccountName 

func (emqx *EmqxBroker) SetServiceAccountName(serviceAccountName string)

func (*EmqxBroker) SetStorage 

func (emqx *EmqxBroker) SetStorage(storage corev1.PersistentVolumeClaimSpec)

func (*EmqxBroker) SetTelegrafTemplate 

func (emqx *EmqxBroker) SetTelegrafTemplate(telegrafTemplate *TelegrafTemplate)

func (*EmqxBroker) SetToleRations 

func (emqx *EmqxBroker) SetToleRations(tolerations []corev1.Toleration)

func (*EmqxBroker) SetupWebhookWithManager 

func (r *EmqxBroker) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*EmqxBroker) ValidateCreate 

func (r *EmqxBroker) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*EmqxBroker) ValidateDelete 

func (r *EmqxBroker) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*EmqxBroker) ValidateUpdate 

func (r *EmqxBroker) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

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 EmqxBrokerModules 

type EmqxBrokerModules struct {
	Name   string `json:"name,omitempty"`
	Enable bool   `json:"enable,omitempty"`
}

+kubebuilder:object:generate=true

func (*EmqxBrokerModules) DeepCopy 

func (in *EmqxBrokerModules) DeepCopy() *EmqxBrokerModules

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

func (*EmqxBrokerModules) DeepCopyInto 

func (in *EmqxBrokerModules) DeepCopyInto(out *EmqxBrokerModules)

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

type EmqxBrokerModulesList 

type EmqxBrokerModulesList struct {
	Items []EmqxBrokerModules
}

+kubebuilder:object:generate=false

func (*EmqxBrokerModulesList) Default 

func (list *EmqxBrokerModulesList) Default()

func (*EmqxBrokerModulesList) Lookup 

func (list *EmqxBrokerModulesList) Lookup(name string) (*EmqxBrokerModules, int)

func (*EmqxBrokerModulesList) String 

func (list *EmqxBrokerModulesList) String() string

type EmqxBrokerSpec 

type EmqxBrokerSpec struct {

	// The fields of Broker.
	//The replicas of emqx broker
	//+kubebuilder:default:=3
	Replicas *int32 `json:"replicas,omitempty"`

	//+kubebuilder:validation:Required
	Image            string                        `json:"image,omitempty"`
	ImagePullPolicy  corev1.PullPolicy             `json:"imagePullPolicy,omitempty"`
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// The service account name which is being bind with the service
	// account of the crd instance.
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	Storage corev1.PersistentVolumeClaimSpec `json:"storage,omitempty"`

	// The labels configure must be specified.
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`

	Affinity     *corev1.Affinity    `json:"affinity,omitempty"`
	ToleRations  []corev1.Toleration `json:"toleRations,omitempty"`
	NodeName     string              `json:"nodeName,omitempty"`
	NodeSelector map[string]string   `json:"nodeSelector,omitempty"`

	ExtraVolumes      []corev1.Volume      `json:"extraVolumes,omitempty"`
	ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"`

	Env []corev1.EnvVar `json:"env,omitempty"`

	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"`

	EmqxTemplate EmqxBrokerTemplate `json:"emqxTemplate,omitempty"`

	TelegrafTemplate *TelegrafTemplate `json:"telegrafTemplate,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 {
	Listener Listener            `json:"listener,omitempty"`
	ACL      []ACL               `json:"acl,omitempty"`
	Plugins  []Plugin            `json:"plugins,omitempty"`
	Modules  []EmqxBrokerModules `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 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) 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) Default 

func (r *EmqxEnterprise) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*EmqxEnterprise) GetACL 

func (emqx *EmqxEnterprise) GetACL() []ACL

func (*EmqxEnterprise) GetAPIVersion 

func (emqx *EmqxEnterprise) GetAPIVersion() string

func (*EmqxEnterprise) GetAffinity 

func (emqx *EmqxEnterprise) GetAffinity() *corev1.Affinity

func (*EmqxEnterprise) GetAnnotations 

func (emqx *EmqxEnterprise) GetAnnotations() map[string]string

func (*EmqxEnterprise) GetEnv 

func (emqx *EmqxEnterprise) GetEnv() []corev1.EnvVar

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) GetKind 

func (emqx *EmqxEnterprise) GetKind() string

func (*EmqxEnterprise) GetLicense 

func (emqx *EmqxEnterprise) GetLicense() string

func (*EmqxEnterprise) GetListener 

func (emqx *EmqxEnterprise) GetListener() Listener

func (*EmqxEnterprise) GetModules 

func (emqx *EmqxEnterprise) GetModules() []EmqxEnterpriseModules

func (*EmqxEnterprise) GetNodeName 

func (emqx *EmqxEnterprise) GetNodeName() string

func (*EmqxEnterprise) GetNodeSelector 

func (emqx *EmqxEnterprise) GetNodeSelector() map[string]string

func (*EmqxEnterprise) GetPlugins 

func (emqx *EmqxEnterprise) GetPlugins() []Plugin

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) GetServiceAccountName 

func (emqx *EmqxEnterprise) GetServiceAccountName() string

func (*EmqxEnterprise) GetStorage 

func (emqx *EmqxEnterprise) GetStorage() corev1.PersistentVolumeClaimSpec

func (*EmqxEnterprise) GetTelegrafTemplate 

func (emqx *EmqxEnterprise) GetTelegrafTemplate() *TelegrafTemplate

func (*EmqxEnterprise) GetToleRations 

func (emqx *EmqxEnterprise) GetToleRations() []corev1.Toleration

func (*EmqxEnterprise) Hub 

func (*EmqxEnterprise) Hub()

func (*EmqxEnterprise) SetACL 

func (emqx *EmqxEnterprise) SetACL(acl []ACL)

func (*EmqxEnterprise) SetAPIVersion 

func (emqx *EmqxEnterprise) SetAPIVersion(version string)

func (*EmqxEnterprise) SetAffinity 

func (emqx *EmqxEnterprise) SetAffinity(affinity *corev1.Affinity)

func (*EmqxEnterprise) SetAnnotations 

func (emqx *EmqxEnterprise) SetAnnotations(annotations map[string]string)

func (*EmqxEnterprise) SetEnv 

func (emqx *EmqxEnterprise) SetEnv(env []corev1.EnvVar)

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) SetKind 

func (emqx *EmqxEnterprise) SetKind(kind string)

func (*EmqxEnterprise) SetLicense 

func (emqx *EmqxEnterprise) SetLicense(license string)

func (*EmqxEnterprise) SetListener 

func (emqx *EmqxEnterprise) SetListener(listener Listener)

func (*EmqxEnterprise) SetModules 

func (emqx *EmqxEnterprise) SetModules(modules []EmqxEnterpriseModules)

func (*EmqxEnterprise) SetNodeName 

func (emqx *EmqxEnterprise) SetNodeName(nodeName string)

func (*EmqxEnterprise) SetNodeSelector 

func (emqx *EmqxEnterprise) SetNodeSelector(nodeSelector map[string]string)

func (*EmqxEnterprise) SetPlugins 

func (emqx *EmqxEnterprise) SetPlugins(plugins []Plugin)

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) SetServiceAccountName 

func (emqx *EmqxEnterprise) SetServiceAccountName(serviceAccountName string)

func (*EmqxEnterprise) SetStorage 

func (emqx *EmqxEnterprise) SetStorage(storage corev1.PersistentVolumeClaimSpec)

func (*EmqxEnterprise) SetTelegrafTemplate 

func (emqx *EmqxEnterprise) SetTelegrafTemplate(telegrafTemplate *TelegrafTemplate)

func (*EmqxEnterprise) SetToleRations 

func (emqx *EmqxEnterprise) SetToleRations(tolerations []corev1.Toleration)

func (*EmqxEnterprise) SetupWebhookWithManager 

func (r *EmqxEnterprise) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*EmqxEnterprise) ValidateCreate 

func (r *EmqxEnterprise) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*EmqxEnterprise) ValidateDelete 

func (r *EmqxEnterprise) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*EmqxEnterprise) ValidateUpdate 

func (r *EmqxEnterprise) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

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 EmqxEnterpriseModules 

type EmqxEnterpriseModules 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 (*EmqxEnterpriseModules) DeepCopy 

func (in *EmqxEnterpriseModules) DeepCopy() *EmqxEnterpriseModules

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

func (*EmqxEnterpriseModules) DeepCopyInto 

func (in *EmqxEnterpriseModules) DeepCopyInto(out *EmqxEnterpriseModules)

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

type EmqxEnterpriseModulesList 

type EmqxEnterpriseModulesList struct {
	Items []EmqxEnterpriseModules
}

+kubebuilder:object:generate=false

func (*EmqxEnterpriseModulesList) Append 

func (list *EmqxEnterpriseModulesList) Append(modules []EmqxEnterpriseModules)

func (*EmqxEnterpriseModulesList) Default 

func (list *EmqxEnterpriseModulesList) Default()

func (*EmqxEnterpriseModulesList) Lookup 

func (list *EmqxEnterpriseModulesList) Lookup(name string) (*EmqxEnterpriseModules, int)

func (*EmqxEnterpriseModulesList) Overwrite 

func (list *EmqxEnterpriseModulesList) Overwrite(modules []EmqxEnterpriseModules)

type EmqxEnterpriseSpec 

type EmqxEnterpriseSpec struct {

	// The fields of Broker.
	//The replicas of emqx broker
	//+kubebuilder:default:=3
	Replicas *int32 `json:"replicas,omitempty"`

	//+kubebuilder:validation:Required
	Image            string                        `json:"image,omitempty"`
	ImagePullPolicy  corev1.PullPolicy             `json:"imagePullPolicy,omitempty"`
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// The service account name which is being bind with the service
	// account of the crd instance.
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	Storage corev1.PersistentVolumeClaimSpec `json:"storage,omitempty"`

	// The labels configure must be specified.
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`

	Affinity     *corev1.Affinity    `json:"affinity,omitempty"`
	ToleRations  []corev1.Toleration `json:"toleRations,omitempty"`
	NodeName     string              `json:"nodeName,omitempty"`
	NodeSelector map[string]string   `json:"nodeSelector,omitempty"`

	ExtraVolumes      []corev1.Volume      `json:"extraVolumes,omitempty"`
	ExtraVolumeMounts []corev1.VolumeMount `json:"extraVolumeMounts,omitempty"`

	Env []corev1.EnvVar `json:"env,omitempty"`

	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"`

	EmqxTemplate     EmqxEnterpriseTemplate `json:"emqxTemplate,omitempty"`
	TelegrafTemplate *TelegrafTemplate      `json:"telegrafTemplate,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 {
	License  string                  `json:"license,omitempty"`
	Listener Listener                `json:"listener,omitempty"`
	ACL      []ACL                   `json:"acl,omitempty"`
	Plugins  []Plugin                `json:"plugins,omitempty"`
	Modules  []EmqxEnterpriseModules `json:"modules,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 EmqxSpec 

type EmqxSpec interface {
	GetReplicas() *int32
	SetReplicas(replicas *int32)

	GetImage() string
	SetImage(image string)

	GetImagePullPolicy() corev1.PullPolicy
	SetImagePullPolicy(pullPolicy corev1.PullPolicy)

	GetImagePullSecrets() []corev1.LocalObjectReference
	SetImagePullSecrets([]corev1.LocalObjectReference)

	GetServiceAccountName() string
	SetServiceAccountName(serviceAccountName string)

	GetResource() corev1.ResourceRequirements
	SetResource(resource corev1.ResourceRequirements)

	GetStorage() corev1.PersistentVolumeClaimSpec
	SetStorage(storage 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)

	GetListener() Listener
	SetListener(Listener)

	GetAffinity() *corev1.Affinity
	SetAffinity(affinity *corev1.Affinity)

	GetToleRations() []corev1.Toleration
	SetToleRations(tolerations []corev1.Toleration)

	GetExtraVolumes() []corev1.Volume
	GetExtraVolumeMounts() []corev1.VolumeMount

	GetACL() []ACL
	SetACL(acl []ACL)

	GetEnv() []corev1.EnvVar
	SetEnv(env []corev1.EnvVar)

	GetPlugins() []Plugin
	SetPlugins(plugins []Plugin)

	GetSecurityContext() *corev1.PodSecurityContext
	SetSecurityContext(securityContext *corev1.PodSecurityContext)

	GetTelegrafTemplate() *TelegrafTemplate
	SetTelegrafTemplate(telegraftedTemplate *TelegrafTemplate)
}

+kubebuilder:object:generate=false

type EmqxStatus 

type EmqxStatus interface {
	DescConditionsByTime()
	GetConditions() []Condition
	SetScalingUpCondition(message string)
	SetCreateCondition(message string)
	SetScalingDownCondition(message string)
	SetUpgradingCondition(message string)
	SetUpdatingCondition(message string)
	SetReadyCondition(message string)
	SetFailedCondition(message string)

	ClearCondition(t ConditionType)
	// contains filtered or unexported methods
}

+kubebuilder:object:generate=false

type Environments 

type Environments struct {
	Items []corev1.EnvVar
}

func (*Environments) Append 

func (e *Environments) Append(envs []corev1.EnvVar)

func (*Environments) ClusterForDNS 

func (e *Environments) ClusterForDNS(emqx client.Object)

func (*Environments) ClusterForK8S 

func (e *Environments) ClusterForK8S(emqx client.Object)

func (*Environments) DeepCopy 

func (in *Environments) DeepCopy() *Environments

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

func (*Environments) DeepCopyInto 

func (in *Environments) DeepCopyInto(out *Environments)

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

func (*Environments) Default 

func (e *Environments) Default(emqx client.Object)

func (*Environments) Lookup 

func (e *Environments) Lookup(name string) (*corev1.EnvVar, int)

func (*Environments) Overwrite 

func (e *Environments) Overwrite(envs []corev1.EnvVar)

type Listener 

type Listener struct {
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
	//+kubebuilder:validation:Enum=NodePort;LoadBalancer;ClusterIP
	Type                     corev1.ServiceType `json:"type,omitempty"`
	LoadBalancerIP           string             `json:"loadBalancerIP,omitempty" protobuf:"bytes,8,opt,name=loadBalancerIP"`
	LoadBalancerSourceRanges []string           `json:"loadBalancerSourceRanges,omitempty" protobuf:"bytes,9,opt,name=loadBalancerSourceRanges"`
	ExternalIPs              []string           `json:"externalIPs,omitempty" protobuf:"bytes,5,rep,name=externalIPs"`
	Ports                    Ports              `json:"ports,omitempty"`
	NodePorts                Ports              `json:"nodePorts,omitempty"`
	Certificate              Certificate        `json:"certificate,omitempty"`
}

+kubebuilder:object:generate=true

func (*Listener) DeepCopy 

func (in *Listener) DeepCopy() *Listener

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

func (*Listener) DeepCopyInto 

func (in *Listener) DeepCopyInto(out *Listener)

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

func (*Listener) Default 

func (l *Listener) Default()

type Names 

type Names struct {
	client.Object
}

+kubebuilder:object:generate=false

func (Names) ACL 

func (n Names) ACL() string

func (Names) Data 

func (n Names) Data() string

func (Names) HeadlessSvc 

func (n Names) HeadlessSvc() string

func (Names) License 

func (n Names) License() string

func (Names) Log 

func (n Names) Log() string

func (Names) MQTTSCertificate 

func (n Names) MQTTSCertificate() string

func (Names) Modules 

func (n Names) Modules() string

func (Names) Plugins 

func (n Names) Plugins() string

func (Names) Telegraf 

func (n Names) Telegraf() string

func (Names) WSSCertificate 

func (n Names) WSSCertificate() string

type Phase 

type Phase string

Phase of the RF status

type Plugin 

type Plugin struct {
	Name   string `json:"name,omitempty"`
	Enable bool   `json:"enable,omitempty"`
}

+kubebuilder:object:generate=true

func (*Plugin) DeepCopy 

func (in *Plugin) DeepCopy() *Plugin

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

func (*Plugin) DeepCopyInto 

func (in *Plugin) DeepCopyInto(out *Plugin)

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

type Plugins 

type Plugins struct {
	Items []Plugin
}

+kubebuilder:object:generate=false

func (*Plugins) Default 

func (p *Plugins) Default()

func (*Plugins) Lookup 

func (p *Plugins) Lookup(name string) (*Plugin, int)

func (*Plugins) String 

func (p *Plugins) String() string

type Ports 

type Ports struct {
	//+kubebuilder:validation:Maximum=65535
	MQTT int32 `json:"mqtt,omitempty"`
	//+kubebuilder:validation:Maximum=65535
	MQTTS int32 `json:"mqtts,omitempty"`
	//+kubebuilder:validation:Maximum=65535
	WS int32 `json:"ws,omitempty"`
	//+kubebuilder:validation:Maximum=65535
	WSS int32 `json:"wss,omitempty"`
	//+kubebuilder:validation:Maximum=65535
	Dashboard int32 `json:"dashboard,omitempty"`
	//+kubebuilder:validation:Maximum=65535
	API int32 `json:"api,omitempty"`
}

func (*Ports) DeepCopy 

func (in *Ports) DeepCopy() *Ports

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

func (*Ports) DeepCopyInto 

func (in *Ports) DeepCopyInto(out *Ports)

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

type Status 

type Status struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file
	// Add custom validation using kubebuilder tags: https://book.kubebuilder.io/beyond_basics/generating_crd.html
	Conditions []Condition `json:"conditions,omitempty"`
}

Emqx Status defines the observed state of EMQX

func (*Status) ClearCondition 

func (ecs *Status) ClearCondition(t ConditionType)

func (*Status) DeepCopy 

func (in *Status) DeepCopy() *Status

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

func (*Status) DeepCopyInto 

func (in *Status) DeepCopyInto(out *Status)

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

func (*Status) DescConditionsByTime 

func (ecs *Status) DescConditionsByTime()

func (*Status) GetConditions 

func (ecs *Status) GetConditions() []Condition

func (*Status) SetCreateCondition 

func (ecs *Status) SetCreateCondition(message string)

func (*Status) SetFailedCondition 

func (ecs *Status) SetFailedCondition(message string)

func (*Status) SetReadyCondition 

func (ecs *Status) SetReadyCondition(message string)

func (*Status) SetScalingDownCondition 

func (ecs *Status) SetScalingDownCondition(message string)

func (*Status) SetScalingUpCondition 

func (ecs *Status) SetScalingUpCondition(message string)

func (*Status) SetUpdatingCondition 

func (ecs *Status) SetUpdatingCondition(message string)

func (*Status) SetUpgradingCondition 

func (ecs *Status) SetUpgradingCondition(message string)

type TelegrafTemplate 

type TelegrafTemplate struct {
	//+kubebuilder:validation:Required
	Image string `json:"image,omitempty"`
	//+kubebuilder:validation:Required
	Conf            *string                     `json:"conf,omitempty"`
	Resources       corev1.ResourceRequirements `json:"resources,omitempty"`
	ImagePullPolicy corev1.PullPolicy           `json:"imagePullPolicy,omitempty"`
}

+kubebuilder:object:generate=true

func (*TelegrafTemplate) DeepCopy 

func (in *TelegrafTemplate) DeepCopy() *TelegrafTemplate

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

func (*TelegrafTemplate) DeepCopyInto 

func (in *TelegrafTemplate) DeepCopyInto(out *TelegrafTemplate)

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

type Topics 

type Topics struct {
	Filter []string `json:"filter,omitempty"`
	Equal  []string `json:"equal,omitempty"`
}

+kubebuilder:object:generate=true

func (*Topics) DeepCopy 

func (in *Topics) DeepCopy() *Topics

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

func (*Topics) DeepCopyInto 

func (in *Topics) DeepCopyInto(out *Topics)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.