be

package

v1.11.2 Latest Latest Go to latest Published: Sep 22, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func New(k8sClient client.Client, recorderFor subc.GetEventRecorderForFunc) *BeController

func (be *BeController) ClearCluster(ctx context.Context, src *srapi.StarRocksCluster) error

func (be *BeController) GetBeConfig(ctx context.Context,
	beSpec *srapi.StarRocksBeSpec, namespace string) (map[string]interface{}, error)

GetBeConfig get the config of BE from configmap.

func (be *BeController) GetControllerName() string

func (be *BeController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error

func (be *BeController) UpdateClusterStatus(ctx context.Context, src *srapi.StarRocksCluster) error

UpdateClusterStatus update the all resource status about be.