Documentation ¶
Overview ¶
Package v1beta1 contains API Schema definitions for the v1beta1 API group +kubebuilder:object:generate=true +groupName=al-assad.github.io
Index ¶
- Variables
- type AutoScaleRecPhase
- type AutoScalerRef
- type AutoscalerRecStatus
- type BESpec
- type BEStatus
- type BEStorage
- type BrokerSpec
- type BrokerStatus
- type CNAutoscalerRules
- type CNAutoscalerSpec
- type CNAutoscalerStatus
- type CNAutoscalerSyncStatus
- type CNSpec
- type CNStatus
- type DorisAutoscaler
- type DorisAutoscalerList
- type DorisAutoscalerSpec
- type DorisAutoscalerStatus
- type DorisCluster
- type DorisClusterList
- type DorisClusterOprStage
- type DorisClusterRecStatus
- type DorisClusterSpec
- type DorisClusterStatus
- type DorisClusterSyncStatus
- type DorisComponentSpec
- type DorisComponentStatus
- type DorisInitializer
- type DorisInitializerList
- type DorisInitializerRecStatus
- type DorisInitializerSpec
- type DorisInitializerStatus
- type DorisInitializerSyncStatus
- type DorisMonitor
- type DorisMonitorComponentStatus
- type DorisMonitorList
- type DorisMonitorOprStage
- type DorisMonitorRecStatus
- type DorisMonitorSpec
- type DorisMonitorStatus
- type DorisMonitorSyncStatus
- type FESpec
- type FEStatus
- type FeServiceSpec
- type GrafanaSpec
- type GrafanaStatus
- type HadoopConfSpec
- type HostnameIpItem
- type InitializeJobStatus
- type InitializeRecPhase
- type LokiSpec
- type LokiStatus
- type MonitorServiceSpec
- type NamespacedName
- type OprStageAction
- type OprStageStatus
- type PrometheusSpec
- type PrometheusStatus
- type PromtailSpec
- type PromtailStatus
- type ReplicasRange
- type ScalePeriodSeconds
- type UtilizationThresholdRange
Constants ¶
This section is empty.
Variables ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BESpec.
func (*BESpec) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BEStatus.
func (*BEStatus) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BEStorage.
func (*BEStorage) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CNSpec.
func (*CNSpec) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CNStatus.
func (*CNStatus) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FESpec.
func (*FESpec) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FEStatus.
func (*FEStatus) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LokiSpec.
func (*LokiSpec) DeepCopyInto ¶
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 ¶
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.