be

Documentation

Index

• type BeController
  • func New(k8sClient client.Client) *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) Sync(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (be *BeController) UpdateStatus(src *srapi.StarRocksCluster) error

Types

type BeController

type BeController struct {
	// contains filtered or unexported fields
}

func New

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

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

func (*BeController) UpdateStatus

func (be *BeController) UpdateStatus(src *srapi.StarRocksCluster) error

UpdateStatus update the all resource status about be.