cn

Documentation

Index

• Constants
• type Controller
  • func New(k8sclient client.Client, k8srecorder record.EventRecorder) *Controller
  • func (cn *Controller) ClearResources(ctx context.Context, dcr *dorisv1.DorisCluster) (bool, error)
  • func (cn *Controller) DeleteAutoscaler(ctx context.Context, dcr *dorisv1.DorisCluster) error
  • func (cn *Controller) GetConfig(ctx context.Context, configMapInfo *dorisv1.ConfigMapInfo, namespace string) (map[string]interface{}, error)
  • func (cn *Controller) GetControllerName() string
  • func (cn *Controller) Sync(ctx context.Context, dcr *dorisv1.DorisCluster) error
  • func (cn *Controller) UpdateComponentStatus(cluster *dorisv1.DorisCluster) error

Constants

const (
	CN_SEARCH_SUFFIX = "-search"
)

Types

type Controller

type Controller struct {
	sub_controller.SubDefaultController
}

func New

func New(k8sclient client.Client, k8srecorder record.EventRecorder) *Controller

func (*Controller) ClearResources

func (cn *Controller) ClearResources(ctx context.Context, dcr *dorisv1.DorisCluster) (bool, error)

func (*Controller) DeleteAutoscaler

func (cn *Controller) DeleteAutoscaler(ctx context.Context, dcr *dorisv1.DorisCluster) error

func (*Controller) GetConfig

func (cn *Controller) GetConfig(ctx context.Context, configMapInfo *dorisv1.ConfigMapInfo, namespace string) (map[string]interface{}, error)

func (*Controller) GetControllerName

func (cn *Controller) GetControllerName() string

func (*Controller) Sync

func (cn *Controller) Sync(ctx context.Context, dcr *dorisv1.DorisCluster) error

func (*Controller) UpdateComponentStatus

func (cn *Controller) UpdateComponentStatus(cluster *dorisv1.DorisCluster) error