v1beta1

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: 18 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the apps v1beta1 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: "v1beta1"}

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func VersionKind 

func VersionKind(kind string) schema.GroupVersionKind

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 (*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 EmbeddedObjectMetadata 

type EmbeddedObjectMetadata struct {
	// Name must be unique within a namespace. Is required when creating resources, although
	// some resources may allow a client to request the generation of an appropriate name
	// automatically. Name is primarily intended for creation idempotence and configuration
	// definition.
	// Cannot be updated.
	// More info: http://kubernetes.io/docs/user-guide/identifiers#names
	// +optional
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`

	// Map of string keys and values that can be used to organize and categorize
	// (scope and select) objects. May match selectors of replication controllers
	// and services.
	// More info: http://kubernetes.io/docs/user-guide/labels
	// +optional
	Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,11,rep,name=labels"`

	// Annotations is an unstructured key value map stored with a resource that may be
	// set by external tools to store and retrieve arbitrary metadata. They are not
	// queryable and should be preserved when modifying objects.
	// More info: http://kubernetes.io/docs/user-guide/annotations
	// +optional
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,12,rep,name=annotations"`
}

EmbeddedObjectMetadata contains a subset of the fields included in k8s.io/apimachinery/pkg/apis/meta/v1.ObjectMeta Only fields which are relevant to embedded resources are included.

func (*EmbeddedObjectMetadata) DeepCopy 

func (in *EmbeddedObjectMetadata) DeepCopy() *EmbeddedObjectMetadata

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

func (*EmbeddedObjectMetadata) DeepCopyInto 

func (in *EmbeddedObjectMetadata) DeepCopyInto(out *EmbeddedObjectMetadata)

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

type EmbeddedPersistentVolumeClaim 

type EmbeddedPersistentVolumeClaim struct {
	metav1.TypeMeta `json:",inline"`

	// EmbeddedMetadata contains metadata relevant to an EmbeddedResource.
	EmbeddedObjectMetadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	// Spec defines the desired characteristics of a volume requested by a pod author.
	// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#persistentvolumeclaims
	// +optional
	Spec v1.PersistentVolumeClaimSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

	// Status represents the current information/status of a persistent volume claim.
	// Read-only.
	// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#persistentvolumeclaims
	// +optional
	Status v1.PersistentVolumeClaimStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

EmbeddedPersistentVolumeClaim is an embedded version of k8s.io/api/core/v1.PersistentVolumeClaim. It contains TypeMeta and a reduced ObjectMeta.

func (*EmbeddedPersistentVolumeClaim) DeepCopy 

func (in *EmbeddedPersistentVolumeClaim) DeepCopy() *EmbeddedPersistentVolumeClaim

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

func (*EmbeddedPersistentVolumeClaim) DeepCopyInto 

func (in *EmbeddedPersistentVolumeClaim) DeepCopyInto(out *EmbeddedPersistentVolumeClaim)

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

type Emqx 

type Emqx interface {
	v1.Type
	v1.Object

	EmqxSpec
	v1beta2.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"`
	v1beta2.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) 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() []v1beta2.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) GetHeadlessServiceName 

func (emqx *EmqxBroker) GetHeadlessServiceName() string

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() v1beta2.Listener

func (*EmqxBroker) GetModules 

func (emqx *EmqxBroker) GetModules() []v1beta2.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() []v1beta2.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() *Storage

func (*EmqxBroker) GetTelegrafTemplate 

func (emqx *EmqxBroker) GetTelegrafTemplate() *v1beta2.TelegrafTemplate

func (*EmqxBroker) GetToleRations 

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

func (*EmqxBroker) SetACL 

func (emqx *EmqxBroker) SetACL(acl []v1beta2.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 v1beta2.Listener)

func (*EmqxBroker) SetModules 

func (emqx *EmqxBroker) SetModules(modules []v1beta2.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 []v1beta2.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 *Storage)

func (*EmqxBroker) SetTelegrafTemplate 

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

func (*EmqxBroker) SetToleRations 

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

func (*EmqxBroker) SetupWebhookWithManager 

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

func (*EmqxBroker) String 

func (emqx *EmqxBroker) String() string

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"`
}

