be

Documentation

Index

• type BeController
  • func New(k8sClient client.Client, recorderFor subc.GetEventRecorderForFunc) *BeController
  • func (be *BeController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (be *BeController) GetConfig(ctx context.Context, configMapInfo *srapi.ConfigMapInfo, namespace string) (map[string]interface{}, error)
  • 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

Types

type BeController

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

func New

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

func (*BeController) ClearResources

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

func (*BeController) GetConfig

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

func (*BeController) GetControllerName

func (be *BeController) GetControllerName() string

func (*BeController) SyncCluster

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

func (*BeController) UpdateClusterStatus

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

UpdateClusterStatus update the all resource status about be.