controller

package
v0.0.0-...-6f13191 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 18, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ResolveDorisRoleGroup

func ResolveDorisRoleGroup(
	ctx context.Context,
	k8sClient ctrlclient.Client,
	cr *dorisv1alpha1.DorisCluster,
	buildCtx *reconciler.RoleGroupBuildContext,
) (*reconciler.Contribution, error)

ResolveDorisRoleGroup supplies product config defaults beneath both user override levels.

Types

type DorisRoleGroupHandler

type DorisRoleGroupHandler struct {
	*reconciler.BaseRoleGroupHandler[*dorisv1alpha1.DorisCluster]
}

DorisRoleGroupHandler is the Gen 3 resource seam for all Doris roles. The framework owns reconciliation and apply ordering; this handler declares the product facts and preserves the workload identities created by the pre-v0.13 controller.

func NewDorisRoleGroupHandler

func NewDorisRoleGroupHandler(scheme *runtime.Scheme) *DorisRoleGroupHandler

func (*DorisRoleGroupHandler) BuildResources

func (*DorisRoleGroupHandler) BuildRolePodDisruptionBudget

func (h *DorisRoleGroupHandler) BuildRolePodDisruptionBudget(
	buildCtx *reconciler.RoleBuildContext,
) *policyv1.PodDisruptionBudget

func (*DorisRoleGroupHandler) DeclareRoles

type LegacyRoleServiceExtension

type LegacyRoleServiceExtension struct {
	// contains filtered or unexported fields
}

LegacyRoleServiceExtension owns the two legacy, role-wide Services independently of any role group. It also bridges the legacy workload label identity into the Gen 3 status-ledger and health contracts; see legacy_compatibility.go.

func NewLegacyRoleServiceExtension

func NewLegacyRoleServiceExtension(scheme *runtime.Scheme) *LegacyRoleServiceExtension

NewLegacyRoleServiceExtension creates the cluster extension for legacy role Services.

func (*LegacyRoleServiceExtension) Name

Name implements common.Extension.

func (*LegacyRoleServiceExtension) OnReconcileError

OnReconcileError implements common.ClusterExtension.

func (*LegacyRoleServiceExtension) PostReconcile

func (e *LegacyRoleServiceExtension) PostReconcile(
	ctx context.Context,
	k8sClient ctrlclient.Client,
	cluster *dorisv1alpha1.DorisCluster,
) error

PostReconcile implements common.ClusterExtension.

func (*LegacyRoleServiceExtension) PreReconcile

func (e *LegacyRoleServiceExtension) PreReconcile(
	ctx context.Context,
	k8sClient ctrlclient.Client,
	cluster *dorisv1alpha1.DorisCluster,
) error

PreReconcile creates or updates role-wide Services before role-group resources are reconciled. The Services carry only a cluster controller reference, never a role-group identity label, so role-group cleanup cannot claim them.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL