feproxy

Documentation

Index

• type FeProxyController
  • func New(k8sClient client.Client, recorderFor subcontrollers.GetEventRecorderForFunc) *FeProxyController
  • func (controller *FeProxyController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (controller *FeProxyController) GetControllerName() string
  • func (controller *FeProxyController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (controller *FeProxyController) SyncConfigMap(ctx context.Context, src *srapi.StarRocksCluster) error
  • func (controller *FeProxyController) UpdateClusterStatus(ctx context.Context, src *srapi.StarRocksCluster) error

Types

type FeProxyController

type FeProxyController struct {
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func New

func New(k8sClient client.Client, recorderFor subcontrollers.GetEventRecorderForFunc) *FeProxyController

New construct a FeController.

func (*FeProxyController) ClearResources

func (controller *FeProxyController) ClearResources(ctx context.Context, src *srapi.StarRocksCluster) error

ClearResources clear resource about fe.

func (*FeProxyController) GetControllerName

func (controller *FeProxyController) GetControllerName() string

func (*FeProxyController) SyncCluster

func (controller *FeProxyController) SyncCluster(ctx context.Context, src *srapi.StarRocksCluster) error

func (*FeProxyController) SyncConfigMap

func (controller *FeProxyController) SyncConfigMap(ctx context.Context, src *srapi.StarRocksCluster) error

func (*FeProxyController) UpdateClusterStatus

func (controller *FeProxyController) UpdateClusterStatus(ctx context.Context, src *srapi.StarRocksCluster) error

UpdateClusterStatus update the all resource status about fe.