disaggregated_fe

Documentation

Index

• Constants
• type DisaggregatedFEController
  • func New(mgr ctrl.Manager) *DisaggregatedFEController
  • func (dfc *DisaggregatedFEController) ClearResources(ctx context.Context, obj client.Object) (bool, error)
  • func (dfc *DisaggregatedFEController) GetControllerName() string
  • func (dfc *DisaggregatedFEController) NewFEContainer(ddc *v1.DorisDisaggregatedCluster, cvs map[string]interface{}) corev1.Container
  • func (dfc *DisaggregatedFEController) NewPodTemplateSpec(ddc *v1.DorisDisaggregatedCluster, confMap map[string]interface{}) corev1.PodTemplateSpec
  • func (dfc *DisaggregatedFEController) NewStatefulset(ddc *v1.DorisDisaggregatedCluster, confMap map[string]interface{}) *appv1.StatefulSet
  • func (dfc *DisaggregatedFEController) Sync(ctx context.Context, obj client.Object) error
  • func (dfc *DisaggregatedFEController) UpdateComponentStatus(obj client.Object) error

Constants

const (
	MS_ENDPOINT      string = "MS_ENDPOINT"
	STATEFULSET_NAME string = "STATEFULSET_NAME"
	CLUSTER_ID       string = "CLUSTER_ID"
)

const (
	DefaultMetaPath          = "/opt/apache-doris/fe/doris-meta"
	MetaPathKey              = "meta_dir"
	DefaultLogPath           = "/opt/apache-doris/fe/log"
	LogPathKey               = "LOG_DIR"
	LogStoreName             = "fe-log"
	MetaStoreName            = "fe-meta"
	DefaultStorageSize int64 = 107374182400
)

Types

type DisaggregatedFEController

type DisaggregatedFEController struct {
	sc.DisaggregatedSubDefaultController
}

func New

func New(mgr ctrl.Manager) *DisaggregatedFEController

func (*DisaggregatedFEController) ClearResources

func (dfc *DisaggregatedFEController) ClearResources(ctx context.Context, obj client.Object) (bool, error)

func (*DisaggregatedFEController) GetControllerName

func (dfc *DisaggregatedFEController) GetControllerName() string

func (*DisaggregatedFEController) NewFEContainer

func (dfc *DisaggregatedFEController) NewFEContainer(ddc *v1.DorisDisaggregatedCluster, cvs map[string]interface{}) corev1.Container

func (*DisaggregatedFEController) NewPodTemplateSpec

func (dfc *DisaggregatedFEController) NewPodTemplateSpec(ddc *v1.DorisDisaggregatedCluster, confMap map[string]interface{}) corev1.PodTemplateSpec

func (*DisaggregatedFEController) NewStatefulset

func (dfc *DisaggregatedFEController) NewStatefulset(ddc *v1.DorisDisaggregatedCluster, confMap map[string]interface{}) *appv1.StatefulSet

func (*DisaggregatedFEController) Sync

func (dfc *DisaggregatedFEController) Sync(ctx context.Context, obj client.Object) error

func (*DisaggregatedFEController) UpdateComponentStatus

func (dfc *DisaggregatedFEController) UpdateComponentStatus(obj client.Object) error