v1beta1

package
v0.0.0-...-22a2038 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the v1beta1 API group +kubebuilder:object:generate=true +groupName=al-assad.github.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "al-assad.github.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

This section is empty.

Types

type AutoScaleRecPhase 

type AutoScaleRecPhase string

AutoScaleRecPhase is the current reconciling state of autoscaler 

const (
	AutoScalePhaseFailed    AutoScaleRecPhase = "failed"
	AutoScalePhaseCompleted AutoScaleRecPhase = "completed"
)

type AutoScalerRef 

type AutoScalerRef struct {
	NamespacedName  `json:",inline"`
	metav1.TypeMeta `json:",inline"`
}

AutoScalerRef identifies a K8s HPA resource.

func (*AutoScalerRef) DeepCopy 

func (in *AutoScalerRef) DeepCopy() *AutoScalerRef

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

func (*AutoScalerRef) DeepCopyInto 

func (in *AutoScalerRef) DeepCopyInto(out *AutoScalerRef)

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

type AutoscalerRecStatus 

type AutoscalerRecStatus struct {
	Phase   AutoScaleRecPhase `json:"phase,omitempty"`
	Message string            `json:"Message,omitempty"`
}

func (*AutoscalerRecStatus) DeepCopy 

func (in *AutoscalerRecStatus) DeepCopy() *AutoscalerRecStatus

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

func (*AutoscalerRecStatus) DeepCopyInto 

func (in *AutoscalerRecStatus) DeepCopyInto(out *AutoscalerRecStatus)

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

type BESpec 

type BESpec struct {
	DorisComponentSpec `json:",inline"`

	// The default storageClassName of the persistent volume for BE data storage
	// Defaults to Kubernetes default storage class.
	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// The custom storage of BE
	// +optional
	Storage []BEStorage `json:"storage,omitempty"`

	// Whether to retain the default data storage mount for BE which is located at be/storage,
	// Default to false
	// +optional
	RetainDefaultStorage bool `json:"retainDefaultStorage,omitempty"`
}

BESpec contains details of BE members. +k8s:openapi-gen=true

func (*BESpec) DeepCopy 

func (in *BESpec) DeepCopy() *BESpec

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

func (*BESpec) DeepCopyInto 

func (in *BESpec) DeepCopyInto(out *BESpec)

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

type BEStatus 

type BEStatus struct {
	DorisComponentStatus `json:",inline"`
}

BEStatus represents the current state of Doris BE

func (*BEStatus) DeepCopy 

func (in *BEStatus) DeepCopy() *BEStatus

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

func (*BEStatus) DeepCopyInto 

func (in *BEStatus) DeepCopyInto(out *BEStatus)

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

type BEStorage 

type BEStorage struct {
	// Name of the storage
	Name string `json:"name"`

	// Medium of the storage, the optional values include “SSD” (hot data) and “HDD” (cold data).
	// Default to HDD
	Medium string `json:"medium,omitempty"`

	// Storage size requirements, e.g: "500Gi"
	Request *resource.Quantity `json:"request"`

	// K8s storage-class-name of the BE storage
	StorageClassName *string `json:"storageClassName"`
}

BEStorage defines the custom storage of BE

func (*BEStorage) DeepCopy 

func (in *BEStorage) DeepCopy() *BEStorage

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

func (*BEStorage) DeepCopyInto 

func (in *BEStorage) DeepCopyInto(out *BEStorage)

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

type BrokerSpec 

type BrokerSpec struct {
	DorisComponentSpec `json:",inline"`
}

BrokerSpec contains details of Broker members. +k8s:openapi-gen=true

func (*BrokerSpec) DeepCopy 

func (in *BrokerSpec) DeepCopy() *BrokerSpec

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

func (*BrokerSpec) DeepCopyInto 

func (in *BrokerSpec) DeepCopyInto(out *BrokerSpec)

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

type BrokerStatus 

type BrokerStatus struct {
	DorisComponentStatus `json:",inline"`
}

BrokerStatus represents the current state of Doris Broker

func (*BrokerStatus) DeepCopy 

func (in *BrokerStatus) DeepCopy() *BrokerStatus

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

func (*BrokerStatus) DeepCopyInto 

func (in *BrokerStatus) DeepCopyInto(out *BrokerStatus)

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

type CNAutoscalerRules 

type CNAutoscalerRules struct {
	// Rules for scaling based on cpu usage percentage of CN pods
	// +optional
	Cpu *UtilizationThresholdRange `json:"cpu,omitempty"`

	// Rules for scaling based on memory usage percentage of CN pods
	// +optional
	Memory *UtilizationThresholdRange `json:"memory,omitempty"`
}

CNAutoscalerRules contains metric rules for automatic scaling.

func (*CNAutoscalerRules) DeepCopy 

func (in *CNAutoscalerRules) DeepCopy() *CNAutoscalerRules

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

func (*CNAutoscalerRules) DeepCopyInto 

func (in *CNAutoscalerRules) DeepCopyInto(out *CNAutoscalerRules)

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

type CNAutoscalerSpec 

type CNAutoscalerSpec struct {
	// The range of replicas for automatic scaling
	Replicas ReplicasRange `json:"replicas,omitempty"`

	// The metric rules for automatic scaling
	Rules CNAutoscalerRules `json:"rules,omitempty"`

	// ScalePeriodSeconds indicates the length of time in the past for which the k8s HPA scale policy must hold true
	// Ref: https://kubernetes.io/docs/tasks/run-application/horizontal-pod-autoscale/#scaling-policies
	// +optional
	ScalePeriodSeconds *ScalePeriodSeconds `json:"scalePeriodSeconds,omitempty"`

	// Whether to disable scale down
	// Default to false
	// +optional
	DisableScaleDown bool `json:"disableScaleDown,omitempty"`
}

