fe

Documentation

Index

• func CheckFEReady(ctx context.Context, k8sClient client.Client, ...) bool
• func GetFEConfig(ctx context.Context, client client.Client, feSpec *srapi.StarRocksFeSpec, ...) (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
  • func (fc *FeController) Validating(feSpec *srapi.StarRocksFeSpec) 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, 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.

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.

func (*FeController) Validating

func (fc *FeController) Validating(feSpec *srapi.StarRocksFeSpec) error