fe

Documentation

Index

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

Variables

var (
	Default_Election_Number int32 = 3
)

Types

type Controller

type Controller struct {
	sub_controller.SubDefaultController
}

func New

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

New construct a FeController.

func (*Controller) ClearResources

func (fc *Controller) ClearResources(ctx context.Context, cluster *v1.DorisCluster) (bool, error)

func (*Controller) GetControllerName

func (fc *Controller) GetControllerName() string

func (*Controller) Sync

func (fc *Controller) Sync(ctx context.Context, cluster *v1.DorisCluster) error

Sync DorisCluster to fe statefulset and service.

func (*Controller) UpdateComponentStatus

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