CNAutoscalerSpec contains autoscaling details of CN components.

func (*CNAutoscalerSpec) DeepCopy 

func (in *CNAutoscalerSpec) DeepCopy() *CNAutoscalerSpec

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

func (*CNAutoscalerSpec) DeepCopyInto 

func (in *CNAutoscalerSpec) DeepCopyInto(out *CNAutoscalerSpec)

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

type CNAutoscalerStatus 

type CNAutoscalerStatus struct {
	AutoscalerRecStatus    `json:",inline"`
	CNAutoscalerSyncStatus `json:",inline"`
}

CNAutoscalerStatus defines the observed state of CN autoscaler

func (*CNAutoscalerStatus) DeepCopy 

func (in *CNAutoscalerStatus) DeepCopy() *CNAutoscalerStatus

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

func (*CNAutoscalerStatus) DeepCopyInto 

func (in *CNAutoscalerStatus) DeepCopyInto(out *CNAutoscalerStatus)

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

type CNAutoscalerSyncStatus 

type CNAutoscalerSyncStatus struct {
	ScaleUpHpaRef   *AutoScalerRef                      `json:"scaleUpHpa,omitempty"`
	ScaleUpStatus   *acv2.HorizontalPodAutoscalerStatus `json:"scaleUpHpaStatus,omitempty"`
	ScaleDownHpaRef *AutoScalerRef                      `json:"scaleDown,omitempty"`
	ScaleDownStatus *acv2.HorizontalPodAutoscalerStatus `json:"scaleDownHpaStatus,omitempty"`
}

func (*CNAutoscalerSyncStatus) DeepCopy 

func (in *CNAutoscalerSyncStatus) DeepCopy() *CNAutoscalerSyncStatus

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

func (*CNAutoscalerSyncStatus) DeepCopyInto 

func (in *CNAutoscalerSyncStatus) DeepCopyInto(out *CNAutoscalerSyncStatus)

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

type CNSpec 

type CNSpec struct {
	DorisComponentSpec `json:",inline"`
}

CNSpec contains details of CN members. +k8s:openapi-gen=true

func (*CNSpec) DeepCopy 

func (in *CNSpec) DeepCopy() *CNSpec

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

func (*CNSpec) DeepCopyInto 

func (in *CNSpec) DeepCopyInto(out *CNSpec)

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

type CNStatus 

type CNStatus struct {
	DorisComponentStatus `json:",inline"`
}

CNStatus represents the current state of Doris CN

func (*CNStatus) DeepCopy 

func (in *CNStatus) DeepCopy() *CNStatus

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

func (*CNStatus) DeepCopyInto 

func (in *CNStatus) DeepCopyInto(out *CNStatus)

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

type DorisAutoscaler 

type DorisAutoscaler struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DorisAutoscalerSpec   `json:"spec,omitempty"`
	Status            DorisAutoscalerStatus `json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DorisAutoscaler) DeepCopy 

func (in *DorisAutoscaler) DeepCopy() *DorisAutoscaler

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

func (*DorisAutoscaler) DeepCopyInto 

func (in *DorisAutoscaler) DeepCopyInto(out *DorisAutoscaler)

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

func (*DorisAutoscaler) DeepCopyObject 

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

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

func (*DorisAutoscaler) ObjKey 

func (e *DorisAutoscaler) ObjKey() types.NamespacedName

type DorisAutoscalerList 

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

DorisAutoscalerList contains a list of DorisAutoscaler +kubebuilder:object:root=true

func (*DorisAutoscalerList) DeepCopy 

func (in *DorisAutoscalerList) DeepCopy() *DorisAutoscalerList

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

func (*DorisAutoscalerList) DeepCopyInto 

func (in *DorisAutoscalerList) DeepCopyInto(out *DorisAutoscalerList)

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

func (*DorisAutoscalerList) DeepCopyObject 

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

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

type DorisAutoscalerSpec 

type DorisAutoscalerSpec struct {
	// name of the target DorisCluster
	// +kubebuilder:validation:Required
	Cluster string            `json:"cluster"`
	CN      *CNAutoscalerSpec `json:"cn,omitempty"`
}

DorisAutoscalerSpec defines the desired state of DorisAutoscaler

func (*DorisAutoscalerSpec) DeepCopy 

func (in *DorisAutoscalerSpec) DeepCopy() *DorisAutoscalerSpec

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

func (*DorisAutoscalerSpec) DeepCopyInto 

func (in *DorisAutoscalerSpec) DeepCopyInto(out *DorisAutoscalerSpec)

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

type DorisAutoscalerStatus 

type DorisAutoscalerStatus struct {
	LastApplySpecHash *string            `json:"lastApplySpecHash,omitempty"`
	ClusterRef        NamespacedName     `json:"clusterRef,omitempty"`
	CN                CNAutoscalerStatus `json:"cn,omitempty"`
}

DorisAutoscalerStatus defines the observed state of DorisAutoscaler

func (*DorisAutoscalerStatus) DeepCopy 

func (in *DorisAutoscalerStatus) DeepCopy() *DorisAutoscalerStatus

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

func (*DorisAutoscalerStatus) DeepCopyInto 

func (in *DorisAutoscalerStatus) DeepCopyInto(out *DorisAutoscalerStatus)

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

type DorisCluster 

type DorisCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DorisClusterSpec   `json:"spec,omitempty"`
	Status            DorisClusterStatus `json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DorisCluster) DeepCopy 

