computegroups

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) GetCG2LayerCommonSchedulerLabels ¶

func (dcgs *DisaggregatedComputeGroupsController) GetCG2LayerCommonSchedulerLabels(ddcName string) map[string]string

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