fe

Documentation

Index

• func CheckFEOk(ctx context.Context, k8sClient client.Client, src *srapi.StarRocksCluster) bool
• func GetFeConfig(ctx context.Context, k8sClient client.Client, ...) (map[string]interface{}, error)
• type FeController
  • func New(k8sClient client.Client) *FeController
  • func (fc *FeController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (fc *FeController) GetControllerName() string
  • func (fc *FeController) Sync(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (fc *FeController) UpdateStatus(src *srapi.StarRocksCluster) error

Functions

func CheckFEOk

func CheckFEOk(ctx context.Context, k8sClient client.Client, src *srapi.StarRocksCluster) bool

CheckFEOk check the fe cluster is ok for add cn node.

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 {
	// contains filtered or unexported fields
}

func New

func New(k8sClient client.Client) *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) Sync

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

Sync starRocksCluster spec to fe statefulset and service.

func (*FeController) UpdateStatus

func (fc *FeController) UpdateStatus(src *srapi.StarRocksCluster) error

UpdateStatus update the all resource status about fe.