func (in *DorisCluster) DeepCopy() *DorisCluster

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

func (*DorisCluster) DeepCopyInto 

func (in *DorisCluster) DeepCopyInto(out *DorisCluster)

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

func (*DorisCluster) DeepCopyObject 

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

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

func (*DorisCluster) ObjKey 

func (e *DorisCluster) ObjKey() types.NamespacedName

type DorisClusterList 

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

DorisClusterList contains a list of DorisCluster +kubebuilder:object:root=true

func (*DorisClusterList) DeepCopy 

func (in *DorisClusterList) DeepCopy() *DorisClusterList

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

func (*DorisClusterList) DeepCopyInto 

func (in *DorisClusterList) DeepCopyInto(out *DorisClusterList)

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

func (*DorisClusterList) DeepCopyObject 

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

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

type DorisClusterOprStage 

type DorisClusterOprStage string

DorisClusterOprStage represents DorisCluster operator stage 

const (
	StageSqlAccountSecret  DorisClusterOprStage = "operator-sql-account/Secret"
	StageFe                DorisClusterOprStage = "fe"
	StageFeConfigmap       DorisClusterOprStage = "fe/Configmap"
	StageFeService         DorisClusterOprStage = "fe/Service"
	StageFeStatefulSet     DorisClusterOprStage = "fe/Statefulset"
	StageBe                DorisClusterOprStage = "be"
	StageBeConfigmap       DorisClusterOprStage = "be/Configmap"
	StageBeService         DorisClusterOprStage = "be/Service"
	StageBeStatefulSet     DorisClusterOprStage = "be/Statefulset"
	StageCn                DorisClusterOprStage = "cn"
	StageCnConfigmap       DorisClusterOprStage = "cn/ConfigMap"
	StageCnService         DorisClusterOprStage = "cn/Service"
	StageCnStatefulSet     DorisClusterOprStage = "cn/Statefulset"
	StageBroker            DorisClusterOprStage = "broker"
	StageBrokerConfigmap   DorisClusterOprStage = "broker/ConfigMap"
	StageBrokerService     DorisClusterOprStage = "broker/Service"
	StageBrokerStatefulSet DorisClusterOprStage = "broker/Statefulset"

	StageComplete DorisClusterOprStage = "complete"
)

type DorisClusterRecStatus 

type DorisClusterRecStatus struct {
	Stage       DorisClusterOprStage `json:"stage,omitempty"`
	StageAction OprStageAction       `json:"stageAction,omitempty"`
	StageStatus OprStageStatus       `json:"stageStatus,omitempty"`
	LastMessage string               `json:"lastMessage,omitempty"`
}

func (*DorisClusterRecStatus) DeepCopy 

func (in *DorisClusterRecStatus) DeepCopy() *DorisClusterRecStatus

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

func (*DorisClusterRecStatus) DeepCopyInto 

func (in *DorisClusterRecStatus) DeepCopyInto(out *DorisClusterRecStatus)

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

type DorisClusterSpec 

type DorisClusterSpec struct {
	FE         *FESpec         `json:"fe,omitempty"`
	BE         *BESpec         `json:"be,omitempty"`
	CN         *CNSpec         `json:"cn,omitempty"`
	Broker     *BrokerSpec     `json:"broker,omitempty"`
	HadoopConf *HadoopConfSpec `json:"hadoopConf,omitempty"`

	// Default busybox image
	// +optional
	BusyBoxImage *string `json:"busyBoxImage,omitempty"`

	// Doris cluster image version
	Version string `json:"version"`

	// ImagePullPolicy of Doris cluster Pods
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling
	// any of the images.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	// Specify a Service Account
	// +optional
	ServiceAccount string `json:"serviceAccount,omitempty"`

	// Affinity for pod scheduling of Doris cluster.
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// NodeSelector of the Doris cluster.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// Annotations of the Doris cluster.
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// Tolerations are applied to Doris cluster pods, allowing pods to be scheduled onto nodes with matching taints.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// Specify pod priorities of pods in Doris cluster, default to empty.
	// +optional
	PriorityClassName string `json:"priorityClassName,omitempty"`

	// Update strategy of Doris cluster StatefulSet.
	// +optional
	StatefulSetUpdateStrategy *appv1.StatefulSetUpdateStrategyType `json:"statefulSetUpdateStrategy,omitempty"`
}

DorisClusterSpec describes the attributes that a user creates on a Doris cluster. +k8s:openapi-gen=true

func (*DorisClusterSpec) DeepCopy 

func (in *DorisClusterSpec) DeepCopy() *DorisClusterSpec

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

func (*DorisClusterSpec) DeepCopyInto 

func (in *DorisClusterSpec) DeepCopyInto(out *DorisClusterSpec)

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

type DorisClusterStatus 

type DorisClusterStatus struct {
	LastApplySpecHash      *string `json:"lastApplySpecHash,omitempty"`
	DorisClusterRecStatus  `json:",inline"`
	DorisClusterSyncStatus `json:",inline"`
}

DorisClusterStatus defines the observed state of DorisCluster +k8s:openapi-gen=true

func (*DorisClusterStatus) DeepCopy 

func (in *DorisClusterStatus) DeepCopy() *DorisClusterStatus

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

func (*DorisClusterStatus) DeepCopyInto 

func (in *DorisClusterStatus) DeepCopyInto(out *DorisClusterStatus)

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

type DorisClusterSyncStatus 

