fe

func CheckFEReady ¶

func CheckFEReady(ctx context.Context, k8sClient client.Client, clusterNamespace, clusterName string) bool

CheckFEReady check the fe cluster is ok. Note: When user upgrade the cluster, and the statefulset controller has not begun to update the statefulset, CheckFEReady will use the old status to check whether FE is ready.

func CheckFEReadyInDisasterRecovery ¶ added in v1.10.0

func CheckFEReadyInDisasterRecovery(ctx context.Context, k8sClient client.Client,
	clusterNamespace string, clusterName string, generation int64) bool

CheckFEReadyInDisasterRecovery check whether the FE pod is ready. When user upgrade the cluster, and the statefulset controller has not begun to update the statefulset, CheckFEReady will use the old status to check whether FE is ready. CheckFEReadyInDisasterRecovery will check the following things:

1. make sure the value of environment RESTORE_CLUSTER_GENERATION equals to the generation of disaster recovery.
2. make sure the pod is ready.

func EnterDisasterRecoveryMode ¶ added in v1.10.0

func EnterDisasterRecoveryMode(ctx context.Context, k8sClient client.Client,
	src *v1.StarRocksCluster, sts *appsv1.StatefulSet, queryPort int32) error

func GetFEConfig ¶ added in v1.9.8

func GetFEConfig(ctx context.Context, client client.Client,
	feSpec *srapi.StarRocksFeSpec, namespace string) (map[string]interface{}, error)

GetFEConfig get the fe config from configMap. It is not a method of FeController, but BE/CN controller also need to get the config from configMap.

func IsRunInSharedDataMode ¶ added in v1.10.0

func IsRunInSharedDataMode(config map[string]interface{}) bool

func PortReadyProbe ¶ added in v1.10.0

func PortReadyProbe(port int) *corev1.Probe

PortReadyProbe detect whether the port is ready

func ShouldEnterDisasterRecoveryMode ¶ added in v1.10.0

func ShouldEnterDisasterRecoveryMode(drSpec *v1.DisasterRecovery,
	drStatus *v1.DisasterRecoveryStatus, feConfig map[string]interface{}) (bool, int32)