+kubebuilder:object:root=true 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 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 *Storage `json:"storage,omitempty"`

	NodeName     string            `json:"nodeName,omitempty"`
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// TODO: waiting to be deleted, should use meta.labels
	Labels map[string]string `json:"labels,omitempty"`
	// TODO: waiting to be deleted, should use meta.annotations
	Annotations map[string]string `json:"annotations,omitempty"`

	Listener v1beta2.Listener `json:"listener,omitempty"`

	Affinity    *corev1.Affinity    `json:"affinity,omitempty"`
	ToleRations []corev1.Toleration `json:"toleRations,omitempty"`

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

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

	ACL []v1beta2.ACL `json:"acl,omitempty"`

	Plugins []v1beta2.Plugin `json:"plugins,omitempty"`

	Modules []v1beta2.EmqxBrokerModules `json:"modules,omitempty"`

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

	TelegrafTemplate *v1beta2.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 EmqxEnterprise 

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

	Spec           EmqxEnterpriseSpec `json:"spec,omitempty"`
	v1beta2.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) 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() []v1beta2.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) GetHeadlessServiceName 

func (emqx *EmqxEnterprise) GetHeadlessServiceName() string

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() v1beta2.Listener

func (*EmqxEnterprise) GetModules 

func (emqx *EmqxEnterprise) GetModules() []v1beta2.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() []v1beta2.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() *Storage

func (*EmqxEnterprise) GetTelegrafTemplate 

func (emqx *EmqxEnterprise) GetTelegrafTemplate() *v1beta2.TelegrafTemplate

func (*EmqxEnterprise) GetToleRations 

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

func (*EmqxEnterprise) SetACL 

func (emqx *EmqxEnterprise) SetACL(acl []v1beta2.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 v1beta2.Listener)

func (*EmqxEnterprise) SetModules 

func (emqx *EmqxEnterprise) SetModules(modules []v1beta2.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 []v1beta2.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 *Storage)

func (*EmqxEnterprise) SetTelegrafTemplate 

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

func (*EmqxEnterprise) SetToleRations 

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

func (*EmqxEnterprise) SetupWebhookWithManager 

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

func (*EmqxEnterprise) String 

func (emqx *EmqxEnterprise) String() string

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"`
}

+kubebuilder:object:root=true 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 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 *Storage `json:"storage,omitempty"`

	NodeName     string            `json:"nodeName,omitempty"`
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// TODO: waiting to be deleted, should use meta.labels
	Labels map[string]string `json:"labels,omitempty"`
	// TODO: waiting to be deleted, should use meta.annotations
	Annotations map[string]string `json:"annotations,omitempty"`

	Listener v1beta2.Listener `json:"listener,omitempty"`
	License  string           `json:"license,omitempty"`

	Affinity    *corev1.Affinity    `json:"affinity,omitempty"`
	ToleRations []corev1.Toleration `json:"toleRations,omitempty"`

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

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

	ACL []v1beta2.ACL `json:"acl,omitempty"`

	Plugins []v1beta2.Plugin `json:"plugins,omitempty"`

	Modules []v1beta2.EmqxEnterpriseModules `json:"modules,omitempty"`

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

	TelegrafTemplate *v1beta2.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 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() *Storage
	SetStorage(storage *Storage)

	GetNodeName() string
	SetNodeName(nodeName string)

	GetNodeSelector() map[string]string
	SetNodeSelector(nodeSelector map[string]string)

	GetAnnotations() map[string]string
	SetAnnotations(annotations map[string]string)

	GetListener() v1beta2.Listener
	SetListener(v1beta2.Listener)

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

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

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

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

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

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

	GetHeadlessServiceName() string

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

	GetTelegrafTemplate() *v1beta2.TelegrafTemplate
	SetTelegrafTemplate(telegraftedTemplate *v1beta2.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 Phase 

type Phase string

Phase of the RF status

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"`
}

EmqxStatus 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 Storage 

type Storage struct {
	// EmptyDirVolumeSource to be used by the Prometheus StatefulSets. If specified, used in place of any volumeClaimTemplate. More
	// info: https://kubernetes.io/docs/concepts/storage/volumes/#emptydir
	EmptyDir *v1.EmptyDirVolumeSource `json:"emptyDir,omitempty"`
	// A PVC spec to be used by the Prometheus StatefulSets.
	VolumeClaimTemplate EmbeddedPersistentVolumeClaim `json:"volumeClaimTemplate,omitempty"`
}

func (*Storage) DeepCopy 

func (in *Storage) DeepCopy() *Storage

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

func (*Storage) DeepCopyInto 

func (in *Storage) DeepCopyInto(out *Storage)

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

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.

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.