type DorisClusterSyncStatus struct {
	FE     FEStatus     `json:"fe,omitempty"`
	BE     BEStatus     `json:"be,omitempty"`
	CN     CNStatus     `json:"cn,omitempty"`
	Broker BrokerStatus `json:"broker,omitempty"`

	// AllReady represents all components(FE, BE, CN, Broker) of DorisCluster are ready.
	AllReady bool `json:"allReady"`
}

func (*DorisClusterSyncStatus) DeepCopy 

func (in *DorisClusterSyncStatus) DeepCopy() *DorisClusterSyncStatus

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

func (*DorisClusterSyncStatus) DeepCopyInto 

func (in *DorisClusterSyncStatus) DeepCopyInto(out *DorisClusterSyncStatus)

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

type DorisComponentSpec 

type DorisComponentSpec struct {
	//Base image of the component
	// +kubebuilder:validation:Required
	BaseImage string `json:"baseImage"`

	// Type of the real kubernetes service
	// +optional
	Version string `json:"version,omitempty"`

	// The desired ready replicas
	// +kubebuilder:validation:Minimum=0
	Replicas int32 `json:"replicas"`

	// Defines the specification of resource cpu, mem, storage.
	corev1.ResourceRequirements `json:",inline"`

	// Additional Doris component configuration
	// Ref:
	// - https://doris.apache.org/docs/dev/admin-manual/config/fe-config/
	// - https://doris.apache.org/docs/dev/admin-manual/config/be-config/
	// +optional
	Configs map[string]string `json:"config,omitempty"`

	// HostAliases is an optional list of hosts and IPs that will be injected into the pod's hosts
	// file if specified.
	// +optional
	HostAliases []corev1.HostAlias `json:"hostAliases,omitempty"`

	// Specify a Service Account
	// +optional
	ServiceAccount string `json:"serviceAccount,omitempty"`

	// NodeSelector of the component.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// Annotations of the component.
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// Affinity for pod scheduling of Doris cluster.
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// Tolerations are applied to Doris cluster pods, allowing pods to be scheduled onto nodes with matching taints.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// Specify pod priorities of pods in Doris cluster, default to empty.
	// +optional
	PriorityClassName string `json:"priorityClassName,omitempty"`

	// Update strategy of Doris cluster StatefulSet.
	// +optional
	StatefulSetUpdateStrategy *appv1.StatefulSetUpdateStrategyType `json:"statefulSetUpdateStrategy,omitempty"`

	// Additional environment variables to set in the container
	// +optional
	AdditionalEnvs []corev1.EnvVar `json:"additionalEnv,omitempty"`

	// Additional containers of the component.
	// +optional
	AdditionalContainers []corev1.Container `json:"additionalContainers,omitempty"`

	// Additional volumes of component pod.
	// +optional
	AdditionalVolumes []corev1.Volume `json:"additionalVolumes,omitempty"`

	// Additional volume mounts of component pod.
	// +optional
	AdditionalVolumeMounts []corev1.VolumeMount `json:"additionalVolumeMounts,omitempty"`
}

DorisComponentSpec is the base component spec. +k8s:openapi-gen=true

func (*DorisComponentSpec) DeepCopy 

func (in *DorisComponentSpec) DeepCopy() *DorisComponentSpec

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

func (*DorisComponentSpec) DeepCopyInto 

func (in *DorisComponentSpec) DeepCopyInto(out *DorisComponentSpec)

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

type DorisComponentStatus 

type DorisComponentStatus struct {
	Image          string                       `json:"image,omitempty"`
	StatefulSetRef NamespacedName               `json:"statefulSetRef,omitempty"`
	Members        []string                     `json:"members,omitempty"`
	ReadyMembers   []string                     `json:"readyMembers,omitempty"`
	Conditions     []appv1.StatefulSetCondition `json:"conditions,omitempty"`
}

DorisComponentStatus represents the current status of a DorisCluster component

func (*DorisComponentStatus) DeepCopy 

func (in *DorisComponentStatus) DeepCopy() *DorisComponentStatus

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

func (*DorisComponentStatus) DeepCopyInto 

func (in *DorisComponentStatus) DeepCopyInto(out *DorisComponentStatus)

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

type DorisInitializer 

