fe

Documentation

Index

• func CheckFEReady(ctx context.Context, k8sClient client.Client, ...) bool
• func GetFeConfig(ctx context.Context, k8sClient client.Client, ...) (map[string]interface{}, error)
• type FeController
  • func New(k8sClient client.Client, recorderFor subcontrollers.GetEventRecorderForFunc) *FeController
  • func (fc *FeController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (fc *FeController) GetControllerName() string
  • func (fc *FeController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (fc *FeController) UpdateClusterStatus(_ context.Context, src *srapi.StarRocksCluster) error

Functions

func CheckFEReady

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

CheckFEReady check the fe cluster is ok.

func GetFeConfig

func GetFeConfig(ctx context.Context,
	k8sClient client.Client, configMapInfo *srapi.ConfigMapInfo, namespace string) (map[string]interface{}, error)

GetFeConfig get the fe start config.

Types

type FeController

type FeController struct {
	Client   client.Client
	Recorder record.EventRecorder
}

func New

func New(k8sClient client.Client, recorderFor subcontrollers.GetEventRecorderForFunc) *FeController

New construct a FeController.

func (*FeController) ClearResources

func (fc *FeController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error

ClearResources clear resource about fe.

func (*FeController) GetControllerName

func (fc *FeController) GetControllerName() string

func (*FeController) SyncCluster

func (fc *FeController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error

SyncCluster starRocksCluster spec to fe statefulset and service.

func (*FeController) UpdateClusterStatus

func (fc *FeController) UpdateClusterStatus(_ context.Context, src *srapi.StarRocksCluster) error

UpdateClusterStatus update the all resource status about fe.