computegroups

Documentation

Index

• Constants
• type DisaggregatedComputeGroupsController
  • func New(mgr ctrl.Manager) *DisaggregatedComputeGroupsController
  • func (dcgs *DisaggregatedComputeGroupsController) ClearResources(ctx context.Context, obj client.Object) (bool, error)
  • func (dcgs *DisaggregatedComputeGroupsController) ClearStatefulsetUnusedPVCs(ctx context.Context, ddc *dv1.DorisDisaggregatedCluster, ...) error
  • func (dcgs *DisaggregatedComputeGroupsController) GetControllerName() string
  • func (dcgs *DisaggregatedComputeGroupsController) NewCGContainer(ddc *dv1.DorisDisaggregatedCluster, cvs map[string]interface{}, ...) corev1.Container
  • func (dcgs *DisaggregatedComputeGroupsController) NewPodTemplateSpec(ddc *dv1.DorisDisaggregatedCluster, selector map[string]string, ...) corev1.PodTemplateSpec
  • func (dcgs *DisaggregatedComputeGroupsController) NewStatefulset(ddc *dv1.DorisDisaggregatedCluster, cg *dv1.ComputeGroup, ...) *appv1.StatefulSet
  • func (dcgs *DisaggregatedComputeGroupsController) Sync(ctx context.Context, obj client.Object) error
  • func (dcgs *DisaggregatedComputeGroupsController) UpdateComponentStatus(obj client.Object) error

Constants

const (
	DefaultCacheRootPath = "/opt/apache-doris/be/file_cache"
	//default cache storage size: unit=B
	DefaultCacheSize               int64 = 107374182400
	FileCachePathKey                     = "file_cache_path"
	FileCacheSubConfigPathKey            = "path"
	FileCacheSubConfigTotalSizeKey       = "total_size"
	DefaultLogPath                       = "/opt/apache-doris/be/log"
	LogPathKey                           = "LOG_DIR"
	LogStoreName                         = "be-log"
	StorageStorePreName                  = "be-storage"
)

Types

type DisaggregatedComputeGroupsController

type DisaggregatedComputeGroupsController struct {
	sc.DisaggregatedSubDefaultController
}

func New

func New(mgr ctrl.Manager) *DisaggregatedComputeGroupsController

func (*DisaggregatedComputeGroupsController) ClearResources

func (dcgs *DisaggregatedComputeGroupsController) ClearResources(ctx context.Context, obj client.Object) (bool, error)

clear not configed cg resources, delete not configed cg status from ddc.status .

func (*DisaggregatedComputeGroupsController) ClearStatefulsetUnusedPVCs

func (dcgs *DisaggregatedComputeGroupsController) ClearStatefulsetUnusedPVCs(ctx context.Context, ddc *dv1.DorisDisaggregatedCluster, cgs dv1.ComputeGroupStatus) error

ClearStatefulsetUnusedPVCs 1.delete unused pvc skip cluster is Suspend 2.delete unused pvc for statefulset 3.delete pvc if not used by any statefulset

func (*DisaggregatedComputeGroupsController) GetControllerName

func (dcgs *DisaggregatedComputeGroupsController) GetControllerName() string

func (*DisaggregatedComputeGroupsController) NewCGContainer

func (dcgs *DisaggregatedComputeGroupsController) NewCGContainer(ddc *dv1.DorisDisaggregatedCluster, cvs map[string]interface{}, cg *dv1.ComputeGroup) corev1.Container

func (*DisaggregatedComputeGroupsController) NewPodTemplateSpec

func (dcgs *DisaggregatedComputeGroupsController) NewPodTemplateSpec(ddc *dv1.DorisDisaggregatedCluster, selector map[string]string, cvs map[string]interface{}, cg *dv1.ComputeGroup) corev1.PodTemplateSpec

func (*DisaggregatedComputeGroupsController) NewStatefulset

func (dcgs *DisaggregatedComputeGroupsController) NewStatefulset(ddc *dv1.DorisDisaggregatedCluster, cg *dv1.ComputeGroup, cvs map[string]interface{}) *appv1.StatefulSet

func (*DisaggregatedComputeGroupsController) Sync

func (dcgs *DisaggregatedComputeGroupsController) Sync(ctx context.Context, obj client.Object) error

func (*DisaggregatedComputeGroupsController) UpdateComponentStatus

func (dcgs *DisaggregatedComputeGroupsController) UpdateComponentStatus(obj client.Object) error