type DorisInitializer struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DorisInitializerSpec   `json:"spec,omitempty"`
	Status            DorisInitializerStatus `json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DorisInitializer) DeepCopy 

func (in *DorisInitializer) DeepCopy() *DorisInitializer

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

func (*DorisInitializer) DeepCopyInto 

func (in *DorisInitializer) DeepCopyInto(out *DorisInitializer)

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

func (*DorisInitializer) DeepCopyObject 

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

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

func (*DorisInitializer) ObjKey 

func (e *DorisInitializer) ObjKey() types.NamespacedName

type DorisInitializerList 

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

DorisInitializerList contains a list of DorisInitializer +kubebuilder:object:root=true

func (*DorisInitializerList) DeepCopy 

func (in *DorisInitializerList) DeepCopy() *DorisInitializerList

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

func (*DorisInitializerList) DeepCopyInto 

func (in *DorisInitializerList) DeepCopyInto(out *DorisInitializerList)

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

func (*DorisInitializerList) DeepCopyObject 

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

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

type DorisInitializerRecStatus 

type DorisInitializerRecStatus struct {
	Phase   InitializeRecPhase `json:"phase,omitempty"`
	Message string             `json:"Message,omitempty"`
}

func (*DorisInitializerRecStatus) DeepCopy 

func (in *DorisInitializerRecStatus) DeepCopy() *DorisInitializerRecStatus

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

func (*DorisInitializerRecStatus) DeepCopyInto 

func (in *DorisInitializerRecStatus) DeepCopyInto(out *DorisInitializerRecStatus)

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

type DorisInitializerSpec 

type DorisInitializerSpec struct {
	// name of the target DorisCluster at the same namespace
	Cluster string `json:"cluster"`

	// Image tags of the python-sql executor container
	// Default to tnir/mysqlclient:1.4.6
	// +optional
	Image string `json:"image"`

	// ImagePullPolicy of Doris cluster Pods
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling
	// any of the images.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	// MaxRetry of the Doris initializer Job
	// +optional
	MaxRetry *int32 `json:"maxRetry"`

	// Specify a Service Account
	// +optional
	ServiceAccount string `json:"serviceAccount,omitempty"`

	// Default Doris root user password
	// +optional
	RootPassword string `json:"rootPassword,omitempty"`

	// Default Doris root user password
	// +optional
	AdminPassword string `json:"adminPassword,omitempty"`

	// Doris initialize sqls
	// +optional
	SqlScript string `json:"initSqlScript,omitempty"`

	// +optional
	corev1.ResourceRequirements `json:",inline"`

	// Tolerations of the Doris initializer Pod
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// NodeSelector of the Doris initializer Pod.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

DorisInitializerSpec defines the desired state of doris initializer Job +k8s:openapi-gen=true

func (*DorisInitializerSpec) DeepCopy 

func (in *DorisInitializerSpec) DeepCopy() *DorisInitializerSpec

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

func (*DorisInitializerSpec) DeepCopyInto 

func (in *DorisInitializerSpec) DeepCopyInto(out *DorisInitializerSpec)

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

type DorisInitializerStatus 

type DorisInitializerStatus struct {
	LastApplySpecHash          *string `json:"LastApplySpecHash,omitempty"`
	DorisInitializerRecStatus  `json:",inline"`
	DorisInitializerSyncStatus `json:",inline"`
}

DorisInitializerStatus defines the observed state of DorisInitializer +k8s:openapi-gen=true

func (*DorisInitializerStatus) DeepCopy 

func (in *DorisInitializerStatus) DeepCopy() *DorisInitializerStatus

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

func (*DorisInitializerStatus) DeepCopyInto 

func (in *DorisInitializerStatus) DeepCopyInto(out *DorisInitializerStatus)

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

type DorisInitializerSyncStatus 

type DorisInitializerSyncStatus struct {
	JobRef            NamespacedName      `json:"jobRef,omitempty"`
	Status            InitializeJobStatus `json:"status,omitempty"`
	batchv1.JobStatus `json:",inline"`
}

func (*DorisInitializerSyncStatus) DeepCopy 

func (in *DorisInitializerSyncStatus) DeepCopy() *DorisInitializerSyncStatus

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

func (*DorisInitializerSyncStatus) DeepCopyInto 

func (in *DorisInitializerSyncStatus) DeepCopyInto(out *DorisInitializerSyncStatus)

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

type DorisMonitor 

type DorisMonitor struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DorisMonitorSpec   `json:"spec,omitempty"`
	Status            DorisMonitorStatus `json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DorisMonitor) DeepCopy 

func (in *DorisMonitor) DeepCopy() *DorisMonitor

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

func (*DorisMonitor) DeepCopyInto 

func (in *DorisMonitor) DeepCopyInto(out *DorisMonitor)

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

func (*DorisMonitor) DeepCopyObject 

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

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

func (*DorisMonitor) ObjKey 

func (e *DorisMonitor) ObjKey() types.NamespacedName

type DorisMonitorComponentStatus 

type DorisMonitorComponentStatus struct {
	ServiceRef     NamespacedName             `json:"serviceRef,omitempty"`
	StatefulsetRef NamespacedName             `json:"statefulsetRef,omitempty"`
	Ready          bool                       `json:"ready,omitempty"`
	Conditions     []apps.DeploymentCondition `json:"conditions,omitempty"`
}

DorisMonitorComponentStatus defines the status of the doris monitor component

func (*DorisMonitorComponentStatus) DeepCopy 

func (in *DorisMonitorComponentStatus) DeepCopy() *DorisMonitorComponentStatus

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

func (*DorisMonitorComponentStatus) DeepCopyInto 

func (in *DorisMonitorComponentStatus) DeepCopyInto(out *DorisMonitorComponentStatus)

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

type DorisMonitorList 

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

DorisMonitorList contains a list of DorisMonitor +kubebuilder:object:root=true

func (*DorisMonitorList) DeepCopy 

func (in *DorisMonitorList) DeepCopy() *DorisMonitorList

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

func (*DorisMonitorList) DeepCopyInto 

func (in *DorisMonitorList) DeepCopyInto(out *DorisMonitorList)

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

func (*DorisMonitorList) DeepCopyObject 

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

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

type DorisMonitorOprStage 

