broker

Documentation

Index

• Constants
• type Controller
  • func New(k8sclient client.Client, k8srecorder record.EventRecorder) *Controller
  • func (bk *Controller) ClearResources(ctx context.Context, dcr *v1.DorisCluster) (bool, error)
  • func (bk *Controller) GetControllerName() string
  • func (bk *Controller) Sync(ctx context.Context, dcr *v1.DorisCluster) error
  • func (bk *Controller) UpdateComponentStatus(cluster *v1.DorisCluster) error

Constants

const (
	BROKER_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 (bk *Controller) ClearResources(ctx context.Context, dcr *v1.DorisCluster) (bool, error)

func (*Controller) GetControllerName

func (bk *Controller) GetControllerName() string

func (*Controller) Sync

func (bk *Controller) Sync(ctx context.Context, dcr *v1.DorisCluster) error

func (*Controller) UpdateComponentStatus

func (bk *Controller) UpdateComponentStatus(cluster *v1.DorisCluster) error