cn

Feb 4, 2024

Changes in this version

type CnController

+ Recorder record.EventRecorder

Jan 3, 2024

Changes in this version

+ var FeNotReadyError = errors.New("component fe is not ready")

+ var GetFeFeatureInfoError = errors.New(...)

+ var SpecMissingError = errors.New("spec.template or spec.starRocksCluster is missing")

+ var StarRocksClusterMissingError = errors.New("custom resource StarRocksCluster is missing")

+ var StarRocksClusterRunModeError = errors.New("StarRocks Cluster should run in shared_data mode")

+ type CnController struct

+ func New(k8sClient client.Client) *CnController

+ func (cc *CnController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error

+ func (cc *CnController) ClearWarehouse(ctx context.Context, namespace string, name string) error

+ func (cc *CnController) GetConfig(ctx context.Context, configMapInfo *srapi.ConfigMapInfo, namespace string) (map[string]interface{}, error)

+ func (cc *CnController) GetControllerName() string

+ func (cc *CnController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error

+ func (cc *CnController) SyncCnSpec(ctx context.Context, object object.StarRocksObject, ...) error

+ func (cc *CnController) SyncWarehouse(ctx context.Context, warehouse *srapi.StarRocksWarehouse) error

+ func (cc *CnController) UpdateClusterStatus(ctx context.Context, src *srapi.StarRocksCluster) error

+ func (cc *CnController) UpdateStatus(ctx context.Context, object object.StarRocksObject, ...) error

+ func (cc *CnController) UpdateWarehouseStatus(ctx context.Context, warehouse *srapi.StarRocksWarehouse) error

+ type SQLExecutor struct

+ FeServiceName string

+ FeServicePort string

+ RootPassword string

+ func NewSQLExecutor(ctx context.Context, k8sClient client.Client, namespace, aliasName string) (*SQLExecutor, error)

+ func (executor *SQLExecutor) Execute(ctx context.Context, db *sql.DB, statements string) error