type DorisMonitorOprStage string
const (
	MnrOprStageRbac                     DorisMonitorOprStage = "rbac"
	MnrOprStageNamespacedRole           DorisMonitorOprStage = "rbac/Role"
	MnrOprStageNamespacedServiceAccount DorisMonitorOprStage = "rbac/ServiceAccount"
	MnrOprStageNamespacedRoleBinding    DorisMonitorOprStage = "rbac/RoleBinding"

	MnrOprStagePrometheus            DorisMonitorOprStage = "prometheus"
	MnrOprStagePrometheusConfigMap   DorisMonitorOprStage = "prometheus/ConfigMap"
	MnrOprStagePrometheusService     DorisMonitorOprStage = "prometheus/Service"
	MnrOprStagePrometheusStatefulset DorisMonitorOprStage = "prometheus/Statefulset"

	MnrOprStageGrafana            DorisMonitorOprStage = "grafana"
	MnrOprStageGrafanaSecret      DorisMonitorOprStage = "grafana/Secret"
	MnrOprStageGrafanaConfigMap   DorisMonitorOprStage = "grafana/ConfigMap"
	MnrOprStageGrafanaService     DorisMonitorOprStage = "grafana/Service"
	MnrOprStageGrafanaStatefulset DorisMonitorOprStage = "grafana/Statefulset"

	MnrOprStagePromtail          DorisMonitorOprStage = "promtail"
	MnrOprStagePromtailConfigMap DorisMonitorOprStage = "promtail/ConfigMap"
	MnrOprStagePromtailDaemonSet DorisMonitorOprStage = "promtail/DemonSet"

	MnrOprStageLoki            DorisMonitorOprStage = "loki"
	MnrOprStageLokiConfigMap   DorisMonitorOprStage = "loki/ConfigMap"
	MnrOprStageLokiService     DorisMonitorOprStage = "loki/Service"
	MnrOprStageLokiStatefulset DorisMonitorOprStage = "loki/Statefulset"

	MnrOprStageCompleted DorisMonitorOprStage = "completed"
)

type DorisMonitorRecStatus 

type DorisMonitorRecStatus struct {
	Stage       DorisMonitorOprStage `json:"stage,omitempty"`
	StageStatus OprStageStatus       `json:"stageStatus,omitempty"`
	StageAction OprStageAction       `json:"stageAction,omitempty"`
	LastMessage string               `json:"lastMessage,omitempty"`
}

func (*DorisMonitorRecStatus) DeepCopy 

func (in *DorisMonitorRecStatus) DeepCopy() *DorisMonitorRecStatus

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

func (*DorisMonitorRecStatus) DeepCopyInto 

func (in *DorisMonitorRecStatus) DeepCopyInto(out *DorisMonitorRecStatus)

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

type DorisMonitorSpec 

