v1beta3

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

type ConditionType string

type Emqx interface {
	v1.Type
	v1.Object

	EmqxSpec
	EmqxStatus

	client.Object
}

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

	Spec   EmqxBrokerSpec `json:"spec,omitempty"`
	Status `json:"status,omitempty"`
}

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

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

type EmqxBrokerModuleList struct {
	Items []EmqxBrokerModule
}

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

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

type EmqxConfig map[string]string

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

	Spec   EmqxEnterpriseSpec `json:"spec,omitempty"`
	Status `json:"status,omitempty"`
}

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

type EmqxEnterpriseModule struct {
	Name   string `json:"name,omitempty"`
	Enable bool   `json:"enable,omitempty"`
	// +kubebuilder:pruning:PreserveUnknownFields
	Configs runtime.RawExtension `json:"configs,omitempty"`
}

type EmqxEnterpriseModuleList struct {
	Items []EmqxEnterpriseModule
}

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

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

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

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

	Spec   EmqxPluginSpec   `json:"spec,omitempty"`
	Status EmqxPluginStatus `json:"status,omitempty"`
}

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

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

type EmqxPluginStatus struct {
	Phase phase `json:"phase,omitempty"`
}

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

type EmqxStatus interface {
	IsRunning() bool
	IsPluginInitialized() bool
	GetConditions() []Condition
	SetCondition(c Condition)
}

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

type Names struct {
	client.Object
}

type Phase string

type ServiceTemplate struct {
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              corev1.ServiceSpec `json:"spec,omitempty"`
}

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