cn

Documentation

Index

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

Types

type CnController

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

func New

func New(k8sClient client.Client) *CnController

func (*CnController) ClearResources

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

ClearResources clear the deployed resource about cn. statefulset, services, hpa.

func (*CnController) GetConfig

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

func (*CnController) GetControllerName

func (cc *CnController) GetControllerName() string

func (*CnController) Sync

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

func (*CnController) UpdateStatus

func (cc *CnController) UpdateStatus(src *srapi.StarRocksCluster) error