type DorisMonitorSpec struct {
	// Name of the target DorisCluster
	// +kubebuilder:validation:Required
	Cluster string `json:"cluster"`

	Prometheus *PrometheusSpec `json:"prometheus,omitempty"`
	Grafana    *GrafanaSpec    `json:"grafana,omitempty"`
	Loki       *LokiSpec       `json:"loki,omitempty"`
	Promtail   *PromtailSpec   `json:"promtail,omitempty"`

	// DisableLoki to disable Loki for log collection
	// Default to false
	DisableLoki bool `json:"disableLoki,omitempty"`

	// ImagePullPolicy of DorisMonitor Pods
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling
	// any of the images.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	// StorageClassName of the persistent volume for monitor data storage.
	// Kubernetes default storage class is used if not setting this field.
	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// Specify a Service Account
	// +optional
	ServiceAccount string `json:"serviceAccount,omitempty"`

	// NodeSelector of the Doris monitor components.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

DorisMonitorSpec defines the desired state of DorisMonitor +k8s:openapi-gen=true

func (*DorisMonitorSpec) DeepCopy 

func (in *DorisMonitorSpec) DeepCopy() *DorisMonitorSpec

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

func (*DorisMonitorSpec) DeepCopyInto 

func (in *DorisMonitorSpec) DeepCopyInto(out *DorisMonitorSpec)

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

type DorisMonitorStatus 

type DorisMonitorStatus struct {
	LastApplySpecHash      *string `json:"lastApplySpecHash,omitempty"`
	DorisMonitorRecStatus  `json:",inline"`
	DorisMonitorSyncStatus `json:",inline"`
}

DorisMonitorStatus defines the observed state of DorisMonitor +k8s:openapi-gen=true

func (*DorisMonitorStatus) DeepCopy 

func (in *DorisMonitorStatus) DeepCopy() *DorisMonitorStatus

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

func (*DorisMonitorStatus) DeepCopyInto 

func (in *DorisMonitorStatus) DeepCopyInto(out *DorisMonitorStatus)

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

type DorisMonitorSyncStatus 

type DorisMonitorSyncStatus struct {
	Prometheus PrometheusStatus `json:"prometheus,omitempty"`
	Grafana    GrafanaStatus    `json:"grafana,omitempty"`
	Loki       LokiStatus       `json:"loki,omitempty"`
	Promtail   PromtailStatus   `json:"promtail,omitempty"`
}

func (*DorisMonitorSyncStatus) DeepCopy 

func (in *DorisMonitorSyncStatus) DeepCopy() *DorisMonitorSyncStatus

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

func (*DorisMonitorSyncStatus) DeepCopyInto 

func (in *DorisMonitorSyncStatus) DeepCopyInto(out *DorisMonitorSyncStatus)

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

type FESpec 

type FESpec struct {
	DorisComponentSpec `json:",inline"`

	// The storageClassName of the persistent volume for FE data storage.
	// Defaults to Kubernetes default storage class.
	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// Service defines a Kubernetes service of FE
	Service *FeServiceSpec `json:"service,omitempty"`
}

FESpec contains details of FE members. +k8s:openapi-gen=true

func (*FESpec) DeepCopy 

func (in *FESpec) DeepCopy() *FESpec

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

func (*FESpec) DeepCopyInto 

func (in *FESpec) DeepCopyInto(out *FESpec)

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

type FEStatus 

type FEStatus struct {
	ServiceRef           NamespacedName `json:"serviceName,omitempty"`
	DorisComponentStatus `json:",inline"`
}

FEStatus represents the current state of Doris FE

func (*FEStatus) DeepCopy 

func (in *FEStatus) DeepCopy() *FEStatus

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

func (*FEStatus) DeepCopyInto 

func (in *FEStatus) DeepCopyInto(out *FEStatus)

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

type FeServiceSpec 

type FeServiceSpec struct {
	// Type of the real kubernetes service
	// Only ClusterIP and NodePort support is available.
	Type corev1.ServiceType `json:"type,omitempty"`

	// Expose the FE query port
	// Optional: Defaults to 0
	// +optional
	QueryPort *int32 `json:"queryPort,omitempty"`

	// Expose the FE http port
	// Optional: Defaults to 0
	// +optional
	HttpPort *int32 `json:"httpPort,omitempty"`

	// ExternalTrafficPolicy of the service
	// Optional: Defaults to omitted
	// +optional
	ExternalTrafficPolicy *corev1.ServiceExternalTrafficPolicyType `json:"externalTrafficPolicy,omitempty"`
}

FeServiceSpec defines `.fe.service` field of `DorisCluster.spec`. +k8s:openapi-gen=true

func (*FeServiceSpec) DeepCopy 

func (in *FeServiceSpec) DeepCopy() *FeServiceSpec

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

func (*FeServiceSpec) DeepCopyInto 

func (in *FeServiceSpec) DeepCopyInto(out *FeServiceSpec)

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

type GrafanaSpec 

type GrafanaSpec struct {
	// Image tags of the grafana
	Image string `json:"image"`

	// Default grafana admin username
	// +optional
	AdminUser string `json:"adminUser,omitempty"`

	// Default grafana admin password
	// +optional
	AdminPassword string `json:"adminPassword,omitempty"`

	// +optional
	Service *MonitorServiceSpec `json:"service,omitempty"`

	// +optional
	corev1.ResourceRequirements `json:",inline"`

	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

GrafanaSpec defines the desired state of Grafana +k8s:openapi-gen=true

func (*GrafanaSpec) DeepCopy 

func (in *GrafanaSpec) DeepCopy() *GrafanaSpec

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

func (*GrafanaSpec) DeepCopyInto 

func (in *GrafanaSpec) DeepCopyInto(out *GrafanaSpec)

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

type GrafanaStatus 

type GrafanaStatus struct {
	DorisMonitorComponentStatus `json:",inline"`
}

GrafanaStatus represents the current state of the grafana

func (*GrafanaStatus) DeepCopy 

func (in *GrafanaStatus) DeepCopy() *GrafanaStatus

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

func (*GrafanaStatus) DeepCopyInto 

func (in *GrafanaStatus) DeepCopyInto(out *GrafanaStatus)

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

type HadoopConfSpec 

type HadoopConfSpec struct {
	// Hostname-IP mapping of Hadoop cluster nodes.
	Hosts []HostnameIpItem `json:"hostAliases"`
	// Hadoop configuration files.
	Config map[string]string `json:"config,omitempty"`
}

HadoopConfSpec contains the configuration needed for doris to connect to the Hadoop cluster. +k8s:openapi-gen=true

func (*HadoopConfSpec) DeepCopy 

func (in *HadoopConfSpec) DeepCopy() *HadoopConfSpec

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

func (*HadoopConfSpec) DeepCopyInto 

func (in *HadoopConfSpec) DeepCopyInto(out *HadoopConfSpec)

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

type HostnameIpItem 

type HostnameIpItem struct {
	// +kubebuilder:validation:Required
	IP string `json:"ip"`
	// +kubebuilder:validation:Required
	Name string `json:"name"`
}

HostnameIpItem define Hostname-IP kv item +k8s:openapi-gen=true

func (*HostnameIpItem) DeepCopy 

func (in *HostnameIpItem) DeepCopy() *HostnameIpItem

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

func (*HostnameIpItem) DeepCopyInto 

func (in *HostnameIpItem) DeepCopyInto(out *HostnameIpItem)

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

type InitializeJobStatus 

type InitializeJobStatus string
const (
	InitializeJobPending   InitializeJobStatus = "pending"
	InitializeJobRunning   InitializeJobStatus = "running"
	InitializeJobCompleted InitializeJobStatus = "completed"
	InitializeJobFailed    InitializeJobStatus = "failed"
)

type InitializeRecPhase 

type InitializeRecPhase string
const (
	InitializeRecWaiting   InitializeRecPhase = "waiting"
	InitializeRecFailed    InitializeRecPhase = "failed"
	InitializeRecCompleted InitializeRecPhase = "applied"
)

type LokiSpec 

type LokiSpec struct {
	// Image tags of the loki
	Image string `json:"image"`

	// Loki chunks retention time
	// When it is empty, do not enable retention deletion of Loki.
	// +optional
	RetentionTime *string `json:"retentionTime,omitempty"`

	// +optional
	corev1.ResourceRequirements `json:",inline"`

	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

LokiSpec defines the desired state of Loki

func (*LokiSpec) DeepCopy 

func (in *LokiSpec) DeepCopy() *LokiSpec

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

func (*LokiSpec) DeepCopyInto 

func (in *LokiSpec) DeepCopyInto(out *LokiSpec)

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

type LokiStatus 

type LokiStatus struct {
	DorisMonitorComponentStatus `json:",inline"`
}

LokiStatus represents the current state of the loki

func (*LokiStatus) DeepCopy 

func (in *LokiStatus) DeepCopy() *LokiStatus

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

func (*LokiStatus) DeepCopyInto 

func (in *LokiStatus) DeepCopyInto(out *LokiStatus)

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

type MonitorServiceSpec 

type MonitorServiceSpec struct {
	// Type of the real kubernetes service
	// Only ClusterIP and NodePort support is available.
	Type corev1.ServiceType `json:"type,omitempty"`

	// Expose the http query port of prometheus or grafana
	// Optional: Defaults to 0
	// +optional
	HttpPort *int32 `json:"httpPort,omitempty"`

	// ExternalTrafficPolicy of the service
	// Optional: Defaults to nil
	// +optional
	ExternalTrafficPolicy *corev1.ServiceExternalTrafficPolicyType `json:"externalTrafficPolicy,omitempty"`
}

MonitorServiceSpec defines the service of prometheus and grafana +k8s:openapi-gen=true

func (*MonitorServiceSpec) DeepCopy 

func (in *MonitorServiceSpec) DeepCopy() *MonitorServiceSpec

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

func (*MonitorServiceSpec) DeepCopyInto 

func (in *MonitorServiceSpec) DeepCopyInto(out *MonitorServiceSpec)

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

type NamespacedName 

type NamespacedName struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
}

NamespacedName is the name and namespace of the kubernetes object +k8s:openapi-gen=true

func NewNamespacedName 

func NewNamespacedName(name types.NamespacedName) NamespacedName

func (*NamespacedName) DeepCopy 

func (in *NamespacedName) DeepCopy() *NamespacedName

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

func (*NamespacedName) DeepCopyInto 

func (in *NamespacedName) DeepCopyInto(out *NamespacedName)

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

type OprStageAction 

type OprStageAction string

OprStageAction represents the action type of controller reconcile stage 

const (
	StageActionApply  OprStageAction = "apply"
	StageActionDelete OprStageAction = "delete"
)

type OprStageStatus 

type OprStageStatus string

OprStageStatus represents the status of controller stage 

const (
	StageResultSucceeded OprStageStatus = "succeeded"
	StageResultFailed    OprStageStatus = "failed"
)

type PrometheusSpec 

type PrometheusSpec struct {
	// Image tags of the prometheus
	Image string `json:"image"`

	// Prometheus data retention time
	// +optional
	RetentionTime *string `json:"retentionTime,omitempty"`

	// Service defines a Kubernetes service of Prometheus
	// +optional
	Service *MonitorServiceSpec `json:"service,omitempty"`

	// +optional
	corev1.ResourceRequirements `json:",inline"`

	// +optional
	StorageClassName *string `json:"storageClassName,omitempty"`

	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

PrometheusSpec defines the desired state of Prometheus +k8s:openapi-gen=true

func (*PrometheusSpec) DeepCopy 

func (in *PrometheusSpec) DeepCopy() *PrometheusSpec

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

func (*PrometheusSpec) DeepCopyInto 

func (in *PrometheusSpec) DeepCopyInto(out *PrometheusSpec)

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

type PrometheusStatus 

type PrometheusStatus struct {
	DorisMonitorComponentStatus `json:",inline"`
}

PrometheusStatus represents the current state of the prometheus

func (*PrometheusStatus) DeepCopy 

func (in *PrometheusStatus) DeepCopy() *PrometheusStatus

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

func (*PrometheusStatus) DeepCopyInto 

func (in *PrometheusStatus) DeepCopyInto(out *PrometheusStatus)

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

type PromtailSpec 

type PromtailSpec struct {
	// Image tags of the promtail
	Image string `json:"image"`
	// +optional
	corev1.ResourceRequirements `json:",inline"`
}

PromtailSpec defines the desired state of Promtail

func (*PromtailSpec) DeepCopy 

func (in *PromtailSpec) DeepCopy() *PromtailSpec

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

func (*PromtailSpec) DeepCopyInto 

func (in *PromtailSpec) DeepCopyInto(out *PromtailSpec)

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

type PromtailStatus 

type PromtailStatus struct {
	DaemonSetRef NamespacedName            `json:"daemonSetRef,omitempty"`
	Ready        bool                      `json:"ready,omitempty"`
	Conditions   []apps.DaemonSetCondition `json:"conditions,omitempty"`
}

PromtailStatus represents the current state of the promtail

func (*PromtailStatus) DeepCopy 

func (in *PromtailStatus) DeepCopy() *PromtailStatus

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

func (*PromtailStatus) DeepCopyInto 

func (in *PromtailStatus) DeepCopyInto(out *PromtailStatus)

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

type ReplicasRange 

type ReplicasRange struct {
	Max int32  `json:"max,omitempty"`
	Min *int32 `json:"min,omitempty"`
}

func (*ReplicasRange) DeepCopy 

func (in *ReplicasRange) DeepCopy() *ReplicasRange

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

func (*ReplicasRange) DeepCopyInto 

func (in *ReplicasRange) DeepCopyInto(out *ReplicasRange)

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

type ScalePeriodSeconds 

type ScalePeriodSeconds struct {
	ScaleUp   *int32 `json:"scaleUp,omitempty"`
	ScaleDown *int32 `json:"scaleDown,omitempty"`
}

func (*ScalePeriodSeconds) DeepCopy 

func (in *ScalePeriodSeconds) DeepCopy() *ScalePeriodSeconds

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

func (*ScalePeriodSeconds) DeepCopyInto 

func (in *ScalePeriodSeconds) DeepCopyInto(out *ScalePeriodSeconds)

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

type UtilizationThresholdRange 

type UtilizationThresholdRange struct {
	Max *int32 `json:"max,omitempty"`
	Min *int32 `json:"min,omitempty"`
}

func (*UtilizationThresholdRange) DeepCopy 

func (in *UtilizationThresholdRange) DeepCopy() *UtilizationThresholdRange

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

func (*UtilizationThresholdRange) DeepCopyInto 

func (in *UtilizationThresholdRange) DeepCopyInto(out *UtilizationThresholdRange)

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.